Method removeRpc

src/RegionClient.java:2039–2053

Package private method to allow the timeout timer or other methods to remove an RPCfrom the inflight map. Note that the RPC ID has to be set in the RPC for this to work. And if, somehow, we pop a different RPC from the map then we'll make sure to callback the popped RPC @param rpc The RPC to remove

(final HBaseRpc rpc, final boolean timedout)

   * @return The RPC that was removed
   */
  HBaseRpc removeRpc(final HBaseRpc rpc, final boolean timedout) {
    final HBaseRpc old_rpc = rpcs_inflight.remove(rpc.rpc_id);
    if (old_rpc != rpc) {
      LOG.error("Removed the wrong RPC " + old_rpc + 
          " when we meant to remove " + rpc);
      if (old_rpc != null) {
        old_rpc.callback(new NonRecoverableException(
            "Removed the wrong RPC from client " + this));
      }
    }
    if (timedout) {
      rpcs_timedout.incrementAndGet();
    }
    return old_rpc;
  }
  
  /** @return Package private method to fetch the associated HBase client */
  HBaseClient getHBaseClient() {