Package org.jboss.netty.buffer

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

372
373
374
375
376
377
378
379
380
381
382
                if (log.isTraceEnabled()) {
                    log.trace(this + " send add read=" + next.length);
                }
                StreamService.readBytes.addAndGet(next.length);
                ChannelBuffer buf = getSendBuffer(next.length + StreamService.STREAM_BYTE_OVERHEAD);
                buf.writeByte(StreamService.MODE_MORE);
                buf.writeBytes(next);
                int bytesSent = send(buf, sender);
                sendRemain.addAndGet(-bytesSent);
                sentBytes += bytesSent;
                if (log.isTraceEnabled()) {
View Full Code Here
249
250
251
252
253
254
255
256
257
258
259
    public static ChannelBuffer inetToCB(InetSocketAddress inet)
    {
        byte[] address = inet.getAddress().getAddress();
        ChannelBuffer cb = ChannelBuffers.buffer(1 + address.length + 4);
        cb.writeByte(address.length);
        cb.writeBytes(address);
        cb.writeInt(inet.getPort());
        return cb;
    }
View Full Code Here
177
178
179
180
181
182
183
184
185
186
187
            Frame frame = (Frame)msg;

            ChannelBuffer header = ChannelBuffers.buffer(Frame.Header.LENGTH);
            Message.Type type = frame.header.type;
            header.writeByte(type.direction.addToVersion(frame.header.version));
            header.writeByte(Header.Flag.serialize(frame.header.flags));
            header.writeByte(frame.header.streamId);
            header.writeByte(type.opcode);
            header.writeInt(frame.body.readableBytes());
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
            Frame frame = (Frame)msg;

            ChannelBuffer header = ChannelBuffers.buffer(Frame.Header.LENGTH);
            Message.Type type = frame.header.type;
            header.writeByte(type.direction.addToVersion(frame.header.version));
            header.writeByte(Header.Flag.serialize(frame.header.flags));
            header.writeByte(frame.header.streamId);
            header.writeByte(type.opcode);
            header.writeInt(frame.body.readableBytes());

            return ChannelBuffers.wrappedBuffer(header, frame.body);
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
            ChannelBuffer header = ChannelBuffers.buffer(Frame.Header.LENGTH);
            Message.Type type = frame.header.type;
            header.writeByte(type.direction.addToVersion(frame.header.version));
            header.writeByte(Header.Flag.serialize(frame.header.flags));
            header.writeByte(frame.header.streamId);
            header.writeByte(type.opcode);
            header.writeInt(frame.body.readableBytes());

            return ChannelBuffers.wrappedBuffer(header, frame.body);
        }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
            ChannelBuffer header = ChannelBuffers.buffer(Frame.Header.LENGTH);
            Message.Type type = frame.header.type;
            header.writeByte(type.direction.addToVersion(frame.header.version));
            header.writeByte(Header.Flag.serialize(frame.header.flags));
            header.writeByte(frame.header.streamId);
            header.writeByte(type.opcode);
            header.writeInt(frame.body.readableBytes());

            return ChannelBuffers.wrappedBuffer(header, frame.body);
        }
    }
View Full Code Here
15
16
17
18
19
20
21
22
23
24
25
  public void testOverlyLongIdentity() throws Exception {
    byte[] overlyLong = new byte[256];
    Arrays.fill(overlyLong, (byte) 'a');
    ChannelBuffer buffer = ChannelBuffers.dynamicBuffer();
    ZMTPUtils.encodeLength(overlyLong.length + 1, buffer);
    buffer.writeByte(0);
    buffer.writeBytes(overlyLong);
    try {
      Assert.assertArrayEquals(overlyLong, CodecBase.readZMTP1RemoteIdentity(buffer));
      Assert.fail("Should have thrown exception");
    } catch (ZMTPException e) {
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
  }

  @Test
  public void testLongZMTP1FrameLengthMissingLong() {
    ChannelBuffer buffer = ChannelBuffers.dynamicBuffer();
    buffer.writeByte(0xFF);
    long size = ZMTPUtils.decodeLength(buffer);
    Assert.assertEquals("Length shouldn't have been determined",
                        -1, size);
  }
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
  }

  @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
72
73
74
75
76
77
78
79
80
81
82
      (ThreadPoolExecutor) Executors.newFixedThreadPool(CPUS), 0, SECONDS);

  @Test
  public void testZMTP1LongFrameSize() throws ZMTPMessageParsingException {
    ChannelBuffer buffer = ChannelBuffers.dynamicBuffer();
    buffer.writeByte(0xFF);
    ZMTPMessageParser parser = new ZMTPMessageParser(false, 1024, 1);
    ZMTPParsedMessage msg = parser.parse(buffer);
    assertNull("Message shouldn't be parsed for missing frame size",
               msg);
  }
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.