(final Timeout timeout)
| 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 | } |
nothing calls this directly
no test coverage detected