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

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

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

ByteBuf.hasArray介绍

[英]Returns true if and only if this buffer has a backing byte array. If this method returns true, you can safely call #array() and #arrayOffset().
[中]

代码示例

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

  1. @Override
  2. public boolean hasArray() {
  3.   return buf.hasArray();
  4. }

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

  1. @Override
  2. public boolean hasArray() {
  3.   return buf.hasArray();
  4. }

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

  1. @Override
  2. public boolean hasArray() {
  3.   return unwrap().hasArray();
  4. }

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

  1. @Override
  2. public boolean hasArray() {
  3.   return unwrap().hasArray();
  4. }

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

  1. @Override
  2. public boolean hasArray() {
  3.   switch (components.size()) {
  4.   case 0:
  5.     return true;
  6.   case 1:
  7.     return components.get(0).buf.hasArray();
  8.   default:
  9.     return false;
  10.   }
  11. }

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

  1. @Override
  2. public boolean hasArray() {
  3.   switch (components.size()) {
  4.   case 0:
  5.     return true;
  6.   case 1:
  7.     return components.get(0).buf.hasArray();
  8.   default:
  9.     return false;
  10.   }
  11. }

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

  1. private int setInput(ByteBuf decompressed) {
  2.   int len = decompressed.readableBytes();
  3.   if (decompressed.hasArray()) {
  4.     compressor.setInput(decompressed.array(), decompressed.arrayOffset() + decompressed.readerIndex(), len);
  5.   } else {
  6.     byte[] in = new byte[len];
  7.     decompressed.getBytes(decompressed.readerIndex(), in);
  8.     compressor.setInput(in, 0, in.length);
  9.   }
  10.   return len;
  11. }

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

  1. private int setInput(ByteBuf compressed) {
  2.   int len = compressed.readableBytes();
  3.   if (compressed.hasArray()) {
  4.     decompressor.setInput(compressed.array(), compressed.arrayOffset() + compressed.readerIndex(), len);
  5.   } else {
  6.     byte[] in = new byte[len];
  7.     compressed.getBytes(compressed.readerIndex(), in);
  8.     decompressor.setInput(in, 0, in.length);
  9.   }
  10.   return len;
  11. }

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

  1. private int setInput(ByteBuf decompressed) {
  2.   int len = decompressed.readableBytes();
  3.   if (decompressed.hasArray()) {
  4.     compressor.setInput(decompressed.array(), decompressed.arrayOffset() + decompressed.readerIndex(), len);
  5.   } else {
  6.     byte[] in = new byte[len];
  7.     decompressed.getBytes(decompressed.readerIndex(), in);
  8.     compressor.setInput(in, 0, in.length);
  9.   }
  10.   return len;
  11. }

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

  1. private int setInput(ByteBuf compressed) {
  2.   int len = compressed.readableBytes();
  3.   if (compressed.hasArray()) {
  4.     decompressor.setInput(compressed.array(), compressed.arrayOffset() + compressed.readerIndex(), len);
  5.   } else {
  6.     byte[] in = new byte[len];
  7.     compressed.getBytes(compressed.readerIndex(), in);
  8.     decompressor.setInput(in, 0, in.length);
  9.   }
  10.   return len;
  11. }

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

  1. /**
  2.  * @param buffer buffer with a backing byte array
  3.  */
  4. SeekAheadOptimize(ByteBuf buffer) {
  5.   if (!buffer.hasArray()) {
  6.     throw new IllegalArgumentException("buffer hasn't backing byte array");
  7.   }
  8.   this.buffer = buffer;
  9.   bytes = buffer.array();
  10.   readerIndex = buffer.readerIndex();
  11.   origPos = pos = buffer.arrayOffset() + readerIndex;
  12.   limit = buffer.arrayOffset() + buffer.writerIndex();
  13. }

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

  1. /**
  2.  * @param buffer buffer with a backing byte array
  3.  */
  4. SeekAheadOptimize(ByteBuf buffer) {
  5.   if (!buffer.hasArray()) {
  6.     throw new IllegalArgumentException("buffer hasn't backing byte array");
  7.   }
  8.   this.buffer = buffer;
  9.   bytes = buffer.array();
  10.   readerIndex = buffer.readerIndex();
  11.   origPos = pos = buffer.arrayOffset() + readerIndex;
  12.   limit = buffer.arrayOffset() + buffer.writerIndex();
  13. }

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

  1. @Override
  2. public ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
  3.   checkDstIndex(index, length, dstIndex, dst.capacity());
  4.   if (dst.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(array, index, dst.memoryAddress() + dstIndex, length);
  6.   } else if (dst.hasArray()) {
  7.     getBytes(index, dst.array(), dst.arrayOffset() + dstIndex, length);
  8.   } else {
  9.     dst.setBytes(dstIndex, array, index, length);
  10.   }
  11.   return this;
  12. }

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

  1. @Override
  2. public ByteBuf setBytes(int index, ByteBuf src, int srcIndex, int length) {
  3.   checkSrcIndex(index, length, srcIndex, src.capacity());
  4.   if (src.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(src.memoryAddress() + srcIndex, array, index, length);
  6.   } else  if (src.hasArray()) {
  7.     setBytes(index, src.array(), src.arrayOffset() + srcIndex, length);
  8.   } else {
  9.     src.getBytes(srcIndex, array, index, length);
  10.   }
  11.   return this;
  12. }

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

  1. @Override
  2. public ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
  3.   checkDstIndex(index, length, dstIndex, dst.capacity());
  4.   if (dst.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(array, index, dst.memoryAddress() + dstIndex, length);
  6.   } else if (dst.hasArray()) {
  7.     getBytes(index, dst.array(), dst.arrayOffset() + dstIndex, length);
  8.   } else {
  9.     dst.setBytes(dstIndex, array, index, length);
  10.   }
  11.   return this;
  12. }

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

  1. @Override
  2. public ByteBuf setBytes(int index, ByteBuf src, int srcIndex, int length) {
  3.   checkSrcIndex(index, length, srcIndex, src.capacity());
  4.   if (src.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(src.memoryAddress() + srcIndex, array, index, length);
  6.   } else  if (src.hasArray()) {
  7.     setBytes(index, src.array(), src.arrayOffset() + srcIndex, length);
  8.   } else {
  9.     src.getBytes(srcIndex, array, index, length);
  10.   }
  11.   return this;
  12. }

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

  1. @Override
  2. public final ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
  3.   checkDstIndex(index, length, dstIndex, dst.capacity());
  4.   if (dst.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(memory, idx(index), dst.memoryAddress() + dstIndex, length);
  6.   } else if (dst.hasArray()) {
  7.     getBytes(index, dst.array(), dst.arrayOffset() + dstIndex, length);
  8.   } else {
  9.     dst.setBytes(dstIndex, memory, idx(index), length);
  10.   }
  11.   return this;
  12. }

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

  1. @Override
  2. public final ByteBuf setBytes(int index, ByteBuf src, int srcIndex, int length) {
  3.   checkSrcIndex(index, length, srcIndex, src.capacity());
  4.   if (src.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(src.memoryAddress() + srcIndex, memory, idx(index), length);
  6.   } else if (src.hasArray()) {
  7.     setBytes(index, src.array(), src.arrayOffset() + srcIndex, length);
  8.   } else {
  9.     src.getBytes(srcIndex, memory, idx(index), length);
  10.   }
  11.   return this;
  12. }

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

  1. @Override
  2. public final ByteBuf setBytes(int index, ByteBuf src, int srcIndex, int length) {
  3.   checkSrcIndex(index, length, srcIndex, src.capacity());
  4.   if (src.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(src.memoryAddress() + srcIndex, memory, idx(index), length);
  6.   } else if (src.hasArray()) {
  7.     setBytes(index, src.array(), src.arrayOffset() + srcIndex, length);
  8.   } else {
  9.     src.getBytes(srcIndex, memory, idx(index), length);
  10.   }
  11.   return this;
  12. }

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

  1. @Override
  2. public final ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
  3.   checkDstIndex(index, length, dstIndex, dst.capacity());
  4.   if (dst.hasMemoryAddress()) {
  5.     PlatformDependent.copyMemory(memory, idx(index), dst.memoryAddress() + dstIndex, length);
  6.   } else if (dst.hasArray()) {
  7.     getBytes(index, dst.array(), dst.arrayOffset() + dstIndex, length);
  8.   } else {
  9.     dst.setBytes(dstIndex, memory, idx(index), length);
  10.   }
  11.   return this;
  12. }

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

ByteBuf

相关文章

    查看更多

    热门标签

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

    最新文章

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