com.couchbase.client.deps.io.netty.buffer.ByteBuf.writeInt()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(157)

本文整理了Java中com.couchbase.client.deps.io.netty.buffer.ByteBuf.writeInt()方法的一些代码示例，展示了ByteBuf.writeInt()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ByteBuf.writeInt()方法的具体详情如下：
包路径：com.couchbase.client.deps.io.netty.buffer.ByteBuf
类名称：ByteBuf
方法名：writeInt

ByteBuf.writeInt介绍

[英]Sets the specified 32-bit integer at the current writerIndexand increases the writerIndex by 4 in this buffer.
[中]在当前writerIndex处设置指定的32位整数，并在此缓冲区中将writerIndex增加4。

代码示例

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public ByteBuf writeInt(int value) {
  3.   buf.writeInt(value);
  4.   return this;
  5. }

代码示例来源：origin: com.couchbase.client/core-io

  1. /**
  2.  * Creates a new 4-byte big-endian buffer that holds the specified 32-bit integer.
  3.  */
  4. public static ByteBuf copyInt(int value) {
  5.   ByteBuf buf = buffer(4);
  6.   buf.writeInt(value);
  7.   return buf;
  8. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. public ByteBuf writeInt(int value) {
  3.   buf.writeInt(ByteBufUtil.swapInt(value));
  4.   return this;
  5. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. /**
  2.  * Creates a new 4-byte big-endian buffer that holds the specified 32-bit integer.
  3.  */
  4. public static ByteBuf copyInt(int value) {
  5.   ByteBuf buf = buffer(4);
  6.   buf.writeInt(value);
  7.   return buf;
  8. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public ByteBuf writeInt(int value) {
  3.   buf.writeInt(ByteBufUtil.swapInt(value));
  4.   return this;
  5. }

代码示例来源：origin: com.couchbase.client/core-io

  1. public ByteBuf encodeRstStreamFrame(ByteBufAllocator allocator, int streamId, int statusCode) {
  2.   byte flags = 0;
  3.   int length = 8;
  4.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  5.   writeControlFrameHeader(frame, SPDY_RST_STREAM_FRAME, flags, length);
  6.   frame.writeInt(streamId);
  7.   frame.writeInt(statusCode);
  8.   return frame;
  9. }

代码示例来源：origin: com.couchbase.client/core-io

  1. public ByteBuf encodeGoAwayFrame(ByteBufAllocator allocator, int lastGoodStreamId, int statusCode) {
  2.   byte flags = 0;
  3.   int length = 8;
  4.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  5.   writeControlFrameHeader(frame, SPDY_GOAWAY_FRAME, flags, length);
  6.   frame.writeInt(lastGoodStreamId);
  7.   frame.writeInt(statusCode);
  8.   return frame;
  9. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. public ByteBuf encodeRstStreamFrame(ByteBufAllocator allocator, int streamId, int statusCode) {
  2.   byte flags = 0;
  3.   int length = 8;
  4.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  5.   writeControlFrameHeader(frame, SPDY_RST_STREAM_FRAME, flags, length);
  6.   frame.writeInt(streamId);
  7.   frame.writeInt(statusCode);
  8.   return frame;
  9. }

代码示例来源：origin: couchbase/java-dcp-client

  1. /**
  2.  * Initialize the buffer with all the values needed.
  3.  *
  4.  * Note that this will implicitly set the flags to "consumer".
  5.  */
  6. public static void init(final ByteBuf buffer) {
  7.   MessageUtil.initRequest(OPEN_CONNECTION_OPCODE, buffer);
  8.   ByteBuf extras = Unpooled.buffer(8);
  9.   MessageUtil.setExtras(extras.writeInt(0).writeInt(Type.PRODUCER.value), buffer);
  10.   extras.release();
  11. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. /**
  2.    * Calculates and writes the 4-byte checksum to the output buffer
  3.    *
  4.    * @param slice The data to calculate the checksum for
  5.    * @param out The output buffer to write the checksum to
  6.    */
  7.   private static void calculateAndWriteChecksum(ByteBuf slice, ByteBuf out) {
  8.     out.writeInt(ByteBufUtil.swapInt(calculateChecksum(slice)));
  9.   }
  10. }

代码示例来源：origin: com.couchbase.client/core-io

  1. /**
  2.    * Calculates and writes the 4-byte checksum to the output buffer
  3.    *
  4.    * @param slice The data to calculate the checksum for
  5.    * @param out The output buffer to write the checksum to
  6.    */
  7.   private static void calculateAndWriteChecksum(ByteBuf slice, ByteBuf out) {
  8.     out.writeInt(ByteBufUtil.swapInt(calculateChecksum(slice)));
  9.   }
  10. }

代码示例来源：origin: com.couchbase.client/core-io

  1. public ByteBuf encodePingFrame(ByteBufAllocator allocator, int id) {
  2.   byte flags = 0;
  3.   int length = 4;
  4.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  5.   writeControlFrameHeader(frame, SPDY_PING_FRAME, flags, length);
  6.   frame.writeInt(id);
  7.   return frame;
  8. }

代码示例来源：origin: couchbase/java-dcp-client

  1. public static void ackBytes(final ByteBuf buffer, int bytes) {
  2.   ByteBuf extras = Unpooled.buffer(4);
  3.   MessageUtil.setExtras(extras.writeInt(bytes), buffer);
  4.   extras.release();
  5. }

代码示例来源：origin: couchbase/java-dcp-client

  1. public static void opaque(final ByteBuf buffer, int opaque) {
  2.     ByteBuf extras = Unpooled.buffer(4);
  3.     MessageUtil.setExtras(extras.writeInt(opaque), buffer);
  4.     extras.release();
  5.   }
  6. }

代码示例来源：origin: com.couchbase.client/core-io

  1. public ByteBuf encodeHeadersFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf headerBlock) {
  2.   int headerBlockLength = headerBlock.readableBytes();
  3.   byte flags = last ? SPDY_FLAG_FIN : 0;
  4.   int length = 4 + headerBlockLength;
  5.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  6.   writeControlFrameHeader(frame, SPDY_HEADERS_FRAME, flags, length);
  7.   frame.writeInt(streamId);
  8.   frame.writeBytes(headerBlock, headerBlock.readerIndex(), headerBlockLength);
  9.   return frame;
  10. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. public ByteBuf encodeDataFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf data) {
  2.   byte flags = last ? SPDY_DATA_FLAG_FIN : 0;
  3.   int length = data.readableBytes();
  4.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  5.   frame.writeInt(streamId & 0x7FFFFFFF);
  6.   frame.writeByte(flags);
  7.   frame.writeMedium(length);
  8.   frame.writeBytes(data, data.readerIndex(), length);
  9.   return frame;
  10. }

代码示例来源：origin: com.couchbase.client/core-io

  1. public ByteBuf encodeDataFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf data) {
  2.   byte flags = last ? SPDY_DATA_FLAG_FIN : 0;
  3.   int length = data.readableBytes();
  4.   ByteBuf frame = allocator.ioBuffer(SPDY_HEADER_SIZE + length).order(ByteOrder.BIG_ENDIAN);
  5.   frame.writeInt(streamId & 0x7FFFFFFF);
  6.   frame.writeByte(flags);
  7.   frame.writeMedium(length);
  8.   frame.writeBytes(data, data.readerIndex(), length);
  9.   return frame;
  10. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. protected void encodeHeader(ByteBuf buf, BinaryMemcacheResponse msg) {
  3.   buf.writeByte(msg.getMagic());
  4.   buf.writeByte(msg.getOpcode());
  5.   buf.writeShort(msg.getKeyLength());
  6.   buf.writeByte(msg.getExtrasLength());
  7.   buf.writeByte(msg.getDataType());
  8.   buf.writeShort(msg.getStatus());
  9.   buf.writeInt(msg.getTotalBodyLength());
  10.   buf.writeInt(msg.getOpaque());
  11.   buf.writeLong(msg.getCAS());
  12. }

代码示例来源：origin: com.couchbase.client/core-io

  1. @Override
  2. protected void encodeHeader(ByteBuf buf, BinaryMemcacheRequest msg) {
  3.   buf.writeByte(msg.getMagic());
  4.   buf.writeByte(msg.getOpcode());
  5.   buf.writeShort(msg.getKeyLength());
  6.   buf.writeByte(msg.getExtrasLength());
  7.   buf.writeByte(msg.getDataType());
  8.   buf.writeShort(msg.getReserved());
  9.   buf.writeInt(msg.getTotalBodyLength());
  10.   buf.writeInt(msg.getOpaque());
  11.   buf.writeLong(msg.getCAS());
  12. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. protected void encodeHeader(ByteBuf buf, BinaryMemcacheResponse msg) {
  3.   buf.writeByte(msg.getMagic());
  4.   buf.writeByte(msg.getOpcode());
  5.   buf.writeShort(msg.getKeyLength());
  6.   buf.writeByte(msg.getExtrasLength());
  7.   buf.writeByte(msg.getDataType());
  8.   buf.writeShort(msg.getStatus());
  9.   buf.writeInt(msg.getTotalBodyLength());
  10.   buf.writeInt(msg.getOpaque());
  11.   buf.writeLong(msg.getCAS());
  12. }

内容来源于网络，如有侵权，请联系作者删除！

ByteBuf

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com