Return statistics about this particular region client @return A RegionClientStats object with an immutable copy of the stats @since 1.7
()
| 313 | * @since 1.7 |
| 314 | */ |
| 315 | public RegionClientStats stats() { |
| 316 | synchronized (this) { |
| 317 | return new RegionClientStats( |
| 318 | rpcs_sent.get(), |
| 319 | rpcs_inflight != null ? rpcs_inflight.size() : 0, |
| 320 | pending_rpcs != null ? pending_rpcs.size() : 0, |
| 321 | rpcid.get(), |
| 322 | dead, |
| 323 | chan != null ? chan.getRemoteAddress().toString() : "", |
| 324 | batched_rpcs != null ? batched_rpcs.size() : 0, |
| 325 | rpcs_timedout.get(), |
| 326 | writes_blocked.get(), |
| 327 | rpc_response_timedout.get(), |
| 328 | rpc_response_unknown.get(), |
| 329 | inflight_breached.get(), |
| 330 | pending_breached.get() |
| 331 | ); |
| 332 | } |
| 333 | } |
| 334 | |
| 335 | /** Periodically flushes buffered RPCs. */ |
| 336 | private void periodicFlush() { |
nothing calls this directly
no test coverage detected