Method numberOfKeyValuesAhead

src/RegionClient.java:1874–1893

Pre-computes how many KVs we have so we can rightsized arrays. This assumes that what's coming next in the buffer is a sequence of KeyValues, each of which is prefixed by its length on 32 bits. @param buf The buffer to peek into. @param length The total size of all the KeyValues that follow.

(final ChannelBuffer buf, int length)

   * @param length The total size of all the KeyValues that follow.
   */
  static int numberOfKeyValuesAhead(final ChannelBuffer buf, int length) {
    // Immediately try to "fault" if `length' bytes aren't available.
    ensureReadable(buf, length);
    int num_kv = 0;
    int offset = buf.readerIndex();
    length += offset;
    while (offset < length) {
      final int kv_length = buf.getInt(offset);
      HBaseRpc.checkArrayLength(buf, kv_length);
      num_kv++;
      offset += kv_length + 4;
    }
    if (offset != length) {
      final int index = buf.readerIndex();
      badResponse("We wanted read " + (length - index)
                  + " bytes but we read " + (offset - index)
                  + " from " + buf + '=' + Bytes.pretty(buf));
    }
    return num_kv;
  }

  /**
   * De-serializes an {@code hbase.client.Result} object.