Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -96,29 +96,4 @@ public static File createVersionFile(File parentDir,

return executor;
}

/**
* @param haltingPoint Where to halt finalization in the returned
* executor's {@code execute} method.
* @param terminateLatch The latch that will be counted down 1 by the
* executor when the upgrade finalization has been terminated.
* @param log Where to log messages about pausing and resuming finalization.
* @return A new InjectedUpgradeFinalizationExecutor
*/
public static <T> InjectedUpgradeFinalizationExecutor<T>
newTerminatingFinalizationExecutor(
UpgradeTestInjectionPoints haltingPoint,
CountDownLatch terminateLatch, Logger log) {
InjectedUpgradeFinalizationExecutor<T>
executor =
new InjectedUpgradeFinalizationExecutor<>();
executor.configureTestInjectionFunction(haltingPoint, () -> {
log.info("Terminating upgrade finalization at point: {}. This is " +
"expected test execution.", haltingPoint);
terminateLatch.countDown();
return true;
});

return executor;
}
}
Loading
Loading