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

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

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

ByteBuf.readShort介绍

[英]Gets a 16-bit short integer at the current readerIndexand increases the readerIndex by 2 in this buffer.
[中]获取当前readerIndex处的16位短整数，并在此缓冲区中将readerIndex增加2。

代码示例

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

  1. @Override
  2. public short readShort() {
  3.   return buf.readShort();
  4. }

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

  1. @Override
  2. public short readShort() {
  3.   return buf.readShort();
  4. }

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

  1. @Override
  2. public short readShort() {
  3.   checkReadableBytes(2);
  4.   return buffer.readShort();
  5. }

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

  1. @Override
  2. public short readShort() {
  3.   return ByteBufUtil.swapShort(buf.readShort());
  4. }

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

  1. @Override
  2. public short readShort() {
  3.   checkReadableBytes(2);
  4.   return buffer.readShort();
  5. }

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

  1. @Override
  2. public short readShort() throws IOException {
  3.   checkAvailable(2);
  4.   return buffer.readShort();
  5. }

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

  1. @Override
  2. public short readShort() throws IOException {
  3.   checkAvailable(2);
  4.   return buffer.readShort();
  5. }

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

  1. @Override
  2. public short readShort() {
  3.   return ByteBufUtil.swapShort(buf.readShort());
  4. }

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

  1. private static int readSwappedUnsignedShort(ByteBuf in) {
  2.   return ByteBufUtil.swapShort(in.readShort()) & 0xFFFF;
  3. }

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

  1. /**
  2.  * Returns the closing status code as per <a href="http://tools.ietf.org/html/rfc6455#section-7.4">RFC 6455</a>. If
  3.  * a getStatus code is set, -1 is returned.
  4.  */
  5. public int statusCode() {
  6.   ByteBuf binaryData = content();
  7.   if (binaryData == null || binaryData.capacity() == 0) {
  8.     return -1;
  9.   }
  10.   binaryData.readerIndex(0);
  11.   int statusCode = binaryData.readShort();
  12.   binaryData.readerIndex(0);
  13.   return statusCode;
  14. }

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

  1. /**
  2.  * Returns the closing status code as per <a href="http://tools.ietf.org/html/rfc6455#section-7.4">RFC 6455</a>. If
  3.  * a getStatus code is set, -1 is returned.
  4.  */
  5. public int statusCode() {
  6.   ByteBuf binaryData = content();
  7.   if (binaryData == null || binaryData.capacity() == 0) {
  8.     return -1;
  9.   }
  10.   binaryData.readerIndex(0);
  11.   int statusCode = binaryData.readShort();
  12.   binaryData.readerIndex(0);
  13.   return statusCode;
  14. }

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

  1. ObserveSeqnoResponse(final ByteBuf response) {
  2.   ByteBuf content = MessageUtil.getContent(response);
  3.   this.didFailover = content.readBoolean();
  4.   this.vbid = content.readShort();
  5.   this.vbuuid = content.readLong();
  6.   this.persistSeqno = content.readLong();
  7.   this.currentSeqno = content.readLong();
  8.   this.oldVbuuid = this.didFailover ? content.readLong() : 0;
  9.   this.lastSeqno = this.didFailover ? content.readLong() : 0;
  10. }

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

  1. @Override
  2. protected BinaryMemcacheRequest decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheRequest header = new DefaultBinaryMemcacheRequest();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   header.setKeyLength(in.readShort());
  7.   header.setExtrasLength(in.readByte());
  8.   header.setDataType(in.readByte());
  9.   header.setReserved(in.readShort());
  10.   header.setTotalBodyLength(in.readInt());
  11.   header.setOpaque(in.readInt());
  12.   header.setCAS(in.readLong());
  13.   return header;
  14. }

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

  1. @Override
  2. protected void channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg) throws Exception {
  3.   List<ServerFeatures> supported = new ArrayList<ServerFeatures>();
  4.   ResponseStatus responseStatus = ResponseStatusConverter.fromBinary(msg.getStatus());
  5.   if (responseStatus.isSuccess()) {
  6.     while (msg.content().isReadable()) {
  7.       supported.add(ServerFeatures.fromValue(msg.content().readShort()));
  8.     }
  9.   } else {
  10.     LOGGER.debug("HELLO Negotiation did not succeed ({}).", responseStatus);
  11.   }
  12.   LOGGER.debug("Negotiated supported features: {}", supported);
  13.   ctx.fireUserEventTriggered(new ServerFeaturesEvent(supported));
  14.   originalPromise.setSuccess();
  15.   ctx.pipeline().remove(this);
  16.   ctx.fireChannelActive();
  17. }

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

  1. @Override
  2. protected BinaryMemcacheRequest decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheRequest header = new DefaultBinaryMemcacheRequest();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   header.setKeyLength(in.readShort());
  7.   header.setExtrasLength(in.readByte());
  8.   header.setDataType(in.readByte());
  9.   header.setReserved(in.readShort());
  10.   header.setTotalBodyLength(in.readInt());
  11.   header.setOpaque(in.readInt());
  12.   header.setCAS(in.readLong());
  13.   return header;
  14. }

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

  1. @Override
  2. protected void channelRead0(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg) throws Exception {
  3.   List<ServerFeatures> supported = new ArrayList<ServerFeatures>();
  4.   ResponseStatus responseStatus = ResponseStatusConverter.fromBinary(msg.getStatus());
  5.   if (responseStatus.isSuccess()) {
  6.     while (msg.content().isReadable()) {
  7.       supported.add(ServerFeatures.fromValue(msg.content().readShort()));
  8.     }
  9.   } else {
  10.     LOGGER.debug("HELLO Negotiation did not succeed ({}).", responseStatus);
  11.   }
  12.   LOGGER.debug("Negotiated supported features: {}", supported);
  13.   ctx.fireUserEventTriggered(new ServerFeaturesEvent(supported));
  14.   originalPromise.setSuccess();
  15.   ctx.pipeline().remove(this);
  16.   ctx.fireChannelActive();
  17. }

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

  1. @Override
  2. protected BinaryMemcacheResponse decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheResponse header = new DefaultBinaryMemcacheResponse();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   if (header.getMagic() == FRAMING_MAGIC) {
  7.     header.setFramingExtrasLength(in.readByte());
  8.     header.setKeyLength(in.readByte());
  9.   } else {
  10.     header.setKeyLength(in.readShort());
  11.   }
  12.   header.setExtrasLength(in.readByte());
  13.   header.setDataType(in.readByte());
  14.   header.setStatus(in.readShort());
  15.   header.setTotalBodyLength(in.readInt());
  16.   header.setOpaque(in.readInt());
  17.   header.setCAS(in.readLong());
  18.   return header;
  19. }

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

  1. @Override
  2. protected BinaryMemcacheResponse decodeHeader(ByteBuf in) {
  3.   BinaryMemcacheResponse header = new DefaultBinaryMemcacheResponse();
  4.   header.setMagic(in.readByte());
  5.   header.setOpcode(in.readByte());
  6.   if (header.getMagic() == FRAMING_MAGIC) {
  7.     header.setFramingExtrasLength(in.readByte());
  8.     header.setKeyLength(in.readByte());
  9.   } else {
  10.     header.setKeyLength(in.readShort());
  11.   }
  12.   header.setExtrasLength(in.readByte());
  13.   header.setDataType(in.readByte());
  14.   header.setStatus(in.readShort());
  15.   header.setTotalBodyLength(in.readInt());
  16.   header.setOpaque(in.readInt());
  17.   header.setCAS(in.readLong());
  18.   return header;
  19. }

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

  1. /** */
  2. protected void checkCloseFrameBody(
  3.     ChannelHandlerContext ctx, ByteBuf buffer) {
  4.   if (buffer == null || !buffer.isReadable()) {
  5.     return;
  6.   }
  7.   if (buffer.readableBytes() == 1) {
  8.     protocolViolation(ctx, "Invalid close frame body");
  9.   }
  10.   // Save reader index
  11.   int idx = buffer.readerIndex();
  12.   buffer.readerIndex(0);
  13.   // Must have 2 byte integer within the valid range
  14.   int statusCode = buffer.readShort();
  15.   if (statusCode >= 0 && statusCode <= 999 || statusCode >= 1004 && statusCode <= 1006
  16.       || statusCode >= 1012 && statusCode <= 2999) {
  17.     protocolViolation(ctx, "Invalid close frame getStatus code: " + statusCode);
  18.   }
  19.   // May have UTF-8 message
  20.   if (buffer.isReadable()) {
  21.     try {
  22.       new Utf8Validator().check(buffer);
  23.     } catch (CorruptedFrameException ex) {
  24.       protocolViolation(ctx, ex);
  25.     }
  26.   }
  27.   // Restore reader index
  28.   buffer.readerIndex(idx);
  29. }

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

  1. /** */
  2. protected void checkCloseFrameBody(
  3.     ChannelHandlerContext ctx, ByteBuf buffer) {
  4.   if (buffer == null || !buffer.isReadable()) {
  5.     return;
  6.   }
  7.   if (buffer.readableBytes() == 1) {
  8.     protocolViolation(ctx, "Invalid close frame body");
  9.   }
  10.   // Save reader index
  11.   int idx = buffer.readerIndex();
  12.   buffer.readerIndex(0);
  13.   // Must have 2 byte integer within the valid range
  14.   int statusCode = buffer.readShort();
  15.   if (statusCode >= 0 && statusCode <= 999 || statusCode >= 1004 && statusCode <= 1006
  16.       || statusCode >= 1012 && statusCode <= 2999) {
  17.     protocolViolation(ctx, "Invalid close frame getStatus code: " + statusCode);
  18.   }
  19.   // May have UTF-8 message
  20.   if (buffer.isReadable()) {
  21.     try {
  22.       new Utf8Validator().check(buffer);
  23.     } catch (CorruptedFrameException ex) {
  24.       protocolViolation(ctx, ex);
  25.     }
  26.   }
  27.   // Restore reader index
  28.   buffer.readerIndex(idx);
  29. }

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

ByteBuf

相关文章

    查看更多

    热门标签

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

    最新文章

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