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.

        TestCase.assertEquals(1, ofr.getPorts().size());
        TestCase.assertEquals("eth0", ofr.getPorts().get(0).getName());


        // test a 15 character name
        ofr.getPorts().get(0).setName("012345678901234");
        bb.clear();
        ofr.writeTo(bb);
        ofr.readFrom(bb);
        TestCase.assertEquals("012345678901234", ofr.getPorts().get(0).getName());


        // test a 16 character name getting truncated

View Full Code Here

        ofr.readFrom(bb);
        TestCase.assertEquals("012345678901234", ofr.getPorts().get(0).getName());


        // test a 16 character name getting truncated
        ofr.getPorts().get(0).setName("0123456789012345");
        bb.clear();
        ofr.writeTo(bb);
        ofr.readFrom(bb);
        TestCase.assertEquals("012345678901234", ofr.getPorts().get(0).getName());
    }
}

View Full Code Here

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

View Full Code Here

    }
    
    public void testWriteRead() throws Exception {
        OFVendor msg = makeVendorMessage(1);
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(1, msg.getVendor());
    }

View Full Code Here

        OFVendor msg = makeVendorMessage(ACME_VENDOR_ID);
        OFVendorData vendorData = new AcmeVendorData1((short)11, (short)22);
        msg.setVendorData(vendorData);
        msg.setLengthU(OFVendor.MINIMUM_LENGTH + vendorData.getLength());
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        assertEquals(ACME_VENDOR_ID, msg.getVendor());
        AcmeVendorData1 vendorData1 = (AcmeVendorData1) msg.getVendorData();
        assertEquals(11, vendorData1.getFlags());

View Full Code Here

        assertEquals(22, vendorData1.getValue());
        
        vendorData = new AcmeVendorData2(33, 44);
        msg.setVendorData(vendorData);
        msg.setLengthU(OFVendor.MINIMUM_LENGTH + vendorData.getLength());
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        assertEquals(ACME_VENDOR_ID, msg.getVendor());
        AcmeVendorData2 vendorData2 = (AcmeVendorData2) msg.getVendorData();
        assertEquals(33, vendorData2.getType());

View Full Code Here

        msg.setVendor(DUMMY_VENDOR_ID);
        byte[] genericVendorDataBytes = new byte[] {0x55, 0x66};
        vendorData = new OFByteArrayVendorData(genericVendorDataBytes);
        msg.setVendorData(vendorData);
        msg.setLengthU(OFVendor.MINIMUM_LENGTH + vendorData.getLength());
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        assertEquals(DUMMY_VENDOR_ID, msg.getVendor());
        OFByteArrayVendorData genericVendorData = (OFByteArrayVendorData) msg.getVendorData();
        assertTrue(Arrays.equals(genericVendorDataBytes, genericVendorData.getBytes()));

View Full Code Here

        byte[] hwAddr = new byte[6];
        msg.getMatch().setDataLayerDestination(hwAddr);
        msg.getMatch().setDataLayerSource(hwAddr);
        msg.setReason(OFFlowRemovedReason.OFPRR_DELETE);
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFType.FLOW_REMOVED, msg.getType());
        TestCase.assertEquals(OFFlowRemovedReason.OFPRR_DELETE, msg.getReason());
    }

View Full Code Here

        msg.setMessageFactory(messageFactory);
        msg.setErrorType(OFErrorType.OFPET_HELLO_FAILED.getValue());
        msg.setErrorCode((short) OFHelloFailedCode.OFPHFC_INCOMPATIBLE
                .ordinal());
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFErrorType.OFPET_HELLO_FAILED.getValue(),
                msg.getErrorType());
        TestCase.assertEquals((short) OFHelloFailedCode.OFPHFC_INCOMPATIBLE

View Full Code Here

        TestCase.assertEquals((short) OFHelloFailedCode.OFPHFC_INCOMPATIBLE
                .ordinal(), msg.getErrorType());
        TestCase.assertNull(msg.getOffendingMsg());


        msg.setOffendingMsg(new OFHello());
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFErrorType.OFPET_HELLO_FAILED.getValue(),
                msg.getErrorType());
        TestCase.assertEquals((short) OFHelloFailedCode.OFPHFC_INCOMPATIBLE

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.