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

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

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

ByteBuf.writeShort介绍

[英]Sets the specified 16-bit short integer at the current writerIndex and increases the writerIndex by 2in this buffer. The 16 high-order bits of the specified value are ignored.
[中]在当前writerIndex处设置指定的16位短整数，并在此缓冲区中将writerIndex增加2。指定值的16个高位将被忽略。

代码示例

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

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

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

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

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

  1. @Override
  2. public void writeShort(int v) throws IOException {
  3.   buffer.writeShort((short) v);
  4. }

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

  1. private void writeControlFrameHeader(ByteBuf buffer, int type, byte flags, int length) {
  2.   buffer.writeShort(version | 0x8000);
  3.   buffer.writeShort(type);
  4.   buffer.writeByte(flags);
  5.   buffer.writeMedium(length);
  6. }

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

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

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

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

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

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

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

  1. /**
  2.  * Create a new big-endian buffer that holds a sequence of the specified 16-bit integers.
  3.  */
  4. public static ByteBuf copyShort(int... values) {
  5.   if (values == null || values.length == 0) {
  6.     return EMPTY_BUFFER;
  7.   }
  8.   ByteBuf buffer = buffer(values.length * 2);
  9.   for (int v: values) {
  10.     buffer.writeShort(v);
  11.   }
  12.   return buffer;
  13. }

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

  1. /**
  2.  * Create a new big-endian buffer that holds a sequence of the specified 16-bit integers.
  3.  */
  4. public static ByteBuf copyShort(short... values) {
  5.   if (values == null || values.length == 0) {
  6.     return EMPTY_BUFFER;
  7.   }
  8.   ByteBuf buffer = buffer(values.length * 2);
  9.   for (int v: values) {
  10.     buffer.writeShort(v);
  11.   }
  12.   return buffer;
  13. }

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

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

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

  1. private void writeControlFrameHeader(ByteBuf buffer, int type, byte flags, int length) {
  2.   buffer.writeShort(version | 0x8000);
  3.   buffer.writeShort(type);
  4.   buffer.writeByte(flags);
  5.   buffer.writeMedium(length);
  6. }

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

  1. /**
  2.  * Create a new big-endian buffer that holds a sequence of the specified 16-bit integers.
  3.  */
  4. public static ByteBuf copyShort(short... values) {
  5.   if (values == null || values.length == 0) {
  6.     return EMPTY_BUFFER;
  7.   }
  8.   ByteBuf buffer = buffer(values.length * 2);
  9.   for (int v: values) {
  10.     buffer.writeShort(v);
  11.   }
  12.   return buffer;
  13. }

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

  1. private static ByteBuf newBinaryData(int statusCode, String reasonText) {
  2.   byte[] reasonBytes = EmptyArrays.EMPTY_BYTES;
  3.   if (reasonText != null) {
  4.     reasonBytes = reasonText.getBytes(CharsetUtil.UTF_8);
  5.   }
  6.   ByteBuf binaryData = Unpooled.buffer(2 + reasonBytes.length);
  7.   binaryData.writeShort(statusCode);
  8.   if (reasonBytes.length > 0) {
  9.     binaryData.writeBytes(reasonBytes);
  10.   }
  11.   binaryData.readerIndex(0);
  12.   return binaryData;
  13. }

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

  1. private static ByteBuf newBinaryData(int statusCode, String reasonText) {
  2.   byte[] reasonBytes = EmptyArrays.EMPTY_BYTES;
  3.   if (reasonText != null) {
  4.     reasonBytes = reasonText.getBytes(CharsetUtil.UTF_8);
  5.   }
  6.   ByteBuf binaryData = Unpooled.buffer(2 + reasonBytes.length);
  7.   binaryData.writeShort(statusCode);
  8.   if (reasonBytes.length > 0) {
  9.     binaryData.writeBytes(reasonBytes);
  10.   }
  11.   binaryData.readerIndex(0);
  12.   return binaryData;
  13. }

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

  1. public static void init(ByteBuf buffer, short vbid, long seqno) {
  2.   buffer.writeByte(MessageUtil.MAGIC_INT);
  3.   buffer.writeByte(MessageUtil.INTERNAL_ROLLBACK_OPCODE);
  4.   buffer.writeShort(vbid);
  5.   buffer.writeLong(seqno);
  6. }

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

  1. /**
  2.  * Creates the request to load the error map.
  3.  */
  4. private FullBinaryMemcacheRequest errorMapRequest() {
  5.   LOGGER.debug("Requesting error map in version {}", MAP_VERSION);
  6.   ByteBuf content = Unpooled.buffer(2).writeShort(MAP_VERSION);
  7.   FullBinaryMemcacheRequest request = new DefaultFullBinaryMemcacheRequest(
  8.     new byte[] {}, Unpooled.EMPTY_BUFFER, content
  9.   );
  10.   request.setOpcode(GET_ERROR_MAP_CMD);
  11.   request.setTotalBodyLength(content.readableBytes());
  12.   return request;
  13. }

代码示例来源：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, 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