Method deserialize

src/RegionClient.java:1608–1647

De-serializes an RPC response. @param buf The buffer from which to de-serialize the response. @param rpc The RPC for which we're de-serializing the response. @return The de-serialized RPC response (which can be null or an exception).

(final ChannelBuffer buf, final HBaseRpc rpc)

   * or an exception).
   */
  private Object deserialize(final ChannelBuffer buf, final HBaseRpc rpc) {
    // The 1st byte of the payload contains flags:
    //   0x00  Old style success (prior 0.92).
    //   0x01  RPC failed with an exception.
    //   0x02  New style success (0.92 and above).
    final int flags;
    if (secure_rpc_helper != null) {
      //0.94-security uses an int for the flag section
      flags = buf.readInt();
    } else {
      flags = buf.readByte();
    }
    if ((flags & HBaseRpc.RPC_FRAMED) != 0) {
      // Total size of the response, including the RPC ID (4 bytes) and flags
      // (1 byte) that we've already read, including the 4 bytes used by
      // the length itself, and including the 4 bytes used for the RPC status.
      final int length = buf.readInt() - 4 - 1 - 4 - 4;
      final int status = buf.readInt();  // Unused right now.
      try {
        HBaseRpc.checkArrayLength(buf, length);
        // Make sure we have that many bytes readable.
        // This will have to change to be able to do streaming RPCs where we
        // deserialize parts of the response as it comes off the wire.
        ensureReadable(buf, length);
      } catch (IllegalArgumentException e) {
        LOG.error("WTF?  RPC #" + rpcid + ": ", e);
      }
    } else {
      LOG.info("RPC wasn't framed: " + rpc);
    }

    if ((flags & HBaseRpc.RPC_ERROR) != 0) {
      return deserializeException(buf, rpc);
    }
    try {
      return deserializeObject(buf, rpc);
    } catch (IllegalArgumentException e) {  // The RPC didn't look good to us.
      return new InvalidResponseException(e.getMessage(), e);
    }
  }

  /**
   * Consumes a pre-protobuf RPC from HBase that has been timed out.