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

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

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

WritableBuffer.remaining介绍

暂无

代码示例

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

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

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

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

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

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

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

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

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

  1. public void put(ByteBuffer payload)
  2. {
  3.   int firstRemaining = _first.remaining();
  4.   if(firstRemaining > 0)
  5.   {
  6.     if(firstRemaining >= payload.remaining())
  7.     {
  8.       _first.put(payload);
  9.       return;
  10.     }
  11.     else
  12.     {
  13.       int limit = payload.limit();
  14.       payload.limit(payload.position()+firstRemaining);
  15.       _first.put(payload);
  16.       payload.limit(limit);
  17.     }
  18.   }
  19.   _second.put(payload);
  20. }

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

  1. @Override
  2. public void putShort(short s)
  3. {
  4.   int remaining = _first.remaining();
  5.   if(remaining >= 2)
  6.   {
  7.     _first.putShort(s);
  8.   }
  9.   else if(remaining ==0 )
  10.   {
  11.     _second.putShort(s);
  12.   }
  13.   else
  14.   {
  15.     ByteBuffer wrap = ByteBuffer.wrap(new byte[2]);
  16.     wrap.putShort(s);
  17.     wrap.flip();
  18.     put(wrap);
  19.   }
  20. }

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

  1. @Override
  2. public void putLong(long l)
  3. {
  4.   int remaining = _first.remaining();
  5.   if(remaining >= 8)
  6.   {
  7.     _first.putLong(l);
  8.   }
  9.   else if(remaining ==0 )
  10.   {
  11.     _second.putLong(l);
  12.   }
  13.   else
  14.   {
  15.     ByteBuffer wrap = ByteBuffer.wrap(new byte[8]);
  16.     wrap.putLong(l);
  17.     wrap.flip();
  18.     put(wrap);
  19.   }
  20. }

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

  1. public void putInt(int i)
  2. {
  3.   int remaining = _first.remaining();
  4.   if(remaining >= 4)
  5.   {
  6.     _first.putInt(i);
  7.   }
  8.   else if(remaining ==0 )
  9.   {
  10.     _second.putInt(i);
  11.   }
  12.   else
  13.   {
  14.     ByteBuffer wrap = ByteBuffer.wrap(new byte[4]);
  15.     wrap.putInt(i);
  16.     wrap.flip();
  17.     put(wrap);
  18.   }
  19. }

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

  1. public void putShort(short s)
  2. {
  3.   int remaining = _first.remaining();
  4.   if(remaining >= 2)
  5.   {
  6.     _first.putShort(s);
  7.   }
  8.   else if(remaining ==0 )
  9.   {
  10.     _second.putShort(s);
  11.   }
  12.   else
  13.   {
  14.     ByteBuffer wrap = ByteBuffer.wrap(new byte[2]);
  15.     wrap.putShort(s);
  16.     wrap.flip();
  17.     put(wrap);
  18.   }
  19. }

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

  1. public void putShort(short s)
  2. {
  3.   int remaining = _first.remaining();
  4.   if(remaining >= 2)
  5.   {
  6.     _first.putShort(s);
  7.   }
  8.   else if(remaining ==0 )
  9.   {
  10.     _second.putShort(s);
  11.   }
  12.   else
  13.   {
  14.     ByteBuffer wrap = ByteBuffer.wrap(new byte[2]);
  15.     wrap.putShort(s);
  16.     wrap.flip();
  17.     put(wrap);
  18.   }
  19. }

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

  1. public void putLong(long l)
  2. {
  3.   int remaining = _first.remaining();
  4.   if(remaining >= 8)
  5.   {
  6.     _first.putLong(l);
  7.   }
  8.   else if(remaining ==0 )
  9.   {
  10.     _second.putLong(l);
  11.   }
  12.   else
  13.   {
  14.     ByteBuffer wrap = ByteBuffer.wrap(new byte[8]);
  15.     wrap.putLong(l);
  16.     wrap.flip();
  17.     put(wrap);
  18.   }
  19. }

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

  1. @Override
  2. public CompositeReadableBuffer get(WritableBuffer target) {
  3.   int length = Math.min(target.remaining(), remaining());
  4.   do {
  5.     final int chunk = Math.min((currentArray.length - currentOffset), length);
  6.     if (chunk == 0) {
  7.       break;  // This buffer is out of data
  8.     }
  9.     target.put(currentArray, currentOffset, chunk);
  10.     currentOffset += chunk;
  11.     position += chunk;
  12.     length -= chunk;
  13.     maybeMoveToNextArray();
  14.   } while (length > 0);
  15.   return this;
  16. }

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

  1. public void putLong(long l)
  2. {
  3.   int remaining = _first.remaining();
  4.   if(remaining >= 8)
  5.   {
  6.     _first.putLong(l);
  7.   }
  8.   else if(remaining ==0 )
  9.   {
  10.     _second.putLong(l);
  11.   }
  12.   else
  13.   {
  14.     ByteBuffer wrap = ByteBuffer.wrap(new byte[8]);
  15.     wrap.putLong(l);
  16.     wrap.flip();
  17.     put(wrap);
  18.   }
  19. }

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

  1. public void putLong(long l)
  2. {
  3.   int remaining = _first.remaining();
  4.   if(remaining >= 8)
  5.   {
  6.     _first.putLong(l);
  7.   }
  8.   else if(remaining ==0 )
  9.   {
  10.     _second.putLong(l);
  11.   }
  12.   else
  13.   {
  14.     ByteBuffer wrap = ByteBuffer.wrap(new byte[8]);
  15.     wrap.putLong(l);
  16.     wrap.flip();
  17.     put(wrap);
  18.   }
  19. }

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

  1. public void putInt(int i)
  2. {
  3.   int remaining = _first.remaining();
  4.   if(remaining >= 4)
  5.   {
  6.     _first.putInt(i);
  7.   }
  8.   else if(remaining ==0 )
  9.   {
  10.     _second.putInt(i);
  11.   }
  12.   else
  13.   {
  14.     ByteBuffer wrap = ByteBuffer.wrap(new byte[4]);
  15.     wrap.putInt(i);
  16.     wrap.flip();
  17.     put(wrap);
  18.   }
  19. }

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

  1. int recv(final WritableBuffer buffer)
  2. {
  3.   final int consumed;
  4.   if (_dataBuffer != null && _dataBuffer.hasRemaining())
  5.   {
  6.     consumed = Math.min(buffer.remaining(), _dataBuffer.remaining());
  7.     buffer.put(_dataBuffer);
  8.     _dataBuffer.reclaimRead();
  9.   }
  10.   else
  11.   {
  12.     consumed = 0;
  13.   }
  14.   return (_complete && consumed == 0) ? Transport.END_OF_STREAM : consumed;
  15. }

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

  1. @Override
  2. public void put(byte[] src, int offset, int length)
  3. {
  4.   final int firstRemaining = _first.remaining();
  5.   if(firstRemaining > 0)
  6.   {
  7.     if(firstRemaining >= length)
  8.     {
  9.       _first.put(src, offset, length);
  10.       return;
  11.     }
  12.     else
  13.     {
  14.       _first.put(src,offset, firstRemaining);
  15.     }
  16.   }
  17.   _second.put(src, offset+firstRemaining, length-firstRemaining);
  18. }

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

  1. public void put(byte[] src, int offset, int length)
  2. {
  3.   final int firstRemaining = _first.remaining();
  4.   if(firstRemaining > 0)
  5.   {
  6.     if(firstRemaining >= length)
  7.     {
  8.       _first.put(src, offset, length);
  9.       return;
  10.     }
  11.     else
  12.     {
  13.       _first.put(src,offset, firstRemaining);
  14.     }
  15.   }
  16.   _second.put(src, offset+firstRemaining, length-firstRemaining);
  17. }

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

  1. public void put(byte[] src, int offset, int length)
  2. {
  3.   final int firstRemaining = _first.remaining();
  4.   if(firstRemaining > 0)
  5.   {
  6.     if(firstRemaining >= length)
  7.     {
  8.       _first.put(src, offset, length);
  9.       return;
  10.     }
  11.     else
  12.     {
  13.       _first.put(src,offset, firstRemaining);
  14.     }
  15.   }
  16.   _second.put(src, offset+firstRemaining, length-firstRemaining);
  17. }

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

  1. public void put(byte[] src, int offset, int length)
  2. {
  3.   final int firstRemaining = _first.remaining();
  4.   if(firstRemaining > 0)
  5.   {
  6.     if(firstRemaining >= length)
  7.     {
  8.       _first.put(src, offset, length);
  9.       return;
  10.     }
  11.     else
  12.     {
  13.       _first.put(src,offset, firstRemaining);
  14.     }
  15.   }
  16.   _second.put(src, offset+firstRemaining, length-firstRemaining);
  17. }

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

WritableBuffer

相关文章

    查看更多

    热门标签

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

    最新文章

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