Method isSimulating

storm-client/src/jvm/org/apache/storm/utils/Time.java:38–40 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

36	private static final AtomicLong SIMULATED_CURR_TIME_NANOS = new AtomicLong(0);
37
38	public static boolean isSimulating() {
39	return SIMULATING.get();
40	}
41
42	public static void sleepUntil(long targetTimeMs) throws InterruptedException {
43	if (SIMULATING.get()) {

isSimulatingReturnsTrueDuringSimulationTestMethod · 0.95

waitForReaderMethod · 0.95

completeTopologyMethod · 0.95

simulateWaitMethod · 0.95

LocalClusterMethod · 0.95

addSupervisorMethod · 0.95

sendSupervisorAssignmentsMethod · 0.95

shutdownAllWorkersMethod · 0.95

testSimulatedTimeMethod · 0.95

testWithSimulatedTimeLocalClusterMethod · 0.95

getMethod · 0.65

isSimulatingReturnsTrueDuringSimulationTestMethod · 0.76

completeTopologyMethod · 0.76

simulateWaitMethod · 0.76

testSimulatedTimeMethod · 0.76

testWithSimulatedTimeLocalClusterMethod · 0.76