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

Method retryEdit

src/RegionClient.java:941–950  ·  view source on GitHub ↗

Retries an edit that failed with a recoverable error. @param rpc The RPC that failed. @param e The recoverable error that caused the edit to fail, if known. Can be null. @param The deferred result of the new attempt to send this edit.

(final BatchableRpc rpc,
                                     final RecoverableException e)

Source from the content-addressed store, hash-verified

939 * @param The deferred result of the new attempt to send this edit.
940 */
941 private Deferred<Object> retryEdit(final BatchableRpc rpc,
942 final RecoverableException e) {
943 if (hbase_client.cannotRetryRequest(rpc)) {
944 return HBaseClient.tooManyAttempts(rpc, e);
945 }
946 // This RPC has already been delayed because of a failure,
947 // so make sure we don't buffer it again.
948 rpc.setBufferable(false);
949 return hbase_client.sendRpcToRegion(rpc);
950 }
951
952 /**
953 * Creates callbacks to handle a single-put and adds them to the request.

Callers 3

callMethod · 0.80
handleExceptionMethod · 0.80
callMethod · 0.80

Calls 4

tooManyAttemptsMethod · 0.95
cannotRetryRequestMethod · 0.80
setBufferableMethod · 0.80
sendRpcToRegionMethod · 0.80

Tested by

no test coverage detected