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

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

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

ByteBuf.readInt介绍

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

代码示例

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

  1. @Override
  2. public int readInt() {
  3. return buf.readInt();
  4. }

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

  1. @Override
  2. public int readInt() {
  3. return buf.readInt();
  4. }

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

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

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

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

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

  1. @Override
  2. public int readInt() {
  3. return ByteBufUtil.swapInt(buf.readInt());
  4. }

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

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

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

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

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

  1. @Override
  2. public int readInt() {
  3. return ByteBufUtil.swapInt(buf.readInt());
  4. }

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

  1. int valueLength = body.readInt();
  2. ByteBuf value = ctx.alloc().buffer(valueLength, valueLength);
  3. value.writeBytes(body, valueLength);

代码示例来源: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: 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. int valueLength = body.readInt();
  2. ByteBuf value = ctx.alloc().buffer(valueLength, valueLength);
  3. value.writeBytes(body, valueLength);

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

  1. final ByteBuf byteBuf = header.readSlice(length);
  2. final byte client = byteBuf.readByte();
  3. final int verify = byteBuf.readInt();

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

  1. final ByteBuf byteBuf = header.readSlice(length);
  2. final byte client = byteBuf.readByte();
  3. final int verify = byteBuf.readInt();

代码示例来源: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. int offset = ByteBufUtil.swapInt(in.readInt());

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

  1. int offset = ByteBufUtil.swapInt(in.readInt());

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

  1. int offset = ByteBufUtil.swapInt(in.readInt());

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

  1. return NOT_ENOUGH_INPUT;
  2. length = ByteBufUtil.swapInt(in.readInt());
  3. break;
  4. default:

相关文章