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)
| 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. |
no test coverage detected