Home
last modified time | relevance | path

Searched refs:getFuture (Results 76 – 100 of 266) sorted by relevance

1234567891011

/dports/net/wangle/wangle-2021.12.27.00/wangle/service/
H A DClientDispatcher.h85 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 DCoroFlow.actor.cpp75 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 DResolver.actor.cpp268 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 Dmasterserver.actor.cpp496 …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 DMasterProxyServer.actor.cpp459 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 DOldTLogServer_6_0.actor.cpp963 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 Dgenericactors.actor.h269 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 DNet2.actor.cpp250 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 DActorCollection.actor.cpp47 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 DFutureTest.cpp50 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 DFuture.h277 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 DFlowLineNoise.actor.cpp137 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 Dkeyed_executor.h174 auto future = latch->promise.getFuture(); in onAllCurrentTasksDrained()
233 Future<void> future = promise.getFuture(); in _onCleared()
H A Dout_of_line_executor.h61 auto future = promise.getFuture(); in execute()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/namespace/gen-py3/extend/
H A Dclients_wrapper.cpp19 auto _future = _promise.getFuture(); in check()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/namespace/gen-py3/hsmodule/
H A Dclients_wrapper.cpp19 auto _future = _promise.getFuture(); in init()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/namespace/gen-py3/module/
H A Dclients_wrapper.cpp19 auto _future = _promise.getFuture(); in init()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/adapter/gen-py3/module/
H A Dclients_wrapper.cpp21 auto _future = _promise.getFuture(); in func()
/dports/net/wangle/wangle-2021.12.27.00/wangle/channel/broadcast/test/
H A DObservingHandlerTest.cpp137 .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 Dsimple.h30 auto f = p.getFuture(); in future_getValueX5()
/dports/devel/folly/folly-2021.12.27.00/folly/futures/test/
H A DContextTest.cpp45 auto future = p.getFuture().thenValue([&](auto&&) { in TEST()
H A DUnwrapTest.cpp43 Future<Future<int>> future = p.getFuture(); in TEST()
/dports/net/wangle/wangle-2021.12.27.00/wangle/ssl/
H A DSSLCacheProvider.h67 virtual folly::Future<folly::ssl::SSLSessionUniquePtr> getFuture(
/dports/security/fizz/fizz-2021.12.27.00/fizz/server/test/
H A DAsyncFizzServerTest.cpp312 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 DAsyncFileWinASIO.actor.h127 return result.getFuture(); in read()
138 return result.getFuture(); in write()

1234567891011