MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / inflightTheRpc

Method inflightTheRpc

test/TestRegionClientDecode.java:1465–1469  ·  view source on GitHub ↗

Puts the RPC in the map with the given ID and tells the RPC that this region client is handling it @param id The ID to use @param rpc The RPC

(final int id, final HBaseRpc rpc)

Source from the content-addressed store, hash-verified

1463 * @param rpc The RPC
1464 */
1465 private void inflightTheRpc(final int id, final HBaseRpc rpc) {
1466 rpcs_inflight.put(id, rpc);
1467 rpc.rpc_id = id;
1468 rpc.enqueueTimeout(region_client);
1469 }
1470
1471 /**
1472 * Creates a simple GetRequest response with some dummy data and a single

Calls 2

putMethod · 0.80
enqueueTimeoutMethod · 0.45

Tested by

no test coverage detected