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

Method run

src/HBaseClient.java:3671–3682  ·  view source on GitHub ↗
(final Timeout timeout)

Source from the content-addressed store, hash-verified

3669 // failures / restarts), it may take up to several seconds.
3670 final class NSRETimer implements TimerTask {
3671 public void run(final Timeout timeout) {
3672 if (probe.attempt == 0) { // Brand new probe.
3673 probe.getDeferred().addBoth(new RetryNSREd());
3674 }
3675 if (LOG.isDebugEnabled()) {
3676 LOG.debug("Done waiting after NSRE on " + Bytes.pretty(region_name)
3677 + ", retrying " + probe);
3678 }
3679 // Make sure the probe will cause a META lookup.
3680 invalidateRegionCache(region_name, false, null);
3681 sendRpcToRegion(probe); // Restart the RPC.
3682 }
3683 public String toString() {
3684 return "probe NSRE " + probe;
3685 }

Callers

nothing calls this directly

Calls 4

prettyMethod · 0.95
invalidateRegionCacheMethod · 0.80
sendRpcToRegionMethod · 0.80
getDeferredMethod · 0.45

Tested by

no test coverage detected