Github user dineshjoshi commented on a diff in the pull request: https://github.com/apache/cassandra/pull/239#discussion_r201461162 --- Diff: src/java/org/apache/cassandra/net/async/RebufferingByteBufDataInputPlus.java --- @@ -249,4 +253,50 @@ public ByteBufAllocator getAllocator() { return channelConfig.getAllocator(); } + + /** + * Consumes bytes in the stream until the given length + * + * @param writer + * @param len + * @return + * @throws IOException + */ + public long consumeUntil(BufferedDataOutputStreamPlus writer, long len) throws IOException + { + long copied = 0; // number of bytes copied + while (copied < len) + { + int position = buffer.position(); + int remaining = buffer.remaining(); + if (remaining == 0) + { + try + { + reBuffer(); + } catch (EOFException e) --- End diff -- Fixed
--- --------------------------------------------------------------------- To unsubscribe, e-mail: pr-unsubscr...@cassandra.apache.org For additional commands, e-mail: pr-h...@cassandra.apache.org