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

Method getInflightRpcs

src/RegionClient.java:447–454  ·  view source on GitHub ↗

Returns a possibly empty list of all the RPCs that are in-flight.

()

Source from the content-addressed store, hash-verified

445 * Returns a possibly empty list of all the RPCs that are in-flight.
446 */
447 private ArrayList<Deferred<Object>> getInflightRpcs() {
448 final ArrayList<Deferred<Object>> inflight =
449 new ArrayList<Deferred<Object>>();
450 for (final HBaseRpc rpc : rpcs_inflight.values()) {
451 inflight.add(rpc.getDeferred());
452 }
453 return inflight;
454 }
455
456 /**
457 * Returns a possibly {@code null} list of all RPCs that are pending.

Callers 2

syncMethod · 0.95
shutdownMethod · 0.95

Calls 3

valuesMethod · 0.65
addMethod · 0.45
getDeferredMethod · 0.45

Tested by

no test coverage detected