MCPcopy Index your code
hub / github.com/OpenTSDB/asynchbase / callback

Method callback

src/HBaseRpc.java:707–721  ·  view source on GitHub ↗

Package private way of making an RPC complete by giving it its result. If this RPC has no Deferred associated to it, nothing will happen. This may happen if the RPC was already called back. Once this call to this method completes, this object can be re-used to re-send the same RPC, prov

(final Object result)

Source from the content-addressed store, hash-verified

705 * RPC to be in-flight (guaranteeing this may be hard in error cases).
706 */
707 final void callback(final Object result) {
708 if (timeout_handle != null) {
709 timeout_handle.cancel();
710 timeout_task = null;
711 timeout_handle = null;
712 }
713
714 final Deferred<Object> d = deferred;
715 if (d == null) {
716 return;
717 }
718 deferred = null;
719 attempt = 0;
720 d.callback(result);
721 }
722
723 /** Checks whether or not this RPC has a Deferred without creating one. */
724 final boolean hasDeferred() {

Callers 15

encodeMethod · 0.95
decodeMethod · 0.95
removeRpcMethod · 0.95
runMethod · 0.45
shutdownMethod · 0.45
operationCompleteMethod · 0.45
callMethod · 0.45
handleExceptionMethod · 0.45
sendRpcMethod · 0.45
callMethod · 0.45
cleanupMethod · 0.45
failOrRetryRpcsMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected