Package org.jboss.netty.buffer

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

27
28
29
30
31
32
33
34
35
36
37
    public void testWriteRead() throws Exception {
        OFSetConfig msg = (OFSetConfig) messageFactory
                .getMessage(OFType.SET_CONFIG);
        msg.setFlags((short) 1);
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFType.SET_CONFIG, msg.getType());
        TestCase.assertEquals((short)1, msg.getFlags());
    }
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
        OFPortMod msg = (OFPortMod) messageFactory
                .getMessage(OFType.PORT_MOD);
        msg.setHardwareAddress(new byte[6]);
        msg.portNumber = 1;
        ChannelBuffer bb = ChannelBuffers.dynamicBuffer();
        bb.clear();
        msg.writeTo(bb);
        msg.readFrom(bb);
        TestCase.assertEquals(OFType.PORT_MOD, msg.getType());
        TestCase.assertEquals(1, msg.getPortNumber());
    }
View Full Code Here
1720
1721
1722
1723
1724
1725
1726
1727
1728
1729
1730
                                                   };

  /** Common part of the hello header: magic + version.  */
  private ChannelBuffer commonHeader(final byte[] buf, final byte[] hrpc) {
    final ChannelBuffer header = ChannelBuffers.wrappedBuffer(buf);
    header.clear();  // Set the writerIndex to 0.

    // Magic header.  See HBaseClient#writeHeader
    // "hrpc" followed by the version.
    // See HBaseServer#HEADER and HBaseServer#CURRENT_VERSION.
    header.writeBytes(hrpc);  // for 0.94 and earlier: 4 + 1. For 0.95+: 4 + 2
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
    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
131
132
133
134
135
136
137
138
139
140
141
  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
108
109
110
111
112
113
114
115
116
117
118
                        @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
198
199
200
201
202
203
204
205
206
207
208
                        + (keyBuffer != null ? keyBuffer.capacity() : 0) + (valueBuffer != null ? valueBuffer.capacity() : 0);
                if (corkedResponse != null) {
                    ChannelBuffer oldBuffer = corkedResponse;
                    corkedResponse = ChannelBuffers.buffer(ByteOrder.BIG_ENDIAN, totalCapacity);
                    corkedResponse.writeBytes(oldBuffer);
                    oldBuffer.clear();
                } else {
                    corkedResponse = ChannelBuffers.buffer(ByteOrder.BIG_ENDIAN, totalCapacity);
                }

                corkedResponse.writeBytes(headerBuffer);
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
    @Test
    public void writeNullTerminatedString() throws Exception {
        ChannelBuffer buffer0 = ChannelBuffers.dynamicBuffer(10);

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

        buffer0.clear();
        ChannelBufferUtil.writeNullTerminatedString(buffer0, "");
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
        // handle null case
        buffer0.clear();
        ChannelBufferUtil.writeNullTerminatedString(buffer0, null);
        Assert.assertArrayEquals(HexUtil.toByteArray("00"), BufferHelper.createByteArray(buffer0));

        buffer0.clear();
        ChannelBufferUtil.writeNullTerminatedString(buffer0, "");
        Assert.assertArrayEquals(HexUtil.toByteArray("00"), BufferHelper.createByteArray(buffer0));

        buffer0.clear();
        ChannelBufferUtil.writeNullTerminatedString(buffer0, "A");
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
        buffer0.clear();
        ChannelBufferUtil.writeNullTerminatedString(buffer0, "");
        Assert.assertArrayEquals(HexUtil.toByteArray("00"), BufferHelper.createByteArray(buffer0));

        buffer0.clear();
        ChannelBufferUtil.writeNullTerminatedString(buffer0, "A");
        Assert.assertArrayEquals(HexUtil.toByteArray("4100"), BufferHelper.createByteArray(buffer0));
    }

    @Test
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.