| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/ |
| H A D | QueueModel.h | 55 laggingRequests = actorCollection( addActor.getFuture(), &laggingRequestCount ); in QueueModel()
|
| H A D | LoadBalance.actor.h | 147 …model->laggingRequests = actorCollection( model->addActor.getFuture(), &model->laggingRequestCount… in addLaggingRequest()
321 …secondRequest = makeRequest(stream, request, backoff, requestFinished.getFuture(), model, false, a…
364 …firstRequest = makeRequest(stream, request, backoff, requestFinished.getFuture(), model, true, atM…
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/ |
| H A D | Ratekeeper.actor.cpp | 290 when (wait(err.getFuture())) {} in trackEachStorageServer()
642 state Future<Void> collection = actorCollection( self.addActor.getFuture() ); in ratekeeper()
645 self.addActor.send( waitFailureServer(rkInterf.waitFailure.getFuture()) ); in ratekeeper()
650 self.addActor.send( trackEachStorageServer(&self, serverChanges.getFuture()) ); in ratekeeper()
679 when (GetRateInfoRequest req = waitNext(rkInterf.getRateInfo.getFuture())) { in ratekeeper()
705 when (HaltRatekeeperRequest req = waitNext(rkInterf.haltRatekeeper.getFuture())) { in ratekeeper()
710 when (wait(err.getFuture())) {} in ratekeeper()
|
| H A D | OldTLogServer_4_6.actor.cpp | 881 Version ver = wait(trackerData.sequence_version[sequence].getFuture()); in tLogPeekMessages()
970 if(sequenceData.getFuture().get() != reply.end) { in tLogPeekMessages()
1143 when( TLogPeekRequest req = waitNext( tli.peekMessages.getFuture() ) ) { in serveTLogInterface()
1146 when( TLogPopRequest req = waitNext( tli.popMessages.getFuture() ) ) { in serveTLogInterface()
1149 when( TLogCommitRequest req = waitNext( tli.commit.getFuture() ) ) { in serveTLogInterface()
1153 when( ReplyPromise< TLogLockResult > reply = waitNext( tli.lock.getFuture() ) ) { in serveTLogInterface()
1156 when (TLogQueuingMetricsRequest req = waitNext(tli.getQueuingMetrics.getFuture())) { in serveTLogInterface()
1159 when (TLogConfirmRunningRequest req = waitNext(tli.confirmRunning.getFuture())){ in serveTLogInterface()
1207 state Future<Void> error = actorCollection( logData->addActor.getFuture() ); in tLogCore()
1210 logData->addActor.send( waitFailureServer(logData->tli.waitFailure.getFuture()) ); in tLogCore()
[all …]
|
| H A D | storageserver.actor.cpp | 863 GetValueReply reply = wait( getReq.reply.getFuture() ); in watchValue_impl()
1544 Future<Void> checkFatalError = data->otherError.getFuture(); in changeDurableVersion()
1870 wait( data->coreStarted.getFuture() && delay( 0 ) ); in fetchKeys()
2046 FetchInjectionInfo* batch = wait( p.getFuture() ); in fetchKeys()
2387 if (data->otherError.getFuture().isReady()) data->otherError.getFuture().get(); in applyMutation()
2686 if (data->otherError.getFuture().isReady()) data->otherError.getFuture().get(); in update()
2691 if (data->otherError.getFuture().isReady()) data->otherError.getFuture().get(); in update()
2747 data->durableInProgress = durableInProgress.getFuture(); in updateStorage()
3017 wait( byteSampleSampleRecovered.getFuture() ); in restoreDurableState()
3348 actors.add(waitFailureServer(ssi.waitFailure.getFuture())); in storageServerCore()
[all …]
|
| H A D | LogSystemDiskQueueAdapter.actor.cpp | 146 return cm.acknowledge.getFuture(); in commit()
168 return pcm.getFuture(); in getCommitMessage()
|
| H A D | Orderer.actor.h | 59 wait( yield( taskID ) || self->shutdown.getFuture() ); in waitAndOrder()
|
| H A D | TLogServer.actor.cpp | 1240 Version ver = wait(trackerData.sequence_version[sequence].getFuture()); in tLogPeekMessages()
1289 if(sequenceData.getFuture().get() != rep.end) { in tLogPeekMessages()
1437 if(sequenceData.getFuture().get() != reply.end) { in tLogPeekMessages()
1730 wait( recoveryComplete.getFuture() ); in respondToRecovered()
1812 when( TLogPeekRequest req = waitNext( tli.peekMessages.getFuture() ) ) { in serveTLogInterface()
1815 when( TLogPopRequest req = waitNext( tli.popMessages.getFuture() ) ) { in serveTLogInterface()
1818 when( TLogCommitRequest req = waitNext( tli.commit.getFuture() ) ) { in serveTLogInterface()
2009 logData->addActor.send( waitFailureServer( tli.waitFailure.getFuture()) ); in tLogCore()
2442 wait(logData->committingQueue.getFuture() || logData->removed ); in tLogStart()
2495 self.tlogCache.set( req.recruitmentID, req.reply.getFuture() ); in tLog()
[all …]
|
| H A D | DataDistributionQueue.actor.cpp | 1020 when( wait( signalledTransferComplete ? Never() : dataMovementComplete.getFuture() ) ) { in dataDistributionRelocator()
1253 when ( RelocateData results = waitNext( self.fetchSourceServersComplete.getFuture() ) ) { in dataDistributionQueue()
1257 when ( RelocateData done = waitNext( self.dataTransferComplete.getFuture() ) ) { in dataDistributionQueue()
1263 when ( RelocateData done = waitNext( self.relocationComplete.getFuture() ) ) { in dataDistributionQueue()
1274 when ( KeyRange done = waitNext( rangesComplete.getFuture() ) ) { in dataDistributionQueue()
1296 .detail( "AverageShardSize", req.getFuture().isReady() ? req.getFuture().get() : -1 ) in dataDistributionQueue()
1303 when ( wait( self.error.getFuture() ) ) {} // Propagate errors from dataDistributionRelocator in dataDistributionQueue()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/generate/templates/py3/clients/ |
| H A D | clients_wrapper.cpp_func_body.mustache | 2 auto _future = _promise.getFuture();
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/flow/ |
| H A D | flow.h | 635 Future<T> getFuture() const { sav->addFutureRef(); return Future<T>(sav); } in getFuture() function
732 #define REPLY_TYPE(RequestType) decltype( getReplyPromise( fake<RequestType>() ).getFuture().getVal…
739 typedef decltype(fake<T>().reply.getFuture().getValue()) Type;
773 return getReplyPromise(value).getFuture();
778 return getReplyPromise(value).getFuture();
792 FutureStream<T> getFuture() const { queue->addFutureRef(); return FutureStream<T>(queue); }
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/generate/templates/cpp2/service_async_client_cpp/ |
| H A D | future_functions.mustache | 36 auto future = promise.getFuture();
65 auto future = promise.getFuture();
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/visitation/gen-cpp2/ |
| H A D | service_with_special_namesAsyncClient.cpp | 574 auto future = promise.getFuture(); in future_get()
589 auto future = promise.getFuture(); in header_future_get()
764 auto future = promise.getFuture(); in future_getter()
779 auto future = promise.getFuture(); in header_future_getter()
954 auto future = promise.getFuture(); in future_lists()
969 auto future = promise.getFuture(); in header_future_lists()
1144 auto future = promise.getFuture(); in future_maps()
1159 auto future = promise.getFuture(); in header_future_maps()
1334 auto future = promise.getFuture(); in future_name()
1349 auto future = promise.getFuture(); in header_future_name()
[all …]
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/fatal/gen-cpp2/ |
| H A D | service_with_special_namesAsyncClient.cpp | 574 auto future = promise.getFuture(); in future_get()
589 auto future = promise.getFuture(); in header_future_get()
764 auto future = promise.getFuture(); in future_getter()
779 auto future = promise.getFuture(); in header_future_getter()
954 auto future = promise.getFuture(); in future_lists()
969 auto future = promise.getFuture(); in header_future_lists()
1144 auto future = promise.getFuture(); in future_maps()
1159 auto future = promise.getFuture(); in header_future_maps()
1334 auto future = promise.getFuture(); in future_name()
1349 auto future = promise.getFuture(); in header_future_name()
[all …]
|
| /dports/devel/folly/folly-2021.12.27.00/folly/futures/ |
| H A D | FutureSplitter.h | 63 Future<T> getFuture() { in getFuture() function
|
| /dports/math/openturns/openturns-1.18/python/test/ |
| H A D | t_CompositeProcess_std.py | 34 print('future=', myCompositeProcess.getFuture(5))
|
| /dports/devel/folly/folly-2021.12.27.00/folly/experimental/ |
| H A D | FutureDAG.h | 125 dependencies.push_back(nodes[depHandle].promise.getFuture()); in go()
141 return nodes[sinkHandle].promise.getFuture().thenValue( in go()
|
| /dports/math/openturns/openturns-1.18/python/src/ |
| H A D | Process_doc.i.in | 13 %feature("docstring") OT::Process::getFuture
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/mcpp2-compare/gen-cpp2/ |
| H A D | ReturnServiceAsyncClient.cpp | 464 auto future = promise.getFuture(); in future_noReturn()
479 auto future = promise.getFuture(); in header_future_noReturn()
652 auto future = promise.getFuture(); in future_boolReturn()
667 auto future = promise.getFuture(); in header_future_boolReturn()
842 auto future = promise.getFuture(); in future_i16Return()
857 auto future = promise.getFuture(); in header_future_i16Return()
1032 auto future = promise.getFuture(); in future_i32Return()
1047 auto future = promise.getFuture(); in header_future_i32Return()
1222 auto future = promise.getFuture(); in future_i64Return()
1237 auto future = promise.getFuture(); in header_future_i64Return()
[all …]
|
| /dports/net/wangle/wangle-2021.12.27.00/wangle/channel/ |
| H A D | OutputBufferingHandler.h | 54 return sharedPromise_.getFuture(); in write()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/basic-annotations/gen-cpp2/ |
| H A D | MyServiceAsyncClient.cpp | 243 auto future = promise.getFuture(); in future_ping()
258 auto future = promise.getFuture(); in header_future_ping()
431 auto future = promise.getFuture(); in future_getRandomData()
446 auto future = promise.getFuture(); in header_future_getRandomData()
619 auto future = promise.getFuture(); in future_hasDataById()
634 auto future = promise.getFuture(); in header_future_hasDataById()
809 auto future = promise.getFuture(); in future_getDataById()
824 auto future = promise.getFuture(); in header_future_getDataById()
997 auto future = promise.getFuture(); in future_putDataById()
1012 auto future = promise.getFuture(); in header_future_putDataById()
[all …]
|
| H A D | MyServicePrioParentAsyncClient.cpp | 158 auto future = promise.getFuture(); in future_ping()
173 auto future = promise.getFuture(); in header_future_ping()
346 auto future = promise.getFuture(); in future_pong()
361 auto future = promise.getFuture(); in header_future_pong()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/coroutines/gen-cpp2/ |
| H A D | MyServiceAsyncClient.cpp | 210 auto future = promise.getFuture(); in future_ping()
225 auto future = promise.getFuture(); in header_future_ping()
398 auto future = promise.getFuture(); in future_getRandomData()
413 auto future = promise.getFuture(); in header_future_getRandomData()
586 auto future = promise.getFuture(); in future_hasDataById()
601 auto future = promise.getFuture(); in header_future_hasDataById()
776 auto future = promise.getFuture(); in future_getDataById()
791 auto future = promise.getFuture(); in header_future_getDataById()
964 auto future = promise.getFuture(); in future_putDataById()
979 auto future = promise.getFuture(); in header_future_putDataById()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/exceptions/gen-cpp2/ |
| H A D | RaiserAsyncClient.cpp | 190 auto future = promise.getFuture(); in future_doBland()
205 auto future = promise.getFuture(); in header_future_doBland()
378 auto future = promise.getFuture(); in future_doRaise()
393 auto future = promise.getFuture(); in header_future_doRaise()
566 auto future = promise.getFuture(); in future_get200()
581 auto future = promise.getFuture(); in header_future_get200()
754 auto future = promise.getFuture(); in future_get500()
769 auto future = promise.getFuture(); in header_future_get500()
|
| /dports/graphics/osgearth/osgearth-osgearth-2.10.1/src/osgEarth/ |
| H A D | ThreadingUtils | 135 * and immediately returns promise.getFuture(). The Consumer then performs other
197 * Promise.getFuture(). The caller can then call future.get() to block until
205 const Future<T> getFuture() const { return _future; }
|