Home
last modified time | relevance | path

Searched refs:shutdownSignal (Results 1 – 6 of 6) sorted by relevance

/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/example/java/javadeprecated-to-java-swift/javadeprecated/server/src/main/java/com/facebook/movies/
H A DMoviesServiceImpl.java29 private final CountDownLatch shutdownSignal = new CountDownLatch(1); field in MoviesServiceImpl
52 shutdownSignal.await(); in run()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/
H A DAsyncFileNonDurable.actor.h47 when( wait(success( g_simulator.getCurrentProcess()->shutdownSignal.getFuture() )) ) { in sendErrorOnShutdown()
67 wait(success( g_simulator.getCurrentProcess()->shutdownSignal.getFuture() )); in doShutdown()
74 when( wait(success( g_simulator.getCurrentProcess()->shutdownSignal.getFuture() )) ) { in open()
91 if( !file.getPtr() || g_simulator.getCurrentProcess()->shutdownSignal.getFuture().isReady() ) in read()
97 if( !file.getPtr() || g_simulator.getCurrentProcess()->shutdownSignal.getFuture().isReady() ) in write()
103 if( !file.getPtr() || g_simulator.getCurrentProcess()->shutdownSignal.getFuture().isReady() ) in truncate()
109 if( !file.getPtr() || g_simulator.getCurrentProcess()->shutdownSignal.getFuture().isReady() ) in sync()
115 if( !file.getPtr() || g_simulator.getCurrentProcess()->shutdownSignal.getFuture().isReady() ) in size()
202 state Future<Void> shutdown = success(currentProcess->shutdownSignal.getFuture()); in open()
H A Dsimulator.h77 Future<KillType> onShutdown() { return shutdownSignal.getFuture(); } in onShutdown()
123 Promise<KillType> shutdownSignal; member
H A Dsim2.actor.cpp744 …if(!currentProcess->rebooting && machine == currentProcess && !currentProcess->shutdownSignal.isSe… in delay()
755 ISimulator::KillType kt = wait( self->getCurrentProcess()->shutdownSignal.getFuture() ); in checkShutdown()
1706 p->shutdownSignal.send( kt ); in doReboot()
1709 p->shutdownSignal.sendError(e); // ? in doReboot()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/
H A DVFSAsync.cpp694 simCancel = success( g_simulator.getCurrentProcess()->shutdownSignal.getFuture() ); in asyncSleep()
H A DSimulatedCluster.actor.cpp287 if( !process->shutdownSignal.isSet() && !destructed ) { in simulatedFDBDRebooter()
289 process->shutdownSignal.send(ISimulator::None); in simulatedFDBDRebooter()