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 buffer = ChannelBuffers.buffer(1024 * 1024);
        for (int startDiff = -16384; startDiff < 16384; startDiff++) {
            for (int commitDiff = -512; commitDiff < 512; commitDiff++) {
                long st = zipper.lastStartTimestamp + startDiff;
                long ct = zipper.lastCommitTimestamp + commitDiff;
                buffer.clear();
                zipper.encodeCommit(buffer, st, ct);
                TSOMessage msg = dezipper.decodeMessage(buffer);
                assertThat(msg, is(CommittedTransactionReport.class));
                CommittedTransactionReport ctr = (CommittedTransactionReport) msg;
                assertThat("startDiff: " + startDiff + " commitDiff: " + commitDiff, ctr.commitTimestamp, is(ct));

View Full Code Here

        Zipper zipper = new Zipper();
        Zipper dezipper = new Zipper();
        ChannelBuffer buffer = ChannelBuffers.buffer(1024 * 1024);
        for (int tsDiff = -1024 * 1024; tsDiff < 1024 * 1024; tsDiff++) {
            long st = zipper.lastStartTimestamp + tsDiff;
            buffer.clear();
            zipper.encodeHalfAbort(buffer, st);
            zipper.encodeFullAbort(buffer, st);
            TSOMessage msg = dezipper.decodeMessage(buffer);
            assertThat(msg, is(AbortedTransactionReport.class));
            AbortedTransactionReport atr = (AbortedTransactionReport) msg;

View Full Code Here

        if (corkedBuffers.containsKey(opaque)) {
            ChannelBuffer corkedResponse = corkedBuffers.get(opaque);
            ChannelBuffer oldBuffer = corkedResponse;
            corkedResponse = ChannelBuffers.buffer(ByteOrder.BIG_ENDIAN, totalCapacity + corkedResponse.capacity());
            corkedResponse.writeBytes(oldBuffer);
            oldBuffer.clear();


            corkedBuffers.remove(opaque);
            corkedBuffers.put(opaque, corkedResponse);
            return corkedResponse;
        } else {

View Full Code Here

    for (int i1 = 0; i1 < 2; i1++) {
      for (int i2 = 0; i2 < 5; i2++) {
        byte[] rk = new byte[10];


        ChannelBuffer buf = ChannelBuffers.wrappedBuffer(rk);
        buf.clear();
        buf.writeShort((short) 2);
        buf.writeInt(i1);
        buf.writeInt(i2);


        for (int c = 0; c < 5; c++) {

View Full Code Here


  private void runTest(HTable hTable, int cqStart, int expectedSize) throws IOException {
    // [0, 2, ?, ?, ?, ?, 0, 0, 0, 1]
    byte[] fuzzyKey = new byte[10];
    ChannelBuffer buf = ChannelBuffers.wrappedBuffer(fuzzyKey);
    buf.clear();
    buf.writeShort((short) 2);
    for (int i = 0; i < 4; i++)
      buf.writeByte((short)63);
    buf.writeInt((short)1);

View Full Code Here

        msg.setDesc(new OFPhysicalPort());
        msg.getDesc().setHardwareAddress(new byte[6]);
        msg.getDesc().setName("eth0");
        msg.setReason((byte) OFPortReason.OFPPR_ADD.ordinal());
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFType.PORT_STATUS, msg.getType());
        TestCase.assertEquals((byte) OFPortReason.OFPPR_ADD.ordinal(), msg
                .getReason());

View Full Code Here

    public void testWriteRead() throws Exception {
        OFGetConfigReply msg = (OFGetConfigReply) messageFactory
                .getMessage(OFType.GET_CONFIG_REPLY);
        msg.setFlags((short) 1);
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFType.GET_CONFIG_REPLY, msg.getType());
        TestCase.assertEquals((short)1, msg.getFlags());
    }

View Full Code Here

public class OFGetConfigRequestTest extends OFTestCase {
    public void testWriteRead() throws Exception {
        OFGetConfigRequest msg = (OFGetConfigRequest) messageFactory
                .getMessage(OFType.GET_CONFIG_REQUEST);
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFType.GET_CONFIG_REQUEST, msg.getType());
    }
}

View Full Code Here

public class OFBarrierReplyTest extends OFTestCase {
    public void testWriteRead() throws Exception {
        OFBarrierReply msg = (OFBarrierReply) messageFactory
                .getMessage(OFType.BARRIER_REPLY);
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFType.BARRIER_REPLY, msg.getType());
    }
}

View Full Code Here

        port.setHardwareAddress(new byte[6]);
        port.setName("eth0");
        ports.add(port);
        ofr.setPorts(ports);
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        ofr.writeTo(bb);
        ofr.readFrom(bb);
        TestCase.assertEquals(1, ofr.getPorts().size());
        TestCase.assertEquals("eth0", ofr.getPorts().get(0).getName());

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.