Home
last modified time | relevance | path

Searched refs:addActor (Results 1 – 25 of 54) sorted by relevance

123

/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/
H A DQueueModel.h50 PromiseStream< Future<Void> > addActor; variable
55 laggingRequests = actorCollection( addActor.getFuture(), &laggingRequestCount ); in QueueModel()
H A DLoadBalance.actor.h146 model->addActor = PromiseStream<Future<Void>>(); in addLaggingRequest()
147 …model->laggingRequests = actorCollection( model->addActor.getFuture(), &model->laggingRequestCount… in addLaggingRequest()
150 model->addActor.send(success(errorOr(reply))); in addLaggingRequest()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/
H A Dmasterserver.actor.cpp103 PromiseStream<Future<Void>> addActor; member in ReusableCoordinatedState
113 self->addActor.send( onConflict ); in _read()
219 PromiseStream<Future<Void>> addActor; member
232 PromiseStream<Future<Void>> const& addActor, in MasterData()
238 cstate(coordinators, addActor, dbgid), in MasterData()
254 addActor(addActor), in MasterData()
1354 self->addActor.send( provideVersions(self) ); in masterCore()
1420 self->addActor.send( changeCoordinators(self) ); in masterCore()
1430 state PromiseStream<Future<Void>> addActor; in masterServer() local
1458 while(!self->addActor.isEmpty()) { in masterServer()
[all …]
H A DMasterProxyServer.actor.cpp1103 PromiseStream<Future<Void>> addActor, in transactionStarter() argument
1212 addActor.send(sendGrvReplies(readVersionReply, start[i], &commitData->stats)); in transactionStarter()
1216 addActor.send(timeReply(readVersionReply, replyTimes)); in transactionStarter()
1426 state PromiseStream<Future<Void>> addActor; in masterProxyServerCore() local
1435 addActor.send( fetchVersions(&commitData) ); in masterProxyServerCore()
1436 addActor.send( waitFailureServer(proxy.waitFailure.getFuture()) ); in masterProxyServerCore()
1455 commitData.logSystem = ILogSystem::fromServerDBInfo(proxy.id(), db->get(), false, addActor); in masterProxyServerCore()
1464 addActor.send(monitorRemoteCommitted(&commitData, db)); in masterProxyServerCore()
1465 …addActor.send(transactionStarter(proxy, db, addActor, &commitData, &healthMetricsReply, &detailedH… in masterProxyServerCore()
1466 addActor.send(readRequestServer(proxy, &commitData)); in masterProxyServerCore()
[all …]
H A DLogRouter.actor.cpp394 state PromiseStream<Future<Void>> addActor; in logRouterCore() local
395 state Future<Void> error = actorCollection( addActor.getFuture() ); in logRouterCore()
398 addActor.send( pullAsyncData(&logRouterData) ); in logRouterCore()
407 addActor.send( logRouterPeekMessages( &logRouterData, req ) ); in logRouterCore()
410 addActor.send( logRouterPop( &logRouterData, req ) ); in logRouterCore()
H A DRatekeeper.actor.cpp159 PromiseStream<Future<Void>> addActor; member
642 state Future<Void> collection = actorCollection( self.addActor.getFuture() ); in ratekeeper()
645 self.addActor.send( waitFailureServer(rkInterf.waitFailure.getFuture()) ); in ratekeeper()
646 self.addActor.send( configurationMonitor(dbInfo, &self.configuration) ); in ratekeeper()
649 self.addActor.send( monitorServerListChange(dbInfo, serverChanges) ); in ratekeeper()
650 self.addActor.send( trackEachStorageServer(&self, serverChanges.getFuture()) ); in ratekeeper()
H A DOldTLogServer_4_6.actor.cpp403 PromiseStream<Future<Void>> addActor; member
1144 logData->addActor.send( tLogPeekMessages( self, req, logData ) ); in serveTLogInterface()
1147 logData->addActor.send( tLogPop( self, req, logData ) ); in serveTLogInterface()
1154 logData->addActor.send( tLogLock(self, reply, logData) ); in serveTLogInterface()
1178 …logData->addActor = PromiseStream<Future<Void>>(); //there could be items still in the promise str… in removeLog()
1207 state Future<Void> error = actorCollection( logData->addActor.getFuture() ); in tLogCore()
1209 logData->addActor.send( logData->recovery ); in tLogCore()
1210 logData->addActor.send( waitFailureServer(logData->tli.waitFailure.getFuture()) ); in tLogCore()
1211 logData->addActor.send( logData->removed ); in tLogCore()
1213 …logData->addActor.send( traceCounters("TLogMetrics", logData->logId, SERVER_KNOBS->STORAGE_LOGGING… in tLogCore()
[all …]
H A DClusterController.actor.cpp1157 PromiseStream<Future<Void>> addActor;
2616 self.addActor.send( self.updateWorkerList.init( self.db.db ) );
2618 self.addActor.send( timeKeeper(&self) );
2619 self.addActor.send( monitorProcessClasses(&self) );
2620 self.addActor.send( monitorClientTxnInfoConfigs(&self.db) );
2621 self.addActor.send( updatedChangingDatacenters(&self) );
2622 self.addActor.send( updatedChangedDatacenters(&self) );
2624 self.addActor.send( handleForcedRecoveries(&self, interf) );
2625 self.addActor.send( monitorDataDistributor(&self) );
2626 self.addActor.send( monitorRatekeeper(&self) );
[all …]
H A DDataDistribution.actor.cpp544 PromiseStream<Future<Void>> addActor; member
2327 self->addActor.send(self->badTeamRemover); in teamRemover()
3070 self->addActor.send(self->badTeamRemover); in storageServerTracker()
3285 self->addActor.send( self->getTeam( self, req ) ); in serverGetTeamRequests()
3331 self->addActor.send(self->badTeamRemover); in dataDistributionTeamCollection()
3336 self->addActor.send(self->redundantTeamRemover); in dataDistributionTeamCollection()
3345 self->addActor.send(storageRecruiter( self, db )); in dataDistributionTeamCollection()
3348 self->addActor.send(trackExcludedServers( self )); in dataDistributionTeamCollection()
3349 self->addActor.send(monitorHealthyTeams( self )); in dataDistributionTeamCollection()
3350 self->addActor.send(waitHealthyZoneChange( self )); in dataDistributionTeamCollection()
[all …]
H A DOldTLogServer_6_0.actor.cpp406 PromiseStream<Future<Void>> addActor; member
1453 logData->addActor.send( tLogPeekMessages( self, req, logData ) ); in serveTLogInterface()
1456 logData->addActor.send( tLogPop( self, req, logData ) ); in serveTLogInterface()
1463 logData->addActor.send( tLogCommit( self, req, logData, warningCollectorInput ) ); in serveTLogInterface()
1468 logData->addActor.send( tLogLock(self, reply, logData) ); in serveTLogInterface()
1494 …logData->addActor = PromiseStream<Future<Void>>(); //there could be items still in the promise str… in removeLog()
1643 state Future<Void> error = actorCollection( logData->addActor.getFuture() ); in tLogCore()
1645 logData->addActor.send( waitFailureServer( tli.waitFailure.getFuture()) ); in tLogCore()
1646 logData->addActor.send( logData->removed ); in tLogCore()
1649 logData->addActor.send( serveTLogInterface(self, tli, logData, warningCollectorInput) ); in tLogCore()
[all …]
H A DTLogServer.actor.cpp463 PromiseStream<Future<Void>> addActor; member
1813 logData->addActor.send( tLogPeekMessages( self, req, logData ) ); in serveTLogInterface()
1816 logData->addActor.send( tLogPop( self, req, logData ) ); in serveTLogInterface()
1823 logData->addActor.send( tLogCommit( self, req, logData, warningCollectorInput ) ); in serveTLogInterface()
1828 logData->addActor.send( tLogLock(self, reply, logData) ); in serveTLogInterface()
1854 …logData->addActor = PromiseStream<Future<Void>>(); //there could be items still in the promise str… in removeLog()
2007 state Future<Void> error = actorCollection( logData->addActor.getFuture() ); in tLogCore()
2009 logData->addActor.send( waitFailureServer( tli.waitFailure.getFuture()) ); in tLogCore()
2010 logData->addActor.send( logData->removed ); in tLogCore()
2013 logData->addActor.send( serveTLogInterface(self, tli, logData, warningCollectorInput) ); in tLogCore()
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/workloads/
H A DPing.actor.cpp207 state PromiseStream<Future<Void>> addActor; in payloadSender() local
208 state Future<Void> collection = actorCollection( addActor.getFuture() ); in payloadSender()
223 addActor.send( self->payloadPinger( self, cx, endpoints ) ); in payloadSender()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbclient/
H A DBackupAgentBase.actor.cpp564 …tional<Version> endVersion, Key rangeBegin, PromiseStream<Future<Void>> addActor, FlowLock* commit… in dumpData() argument
618 addActor.send( commitLock->releaseWhen( success(commit.getReply(req)), mutationSize ) ); in dumpData()
626 … commit, NotifiedVersion* committedVersion, PromiseStream<Future<Void>> addActor, FlowLock* commit… in coalesceKeyVersionCache() argument
658 addActor.send( commitLock->releaseWhen( success(commit.getReply(req)), mutationSize ) ); in coalesceKeyVersionCache()
666 state PromiseStream<Future<Void>> addActor; in applyMutations() local
667 state Future<Void> error = actorCollection( addActor.getFuture() ); in applyMutations()
698 …nges.size()-1 ? newEndVersion : Optional<Version>(), ranges[idx].begin, addActor, &commitLock, key… in applyMutations()
703 …wait(coalesceKeyVersionCache(uid, newEndVersion, keyVersion, commit, committedVersion, addActor, &… in applyMutations()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/flow/
H A DActorCollection.actor.cpp26 ACTOR Future<Void> actorCollection( FutureStream<Future<Void>> addActor, int* pCount, double *lastC… in actorCollection() argument
36 when (Future<Void> f = waitNext(addActor)) { in actorCollection()
H A DActorCollection.h34 Future<Void> actorCollection( FutureStream<Future<Void>> const& addActor, int* const& optionalCount…
/dports/graphics/pcl-pointclouds/pcl-pcl-1.12.0/outofcore/include/pcl/outofcore/visualization/
H A Dobject.h45 addActor (vtkActor *actor);
H A Daxes.h61 addActor (axes_actor_); in Object()
/dports/games/manaplus/manaplus-2.1.3.17/src/being/
H A Dactor.cpp58 mMapActor = mMap->addActor(this); in setMap()
/dports/graphics/pcl-pointclouds/pcl-pcl-1.12.0/outofcore/src/visualization/
H A Dgrid.cpp49 addActor (grid_actor_); in Grid()
H A Doutofcore_cloud.cpp128 addActor (voxel_actor_); in OutofcoreCloud()
265 addActor (cloud_actors_map_[pcd_file]); in render()
H A Dobject.cpp64 Object::addActor (vtkActor *actor) in addActor() function in Object
/dports/games/libretro-scummvm/scummvm-7b1e929/engines/bladerunner/
H A Dscene_objects.h75 …bool addActor(int sceneObjectId, const BoundingBox &boundingBox, const Common::Rect &screenRectang…
/dports/games/scummvm/scummvm-2.5.1/engines/bladerunner/
H A Dscene_objects.h75 …bool addActor(int sceneObjectId, const BoundingBox &boundingBox, const Common::Rect &screenRectang…
/dports/games/openmw/openmw-openmw-0.47.0/apps/openmw/mwclass/
H A Dactor.cpp33 physics.addActor(ptr, model); in insertObject()
/dports/www/firefox-legacy/firefox-52.8.0esr/devtools/server/
H A Dcontent-server.jsm45 actorPool.addActor(actor);

123