processTaskEntries(String, ReencryptionUpdater.ReencryptionTask) |  | 0% |  | 0% | 10 | 10 | 51 | 51 | 1 | 1 |
processCheckpoints(INode, ReencryptionUpdater.ZoneSubmissionTracker) |  | 0% |  | 0% | 12 | 12 | 38 | 38 | 1 | 1 |
processTask(ReencryptionUpdater.ReencryptionTask) |  | 0% |  | 0% | 4 | 4 | 24 | 24 | 1 | 1 |
throttle() |  | 0% |  | 0% | 4 | 4 | 16 | 16 | 1 | 1 |
takeAndProcessTasks() |  | 0% |  | 0% | 3 | 3 | 27 | 27 | 1 | 1 |
checkPauseForTesting() |  | 0% |  | 0% | 9 | 9 | 14 | 14 | 1 | 1 |
ReencryptionUpdater(FSDirectory, CompletionService, ReencryptionHandler, Configuration) |  | 0% |  | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
run() |  | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
markZoneSubmissionDone(long) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
pauseForTestingAfterNthCheckpoint(long, int) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
pauseForTesting() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
resumeForTesting() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
isRunning() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |