org.apache.qpid.proton.codec.WritableBuffer.position()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(137)

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

WritableBuffer.position介绍

暂无

代码示例

代码示例来源：origin: org.apache.qpid/proton-j

  1. @Override
  2. public int position()
  3. {
  4.   return _first.position()+_second.position();
  5. }

代码示例来源：origin: org.apache.qpid/proton-j-impl

  1. public int position()
  2. {
  3.   return _first.position()+_second.position();
  4. }

代码示例来源：origin: com.microsoft.azure.iot/proton-j-azure-iot

  1. public int position()
  2. {
  3.   return _first.position()+_second.position();
  4. }

代码示例来源：origin: org.apache.qpid/proton

  1. public int position()
  2. {
  3.   return _first.position()+_second.position();
  4. }

代码示例来源：origin: org.apache.qpid/proton-j-impl

  1. private void startFrame()
  2. {
  3.   _frameStart = _buffer.position();
  4. }

代码示例来源：origin: com.microsoft.azure.iot/proton-j-azure-iot

  1. private void startFrame()
  2. {
  3.   _frameStart = _buffer.position();
  4. }

代码示例来源：origin: org.apache.qpid/proton

  1. public void position(int position)
  2. {
  3.   int first_limit = _first.limit();
  4.   if( position <= first_limit )
  5.   {
  6.     _first.position(position);
  7.     _second.position(0);
  8.   }
  9.   else
  10.   {
  11.     _first.position(first_limit);
  12.     _second.position(position - first_limit);
  13.   }
  14. }

代码示例来源：origin: org.apache.qpid/proton-j

  1. @Override
  2. public void position(int position)
  3. {
  4.   int first_limit = _first.limit();
  5.   if( position <= first_limit )
  6.   {
  7.     _first.position(position);
  8.     _second.position(0);
  9.   }
  10.   else
  11.   {
  12.     _first.position(first_limit);
  13.     _second.position(position - first_limit);
  14.   }
  15. }

代码示例来源：origin: org.apache.qpid/proton-j-impl

  1. public void position(int position)
  2. {
  3.   int first_limit = _first.limit();
  4.   if( position <= first_limit )
  5.   {
  6.     _first.position(position);
  7.     _second.position(0);
  8.   }
  9.   else
  10.   {
  11.     _first.position(first_limit);
  12.     _second.position(position - first_limit);
  13.   }
  14. }

代码示例来源：origin: com.microsoft.azure.iot/proton-j-azure-iot

  1. public void position(int position)
  2. {
  3.   int first_limit = _first.limit();
  4.   if( position <= first_limit )
  5.   {
  6.     _first.position(position);
  7.     _second.position(0);
  8.   }
  9.   else
  10.   {
  11.     _first.position(first_limit);
  12.     _second.position(position - first_limit);
  13.   }
  14. }

代码示例来源：origin: com.microsoft.azure.iot/proton-j-azure-iot

  1. private void endFrame(int channel)
  2. {
  3.   int frameSize = _buffer.position() - _frameStart;
  4.   int limit = _buffer.position();
  5.   _buffer.position(_frameStart);
  6.   _buffer.putInt(frameSize);
  7.   _buffer.put((byte) 2);
  8.   _buffer.put(_frameType);
  9.   _buffer.putShort((short) channel);
  10.   _buffer.position(limit);
  11. }

代码示例来源：origin: org.apache.qpid/proton

  1. int writeFrame(WritableBuffer buffer, SaslFrameBody frameBody)
  2. {
  3.   int oldPosition = buffer.position();
  4.   buffer.position(buffer.position()+8);
  5.   _encoder.setByteBuffer(buffer);
  6.   _encoder.writeObject(frameBody);
  7.   int frameSize = buffer.position() - oldPosition;
  8.   int limit = buffer.position();
  9.   buffer.position(oldPosition);
  10.   buffer.putInt(frameSize);
  11.   buffer.put((byte) 2);
  12.   buffer.put(SASL_FRAME_TYPE);
  13.   buffer.putShort((short) 0);
  14.   buffer.position(limit);
  15.   return frameSize;
  16. }

代码示例来源：origin: org.apache.qpid/proton-j-impl

  1. private void endFrame(int channel)
  2. {
  3.   int frameSize = _buffer.position() - _frameStart;
  4.   int limit = _buffer.position();
  5.   _buffer.position(_frameStart);
  6.   _buffer.putInt(frameSize);
  7.   _buffer.put((byte) 2);
  8.   _buffer.put(_frameType);
  9.   _buffer.putShort((short) channel);
  10.   _buffer.position(limit);
  11.   int offset = _bbuf.arrayOffset() + _frameStart;
  12.   //System.out.println("RAW: \"" + new Binary(_bbuf.array(), offset, frameSize) + "\"");
  13. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public ReadableBuffer get(WritableBuffer target) {
  3.  int start = target.position();
  4.  if (buffer.hasArray()) {
  5.    target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
  6.  } else {
  7.    target.put(buffer.nioBuffer());
  8.  }
  9.  int written = target.position() - start;
  10.  buffer.readerIndex(buffer.readerIndex() + written);
  11.  return this;
  12. }

代码示例来源：origin: org.apache.qpid/qpid-jms-client

  1. @Override
  2. public ReadableBuffer get(WritableBuffer target) {
  3.   int start = target.position();
  4.   if (buffer.hasArray()) {
  5.     target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
  6.   } else {
  7.     target.put(buffer.nioBuffer());
  8.   }
  9.   int written = target.position() - start;
  10.   buffer.readerIndex(buffer.readerIndex() + written);
  11.   return this;
  12. }

代码示例来源：origin: org.apache.activemq/artemis-amqp-protocol

  1. @Override
  2. public ReadableBuffer get(WritableBuffer target) {
  3.  int start = target.position();
  4.  if (buffer.hasArray()) {
  5.    target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
  6.  } else {
  7.    target.put(buffer.nioBuffer());
  8.  }
  9.  int written = target.position() - start;
  10.  buffer.readerIndex(buffer.readerIndex() + written);
  11.  return this;
  12. }

代码示例来源：origin: io.vertx/vertx-proton

  1. @Override
  2. public ReadableBuffer get(WritableBuffer target) {
  3.  int start = target.position();
  4.  if (buffer.hasArray()) {
  5.   target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
  6.  } else {
  7.   target.put(buffer.nioBuffer());
  8.  }
  9.  int written = target.position() - start;
  10.  buffer.readerIndex(buffer.readerIndex() + written);
  11.  return this;
  12. }

代码示例来源：origin: apache/qpid-jms

  1. @Override
  2. public ReadableBuffer get(WritableBuffer target) {
  3.   int start = target.position();
  4.   if (buffer.hasArray()) {
  5.     target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
  6.   } else {
  7.     target.put(buffer.nioBuffer());
  8.   }
  9.   int written = target.position() - start;
  10.   buffer.readerIndex(buffer.readerIndex() + written);
  11.   return this;
  12. }

代码示例来源：origin: org.apache.qpid/proton-j-impl

  1. private void writePerformative(Object frameBody)
  2. {
  3.   while (_buffer.remaining() < 8) {
  4.     grow();
  5.   }
  6.   while (true)
  7.   {
  8.     try
  9.     {
  10.       _buffer.position(_frameStart + 8);
  11.       _encoder.writeObject(frameBody);
  12.       break;
  13.     }
  14.     catch (BufferOverflowException e)
  15.     {
  16.       grow();
  17.     }
  18.   }
  19.   _payloadStart = _buffer.position();
  20.   _performativeSize = _payloadStart - _frameStart;
  21. }

代码示例来源：origin: com.microsoft.azure.iot/proton-j-azure-iot

  1. private void writePerformative(Object frameBody)
  2. {
  3.   while (_buffer.remaining() < 8) {
  4.     grow();
  5.   }
  6.   while (true)
  7.   {
  8.     try
  9.     {
  10.       _buffer.position(_frameStart + 8);
  11.       if (frameBody != null) _encoder.writeObject(frameBody);
  12.       break;
  13.     }
  14.     catch (BufferOverflowException e)
  15.     {
  16.       grow();
  17.     }
  18.   }
  19.   _payloadStart = _buffer.position();
  20.   _performativeSize = _payloadStart - _frameStart;
  21. }

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

WritableBuffer

相关文章

    查看更多

    热门标签

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

    最新文章

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