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

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

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

ByteBuf.array介绍

[英]Returns the backing byte array of this buffer.
[中]返回此缓冲区的后备字节数组。

代码示例

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

  1. @Override
  2. public byte[] array() {
  3.   return buf.array();
  4. }

代码示例来源：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: com.couchbase.client/core-io

  1. private void deflate(ByteBuf out) {
  2.   int numBytes;
  3.   do {
  4.     int writerIndex = out.writerIndex();
  5.     numBytes = deflater.deflate(
  6.         out.array(), out.arrayOffset() + writerIndex, out.writableBytes(), Deflater.SYNC_FLUSH);
  7.     out.writerIndex(writerIndex + numBytes);
  8.   } while (numBytes > 0);
  9. }

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

  1. @Override
  2. public byte[] array() {
  3.   switch (components.size()) {
  4.   case 0:
  5.     return EmptyArrays.EMPTY_BYTES;
  6.   case 1:
  7.     return components.get(0).buf.array();
  8.   default:
  9.     throw new UnsupportedOperationException();
  10.   }
  11. }

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

  1. private void deflate(ByteBuf out) {
  2.   int numBytes;
  3.   do {
  4.     int writerIndex = out.writerIndex();
  5.     numBytes = deflater.deflate(
  6.         out.array(), out.arrayOffset() + writerIndex, out.writableBytes(), Deflater.SYNC_FLUSH);
  7.     out.writerIndex(writerIndex + numBytes);
  8.   } while (numBytes > 0);
  9. }

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

  1. @Override
  2. public byte[] array() {
  3.   switch (components.size()) {
  4.   case 0:
  5.     return EmptyArrays.EMPTY_BYTES;
  6.   case 1:
  7.     return components.get(0).buf.array();
  8.   default:
  9.     throw new UnsupportedOperationException();
  10.   }
  11. }

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

  1. private boolean compressInto(ByteBuf compressed) {
  2.   byte[] out = compressed.array();
  3.   int off = compressed.arrayOffset() + compressed.writerIndex();
  4.   int toWrite = compressed.writableBytes();
  5.   int numBytes = compressor.deflate(out, off, toWrite, Deflater.SYNC_FLUSH);
  6.   compressed.writerIndex(compressed.writerIndex() + numBytes);
  7.   return numBytes == toWrite;
  8. }

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

  1. @Override
  2. public byte[] get() {
  3.   if (byteBuf == null) {
  4.     return EMPTY_BUFFER.array();
  5.   }
  6.   byte[] array = new byte[byteBuf.readableBytes()];
  7.   byteBuf.getBytes(byteBuf.readerIndex(), array);
  8.   return array;
  9. }

代码示例来源：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. @Override
  2. public byte[] get() {
  3.   if (byteBuf == null) {
  4.     return EMPTY_BUFFER.array();
  5.   }
  6.   byte[] array = new byte[byteBuf.readableBytes()];
  7.   byteBuf.getBytes(byteBuf.readerIndex(), array);
  8.   return array;
  9. }

代码示例来源：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: 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: 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: 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: 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: 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 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: 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: 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. }

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

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

ByteBuf

相关文章

    查看更多

    热门标签

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

    最新文章

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