/dports/net/wangle/wangle-2021.12.27.00/wangle/service/ |
H A D | ClientDispatcher.h | 85 auto f = p_->getFuture(); in operator() 116 auto f = p.getFuture(); in operator()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/ |
H A D | CoroFlow.actor.cpp | 75 CoroThreadPool::waitFor( blocked.getFuture() ); in block() 210 pool->anyError.add( w->error.getFuture() ); in addThread() 211 pool->allStopped.add( w->stopped.getFuture() ); in addThread()
|
H A D | Resolver.actor.cpp | 268 actors.add( waitFailureServer(resolver.waitFailure.getFuture()) ); in resolverCore() 272 when ( ResolveTransactionBatchRequest batch = waitNext( resolver.resolve.getFuture() ) ) { in resolverCore() 275 when ( ResolutionMetricsRequest req = waitNext( resolver.metrics.getFuture() ) ) { in resolverCore() 278 when ( ResolutionSplitRequest req = waitNext( resolver.split.getFuture() ) ) { in resolverCore()
|
H A D | masterserver.actor.cpp | 496 …uture<Void> waitFailure = waitFailureServer(parent->provisionalProxies[0].waitFailure.getFuture()); in provisionalMaster() 507 …ionRequest req = waitNext( parent->provisionalProxies[0].getConsistentReadVersion.getFuture() ) ) { in provisionalMaster() 517 …when ( CommitTransactionRequest req = waitNext( parent->provisionalProxies[0].commit.getFuture() )… in provisionalMaster() 537 …tionsRequest req = waitNext( parent->provisionalProxies[0].getKeyServersLocations.getFuture() ) ) { in provisionalMaster() 958 when(GetCommitVersionRequest req = waitNext(self->myInterface.getCommitVersion.getFuture())) { in provideVersions() 1096 ChangeCoordinatorsRequest req = waitNext( self->myInterface.changeCoordinators.getFuture() ); in changeCoordinators() 1124 TLogRejoinRequest req = waitNext( self->myInterface.tlogRejoin.getFuture() ); in rejoinRequestHandler() 1224 self->addActor.send( waitFailureServer(self->myInterface.waitFailure.getFuture()) ); in masterCore() 1392 wait(self->cstateUpdated.getFuture()); in masterCore() 1432 state Future<Void> collection = actorCollection( self->addActor.getFuture() ); in masterServer() [all …]
|
H A D | MasterProxyServer.actor.cpp | 459 Future<GetCommitVersionReply> fVersionReply = waitNext(self->commitBatchVersions.getFuture()); in commitBatch() 1064 waitNext(commitData->commitBatchStartNotifications.getFuture()); in fetchVersions() 1121 …onQueue, proxy.getConsistentReadVersion.getFuture(), GRVTimer, &lastGRVTime, &GRVBatchTime, replyT… in transactionStarter() 1136 waitNext(GRVTimer.getFuture()); in transactionStarter() 1231 wait(commitData->validState.getFuture()); in readRequestServer() 1237 when(GetKeyServerLocationsRequest req = waitNext(proxy.getKeyServersLocations.getFuture())) { in readRequestServer() 1277 …when(GetStorageServerRejoinInfoRequest req = waitNext(proxy.getStorageServerRejoinInfo.getFuture()… in readRequestServer() 1343 waitNext(proxy.getHealthMetrics.getFuture())) in healthMetricsRequestServer() 1436 addActor.send( waitFailureServer(proxy.waitFailure.getFuture()) ); in masterProxyServerCore() 1531 when(GetRawCommittedVersionRequest req = waitNext(proxy.getRawCommittedVersion.getFuture())) { in masterProxyServerCore() [all …]
|
H A D | OldTLogServer_6_0.actor.cpp | 963 Version ver = wait(trackerData.sequence_version[sequence].getFuture()); in tLogPeekMessages() 1012 if(sequenceData.getFuture().get() != rep.end) { in tLogPeekMessages() 1078 if(sequenceData.getFuture().get() != reply.end) { in tLogPeekMessages() 1370 wait( recoveryComplete.getFuture() ); in respondToRecovered() 1452 when( TLogPeekRequest req = waitNext( tli.peekMessages.getFuture() ) ) { in serveTLogInterface() 1455 when( TLogPopRequest req = waitNext( tli.popMessages.getFuture() ) ) { in serveTLogInterface() 1458 when( TLogCommitRequest req = waitNext( tli.commit.getFuture() ) ) { in serveTLogInterface() 1741 tlogRequests.getFuture().pop().reply.sendError(recruitment_failed()); in restorePersistentState() 2055 wait(logData->committingQueue.getFuture() || logData->removed ); in tLogStart() 2108 self.tlogCache.set( req.recruitmentID, req.reply.getFuture() ); in tLog() [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/flow/ |
H A D | genericactors.actor.h | 269 Future<T> result = resultPromise.getFuture(); in uncancellable() 602 return item.change.getFuture(); in onChange() 650 ASSERT(p.change.getFuture() == change); in destroyOnCancel() 671 return nextChange.getFuture(); in onChange() 1297 wait( it->first.getFuture() ); in takeActor() 1329 when(wait(lock->broken_on_destruct.getFuture())) {} in safeYieldActor() 1438 return yieldedFuture(item.change.getFuture()); in onChange() 1449 ASSERT(p.change.getFuture() == change); in destroyOnCancelYield() 1486 return getFuture(); 1505 Future<Void> getFuture() { in getFuture() function [all …]
|
H A D | Net2.actor.cpp | 250 Future<Void> getFuture() { return p.getFuture(); } in getFuture() function in N2::BindPromise 290 Future<Void> onConnected = p.getFuture(); in connect() 313 auto f = p.getFuture(); in onWritable() 322 auto f = p.getFuture(); in onReadable() 466 auto f = p.getFuture(); in doAccept() 816 return t->promise.getFuture(); in delay() 824 return t->promise.getFuture(); in delay() 854 state Future<std::vector<NetworkAddress>> result = promise.getFuture(); in resolveTCPEndpoint_impl()
|
H A D | ActorCollection.actor.cpp | 47 when (int64_t t = waitNext(complete.getFuture())) { in actorCollection() 59 when (Error e = waitNext(errors.getFuture())) { throw e; } in actorCollection()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/test/ |
H A D | FutureTest.cpp | 50 auto f = p.getFuture(); in future_sendResponse() 68 auto f = p.getFuture(); in future_noResponse() 101 auto f = p.getFuture(); in future_throwing() 114 auto f = p.getFuture(); in future_voidThrowing()
|
/dports/sysutils/py-pywatchman/watchman-4.9.0/ |
H A D | Future.h | 277 auto result = state->promise.getFuture(); 307 auto result = state->promise.getFuture(); 396 Future<T> getFuture() { 458 return state->p.getFuture();
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbcli/ |
H A D | FlowLineNoise.actor.cpp | 137 auto f = r->result.getFuture(); in read() 153 wait(result.getFuture()); in waitKeyboardInterrupt()
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/util/ |
H A D | keyed_executor.h | 174 auto future = latch->promise.getFuture(); in onAllCurrentTasksDrained() 233 Future<void> future = promise.getFuture(); in _onCleared()
|
H A D | out_of_line_executor.h | 61 auto future = promise.getFuture(); in execute()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/namespace/gen-py3/extend/ |
H A D | clients_wrapper.cpp | 19 auto _future = _promise.getFuture(); in check()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/namespace/gen-py3/hsmodule/ |
H A D | clients_wrapper.cpp | 19 auto _future = _promise.getFuture(); in init()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/namespace/gen-py3/module/ |
H A D | clients_wrapper.cpp | 19 auto _future = _promise.getFuture(); in init()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/adapter/gen-py3/module/ |
H A D | clients_wrapper.cpp | 21 auto _future = _promise.getFuture(); in func()
|
/dports/net/wangle/wangle-2021.12.27.00/wangle/channel/broadcast/test/ |
H A D | ObservingHandlerTest.cpp | 137 .WillOnce(Return(makeMoveWrapper(promise.getFuture()))); in TEST_F() 161 .WillOnce(Return(makeMoveWrapper(promise.getFuture()))); in TEST_F() 348 .WillOnce(Return(makeMoveWrapper(promise.getFuture()))); in TEST_F()
|
/dports/devel/folly/folly-2021.12.27.00/folly/python/test/ |
H A D | simple.h | 30 auto f = p.getFuture(); in future_getValueX5()
|
/dports/devel/folly/folly-2021.12.27.00/folly/futures/test/ |
H A D | ContextTest.cpp | 45 auto future = p.getFuture().thenValue([&](auto&&) { in TEST()
|
H A D | UnwrapTest.cpp | 43 Future<Future<int>> future = p.getFuture(); in TEST()
|
/dports/net/wangle/wangle-2021.12.27.00/wangle/ssl/ |
H A D | SSLCacheProvider.h | 67 virtual folly::Future<folly::ssl::SSLSessionUniquePtr> getFuture(
|
/dports/security/fizz/fizz-2021.12.27.00/fizz/server/test/ |
H A D | AsyncFizzServerTest.cpp | 312 InvokeWithoutArgs([&p1]() { return AsyncActions(p1.getFuture()); })); in TEST_F() 318 InvokeWithoutArgs([&p2]() { return AsyncActions(p2.getFuture()); })); in TEST_F() 344 InvokeWithoutArgs([&p]() { return AsyncActions(p.getFuture()); })); in TEST_F() 360 InvokeWithoutArgs([&p]() { return AsyncActions(p.getFuture()); })); in TEST_F() 382 InvokeWithoutArgs([&p]() { return AsyncActions(p.getFuture()); })); in TEST_F()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/ |
H A D | AsyncFileWinASIO.actor.h | 127 return result.getFuture(); in read() 138 return result.getFuture(); in write()
|