Returns a possibly empty list of all the RPCs that are in-flight.
()
| 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. |
no test coverage detected