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

Class org.jboss.netty.buffer.ChannelBuffer

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

org.jboss.netty.buffer.ChannelBuffer.clear()
Sets the {@code readerIndex} and {@code writerIndex} of this buffer to{@code 0}. This method is identical to {@link #setIndex(int,int) setIndex(0, 0)}.
Please note that the behavior of this method is different from that of NIO buffer, which sets the {@code limit} tothe {@code capacity} of the buffer.

        ChannelBuffer buffer0 = null;


        buffer0 = ChannelBuffers.dynamicBuffer(10);


        // handle null case
        buffer0.clear();
        ChannelBufferUtil.writeTlv(buffer0, tlv0);
        Assert.assertArrayEquals(HexUtil.toByteArray(""), BufferHelper.createByteArray(buffer0));


        buffer0.clear();
        tlv0 = new Tlv((short)0xFFFF, new byte[] { 0x41, 0x42 });

View Full Code Here

        // handle null case
        buffer0.clear();
        ChannelBufferUtil.writeTlv(buffer0, tlv0);
        Assert.assertArrayEquals(HexUtil.toByteArray(""), BufferHelper.createByteArray(buffer0));


        buffer0.clear();
        tlv0 = new Tlv((short)0xFFFF, new byte[] { 0x41, 0x42 });
        ChannelBufferUtil.writeTlv(buffer0, tlv0);
        Assert.assertArrayEquals(HexUtil.toByteArray("FFFF00024142"), BufferHelper.createByteArray(buffer0));
    }

View Full Code Here

        ChannelBuffer buffer0 = null;


        buffer0 = ChannelBuffers.dynamicBuffer(10);


        // handle null case
        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, addr0);
        Assert.assertArrayEquals(HexUtil.toByteArray("000000"), BufferHelper.createByteArray(buffer0));


        // handle default address
        buffer0.clear();

View Full Code Here

        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, addr0);
        Assert.assertArrayEquals(HexUtil.toByteArray("000000"), BufferHelper.createByteArray(buffer0));


        // handle default address
        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, new Address());
        Assert.assertArrayEquals(HexUtil.toByteArray("000000"), BufferHelper.createByteArray(buffer0));


        // handle some stuff in address
        buffer0.clear();

View Full Code Here

        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, new Address());
        Assert.assertArrayEquals(HexUtil.toByteArray("000000"), BufferHelper.createByteArray(buffer0));


        // handle some stuff in address
        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, new Address((byte)0x01, (byte)0x02, ""));
        Assert.assertArrayEquals(HexUtil.toByteArray("010200"), BufferHelper.createByteArray(buffer0));


        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, new Address((byte)0x01, (byte)0x02, "ABC"));

View Full Code Here

        // handle some stuff in address
        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, new Address((byte)0x01, (byte)0x02, ""));
        Assert.assertArrayEquals(HexUtil.toByteArray("010200"), BufferHelper.createByteArray(buffer0));


        buffer0.clear();
        ChannelBufferUtil.writeAddress(buffer0, new Address((byte)0x01, (byte)0x02, "ABC"));
        Assert.assertArrayEquals(HexUtil.toByteArray("010241424300"), BufferHelper.createByteArray(buffer0));
    }
}

View Full Code Here


          // If exceeded chunk size limit, send a new chunk.
          if (buffer.readableBytes() >= CHUNK_SIZE) {
            // No way to know if it is ok to send chunk or not. See ENG-4168
            responder.sendChunk(buffer);
            buffer.clear();
          }
        }
        events.clear();


        if (limit > 0) {

View Full Code Here

                        @Override
                        public void operationComplete(ChannelFuture future)
                                throws Exception
                        {
                            if (future.isSuccess()) {
                                channelBuffer.clear();
                                if (writeBuffers.size() < MAX_BUFFERS_IN_QUEUE) {
                                    writeBuffers.add(channelBuffer);
                                }
                            }
                        }

View Full Code Here

                partialRequest.add( buffer );
                bufferToReadFrom = targetBuffers.first();
                bufferToWriteTo = ChannelBuffers.dynamicBuffer();
            }


            bufferToWriteTo.clear();
            final ChunkingChannelBuffer chunkingBuffer = new ChunkingChannelBuffer( bufferToWriteTo, channel, MAX_FRAME_LENGTH );
            Response<R> response = type.getMasterCaller().callMaster( realMaster, context, bufferToReadFrom, chunkingBuffer );
            executor.submit( responseWriter( type, channel, context, chunkingBuffer, targetBuffers.other(), response ) );
        }
    }

View Full Code Here

                        @Override
                        public void operationComplete(ChannelFuture future)
                                throws Exception
                        {
                            if (future.isSuccess()) {
                                channelBuffer.clear();
                                if (writeBuffers.size() < MAX_BUFFERS_IN_QUEUE) {
                                    writeBuffers.add(channelBuffer);
                                }
                            }
                        }

View Full Code Here

0 1 2 3

TOP

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.