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

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

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

ByteBuf.writeLong介绍

[英]Sets the specified 64-bit long integer at the current writerIndex and increases the writerIndex by 8in this buffer.
[中]在当前writerIndex处设置指定的64位长整数，并在此缓冲区中将writerIndex增加8。

代码示例

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

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

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

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

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

  1. @Override
  2. public void writeLong(long v) throws IOException {
  3.   buffer.writeLong(v);
  4. }

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

  1. @Override
  2. public void writeLong(long v) throws IOException {
  3.   buffer.writeLong(v);
  4. }

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

  1. @Override
  2. public ByteBuf writeLong(long value) {
  3.   buf.writeLong(ByteBufUtil.swapLong(value));
  4.   return this;
  5. }

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

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

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

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

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

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

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

  1. @Override
  2. public ByteBuf writeLong(long value) {
  3.   buf.writeLong(ByteBufUtil.swapLong(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 64-bit integers.
  3.  */
  4. public static ByteBuf copyLong(long... values) {
  5.   if (values == null || values.length == 0) {
  6.     return EMPTY_BUFFER;
  7.   }
  8.   ByteBuf buffer = buffer(values.length * 8);
  9.   for (long v: values) {
  10.     buffer.writeLong(v);
  11.   }
  12.   return buffer;
  13. }

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

  1. /**
  2.  * Initialize the buffer with all the values needed.
  3.  *
  4.  * Initializes the complete extras needed with 0 and can be overridden through the setters available.
  5.  * If no setters are used this message is effectively a backfill for the given vbucket.
  6.  */
  7. public static void init(final ByteBuf buffer, short vbucket) {
  8.   MessageUtil.initRequest(DCP_STREAM_REQUEST_OPCODE, buffer);
  9.   MessageUtil.setVbucket(vbucket, buffer);
  10.   MessageUtil.setExtras(Unpooled
  11.           .buffer(48)
  12.           .writeInt(0) // flags
  13.           .writeInt(0) // reserved
  14.           .writeLong(0) // start sequence number
  15.           .writeLong(0) // end sequence number
  16.           .writeLong(0) // vbucket uuid
  17.           .writeLong(0) // snapshot start sequence number
  18.           .writeLong(0), // snapshot end sequence number
  19.       buffer
  20.   );
  21. }

代码示例来源：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: couchbase/java-dcp-client

  1. @Override
  2.   public DcpRequestBuilder call() throws Exception {
  3.     return request(MessageUtil.OBSERVE_SEQNO_OPCODE)
  4.         .vbucket(partition)
  5.         .content(Unpooled.buffer(8).writeLong(vbuuid));
  6.   }
  7. }, new Func1<ByteBuf, ObserveSeqnoResponse>() {

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

  1. private static BinaryMemcacheRequest handleObserveSeqnoRequest(final ChannelHandlerContext ctx,
  2.   final ObserveSeqnoRequest msg) {
  3.   ByteBuf content = ctx.alloc().buffer();
  4.   content.writeLong(msg.vbucketUUID());
  5.   BinaryMemcacheRequest request = new DefaultFullBinaryMemcacheRequest(EMPTY_BYTES, Unpooled.EMPTY_BUFFER, content);
  6.   request.setOpcode(OP_OBSERVE_SEQ);
  7.   request.setTotalBodyLength(content.readableBytes());
  8.   return request;
  9. }

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

  1. private static BinaryMemcacheRequest handleObserveSeqnoRequest(final ChannelHandlerContext ctx,
  2.   final ObserveSeqnoRequest msg) {
  3.   ByteBuf content = ctx.alloc().buffer();
  4.   content.writeLong(msg.vbucketUUID());
  5.   BinaryMemcacheRequest request = new DefaultFullBinaryMemcacheRequest(EMPTY_BYTES, Unpooled.EMPTY_BUFFER, content);
  6.   request.setOpcode(OP_OBSERVE_SEQ);
  7.   request.setTotalBodyLength(content.readableBytes());
  8.   return request;
  9. }

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

  1. /**
  2.  * Encodes a {@link CounterRequest} into its lower level representation.
  3.  *
  4.  * Depending on if the {@link CounterRequest#delta} is positive or negative, either the incr or decr memcached
  5.  * commands are utilized. The value is converted to its absolute variant to conform with the protocol.
  6.  *
  7.  * @return a ready {@link BinaryMemcacheRequest}.
  8.  */
  9. private static BinaryMemcacheRequest handleCounterRequest(final ChannelHandlerContext ctx,
  10.   final CounterRequest msg) {
  11.   ByteBuf extras = ctx.alloc().buffer();
  12.   extras.writeLong(Math.abs(msg.delta()));
  13.   extras.writeLong(msg.initial());
  14.   extras.writeInt(msg.expiry());
  15.   byte[] key = msg.keyBytes();
  16.   short keyLength = (short) key.length;
  17.   byte extrasLength = (byte) extras.readableBytes();
  18.   BinaryMemcacheRequest request = new DefaultBinaryMemcacheRequest(key, extras);
  19.   request.setOpcode(msg.delta() < 0 ? OP_COUNTER_DECR : OP_COUNTER_INCR);
  20.   request.setKeyLength(keyLength);
  21.   request.setTotalBodyLength(keyLength + extrasLength);
  22.   request.setExtrasLength(extrasLength);
  23.   return request;
  24. }

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

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

ByteBuf

相关文章

    查看更多

    热门标签

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

    最新文章

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