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

Class org.jboss.netty.buffer.ChannelBuffer

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

org.jboss.netty.buffer.ChannelBuffer.writeShort()
Sets the specified 16-bit short integer at the current {@code writerIndex} and increases the {@code writerIndex} by {@code 2}in this buffer. @throws IndexOutOfBoundsException if {@code this.writableBytes} is less than {@code 2}

            int length = data.readableBytes();
            if (length < 126) {
                encoded.writeByte(length);
            } else if (length < 65535) {
                encoded.writeByte(126);
                encoded.writeShort(length);
            } else {
                encoded.writeByte(127);
                encoded.writeInt(length);
            }

View Full Code Here

    }


    ChannelBuffer result = ChannelBuffers.buffer(BinaryProtocol.BYTE_ORDER, resultSize);
    result.writeByte(_errorCode);
    result.writeInt(resultSize - 1 - 4);
    result.writeShort(classLen);
    result.writeBytes(causeClass, 0, classLen);
    result.writeShort(messageLen);
    if (messageLen > 0)
    {
      result.writeBytes(causeMessage, 0, messageLen);

View Full Code Here

    ChannelBuffer result = ChannelBuffers.buffer(BinaryProtocol.BYTE_ORDER, resultSize);
    result.writeByte(_errorCode);
    result.writeInt(resultSize - 1 - 4);
    result.writeShort(classLen);
    result.writeBytes(causeClass, 0, classLen);
    result.writeShort(messageLen);
    if (messageLen > 0)
    {
      result.writeBytes(causeMessage, 0, messageLen);
    }

View Full Code Here

      {
        stringBuffer = new StringEncoderWrapper(charSet).encode(msg);
      }
      int length = stringBuffer.readableBytes();
      ChannelBuffer lengthBuffer = ChannelBuffers.buffer(2);
      lengthBuffer.writeShort(length);
      buffer = ChannelBuffers.wrappedBuffer(lengthBuffer,stringBuffer);
    }
    catch (Exception e)
    {
      throw new RuntimeException(e);

View Full Code Here

    {
      throw new RuntimeException(e);
    }
    int length = objectBuffer.readableBytes();
    ChannelBuffer lengthBuffer = ChannelBuffers.buffer(2);
    lengthBuffer.writeShort(length);
    buffer = ChannelBuffers.wrappedBuffer(lengthBuffer, objectBuffer);
    return buffer;
  }


  /**

View Full Code Here

        charset = CharsetUtil.UTF_8;
      }
      stringBuffer = copiedBuffer(ByteOrder.BIG_ENDIAN, msg, charset);
      int length = stringBuffer.readableBytes();
      ChannelBuffer lengthBuffer = ChannelBuffers.buffer(2);
      lengthBuffer.writeShort(length);
      buffer = ChannelBuffers.wrappedBuffer(lengthBuffer, stringBuffer);
    }
    catch (Exception e)
    {
      LOG.error("Error occurred while trying to write string buffer: {}",

View Full Code Here

    try 
    {
      ChannelBuffer objectBuffer = converter.convert(object);
      int length = objectBuffer.readableBytes();
      ChannelBuffer lengthBuffer = ChannelBuffers.buffer(2);
      lengthBuffer.writeShort(length);
      buffer = ChannelBuffers.wrappedBuffer(lengthBuffer,
          objectBuffer);
    } catch (Exception e) {
      LOG.error("Error occurred while writing object to buffer: {}", e);
    }

View Full Code Here

        charset = CharsetUtil.UTF_8;
      }
      stringBuffer = copiedBuffer(ByteOrder.BIG_ENDIAN, msg, charset);
      int length = stringBuffer.readableBytes();
      ChannelBuffer lengthBuffer = ChannelBuffers.buffer(2);
      lengthBuffer.writeShort(length);
      buffer = ChannelBuffers.wrappedBuffer(lengthBuffer, stringBuffer);
    }
    catch (Exception e)
    {
      throw new RuntimeException(e);

View Full Code Here

    {
      throw new RuntimeException(e);
    }
    int length = objectBuffer.readableBytes();
    ChannelBuffer lengthBuffer = ChannelBuffers.buffer(2);
    lengthBuffer.writeShort(length);
    buffer = ChannelBuffers.wrappedBuffer(lengthBuffer, objectBuffer);
    return buffer;
  }


  /**

View Full Code Here

        ChannelBuffer header = ChannelBuffers.buffer(ByteOrder.BIG_ENDIAN, 24);
        header.writeByte((byte)0x81);  // magic
        header.writeByte(bcmd.code); // opcode
        short keyLength = (short) (keyBuffer != null ? keyBuffer.capacity() :0);


        header.writeShort(keyLength);
        int extrasLength = extrasBuffer != null ? extrasBuffer.capacity() : 0;
        header.writeByte((byte) extrasLength); // extra length = flags + expiry
        header.writeByte((byte)0); // data type unused
        header.writeShort(responseCode); // status code

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.