Package org.jboss.netty.buffer

Examples of org.jboss.netty.buffer.ChannelBuffer.writeLong()

320
321
322
323
324
325
326
327
328
329
330
            tmpEntry.writeInt(totalHeaderSize - 4);

            tmpEntry.writeInt(new PacketHeader(BookieProtocol.CURRENT_PROTOCOL_VERSION,
                                               BookieProtocol.READENTRY, BookieProtocol.FLAG_NONE).toInt());
            tmpEntry.writeLong(ledgerId);
            tmpEntry.writeLong(entryId);

            ChannelFuture future = channel.write(tmpEntry);
            future.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture future) throws Exception {
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
        // This will need to updated if the protocol for read changes
        ChannelBuffer tmpEntry = bc.channel.getConfig().getBufferFactory().getBuffer(totalHeaderSize);
        tmpEntry.writeInt(totalHeaderSize - 4);
        tmpEntry.writeInt(new BookieProtocol.PacketHeader((byte)version, BookieProtocol.READENTRY, (short)0).toInt());
        tmpEntry.writeLong(1);
        tmpEntry.writeLong(1);
       
       
        bc.channel.write(tmpEntry).awaitUninterruptibly();
        readLatch.await(5, TimeUnit.SECONDS);
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
        // This will need to updated if the protocol for read changes
        ChannelBuffer tmpEntry = bc.channel.getConfig().getBufferFactory().getBuffer(totalHeaderSize);
        tmpEntry.writeInt(totalHeaderSize - 4);
        tmpEntry.writeInt(new BookieProtocol.PacketHeader((byte)version, BookieProtocol.READENTRY, (short)0).toInt());
        tmpEntry.writeLong(1);
        tmpEntry.writeLong(1);
       
       
        bc.channel.write(tmpEntry).awaitUninterruptibly();
        readLatch.await(5, TimeUnit.SECONDS);
        assertEquals("Expected result differs", expectedresult, outerrc.get());
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        ChannelBuffer outBuf = ctx.getChannel().getConfig().getBufferFactory()
                               .getBuffer(24);
        outBuf.writeInt(type);
        outBuf.writeInt(0); // rc
        outBuf.writeLong(ledgerId);
        outBuf.writeLong(entryId);
        e.getChannel().write(outBuf);

    }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        ChannelBuffer outBuf = ctx.getChannel().getConfig().getBufferFactory()
                               .getBuffer(24);
        outBuf.writeInt(type);
        outBuf.writeInt(0); // rc
        outBuf.writeLong(ledgerId);
        outBuf.writeLong(entryId);
        e.getChannel().write(outBuf);

    }

View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
  @Test
  public void testLongZMTP1FrameLengthWithLong() {
    ChannelBuffer buffer = ChannelBuffers.dynamicBuffer();
    buffer.writeByte(0xFF);
    buffer.writeLong(4);
    long size = ZMTPUtils.decodeLength(buffer);
    Assert.assertEquals("Frame length should be after the first byte",
                        4, size);
  }
View Full Code Here
19
20
21
22
23
24
25
26
27
28
29
  }

  @Override
  public ChannelBuffer encode(TimeMessage message) throws IOException {
    ChannelBuffer buffer = ChannelBuffers.buffer(8);
    buffer.writeLong(message.getTime());
    return buffer;
  }

}
View Full Code Here
157
158
159
160
161
162
163
164
165
166
167
        long ledger = getValidLedgerId(servers);
        for(long entry = 0; entry < warmUpCount; entry++) {
            ChannelBuffer toSend = ChannelBuffers.buffer(size);
            toSend.resetReaderIndex();
            toSend.resetWriterIndex();
            toSend.writeLong(ledger);
            toSend.writeLong(entry);
            toSend.writerIndex(toSend.capacity());
            bc.addEntry(new InetSocketAddress(addr, port), ledger, new byte[20],
                        entry, toSend, tc, null, BookieProtocol.FLAG_NONE);
        }
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
        for(long entry = 0; entry < warmUpCount; entry++) {
            ChannelBuffer toSend = ChannelBuffers.buffer(size);
            toSend.resetReaderIndex();
            toSend.resetWriterIndex();
            toSend.writeLong(ledger);
            toSend.writeLong(entry);
            toSend.writerIndex(toSend.capacity());
            bc.addEntry(new InetSocketAddress(addr, port), ledger, new byte[20],
                        entry, toSend, tc, null, BookieProtocol.FLAG_NONE);
        }
        LOG.info("Waiting for warmup");
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
        long startTime = System.nanoTime();
        for(long entry = 0; entry < entryCount; entry++) {
            ChannelBuffer toSend = ChannelBuffers.buffer(size);
            toSend.resetReaderIndex();
            toSend.resetWriterIndex();
            toSend.writeLong(ledger);
            toSend.writeLong(entry);
            toSend.writerIndex(toSend.capacity());
            lc.resetComplete();
            bc.addEntry(new InetSocketAddress(addr, port), ledger, new byte[20],
                        entry, toSend, lc, null, BookieProtocol.FLAG_NONE);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.