| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/workloads/ |
| H A D | TargetedKill.actor.cpp | 64 state vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in killEndpoint()
97 if(machine != self->dbInfo->get().clusterInterface.getWorkers.getEndpoint().getPrimaryAddress()) in assassin()
108 if(machine != self->dbInfo->get().clusterInterface.getWorkers.getEndpoint().getPrimaryAddress()) in assassin()
118 if(machine != self->dbInfo->get().clusterInterface.getWorkers.getEndpoint().getPrimaryAddress()) in assassin()
124 machine = self->dbInfo->get().clusterInterface.getWorkers.getEndpoint().getPrimaryAddress(); in assassin()
|
| H A D | WorkerErrors.actor.cpp | 62 state vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in _start()
|
| H A D | LogMetrics.actor.cpp | 57 vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in setSystemRate()
|
| H A D | Ping.actor.cpp | 183 vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in workerPinger()
211 vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in payloadSender()
|
| H A D | CpuProfiler.actor.cpp | 72 vector<WorkerDetails> _workers = wait( getWorkers( self->dbInfo ) ); in updateProfiler()
|
| H A D | ConsistencyCheck.actor.cpp | 1080 state vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in checkForStorage()
1116 state vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in checkForExtraDataStores()
1165 vector<WorkerDetails> workers = wait( getWorkers( self->dbInfo ) ); in checkWorkerList()
1220 vector<ProcessData> workers = wait(::getWorkers(&tr)); in checkCoordinators()
1251 state vector<WorkerDetails> allWorkers = wait(getWorkers(self->dbInfo)); in checkUsingDesiredClasses()
1252 …state vector<WorkerDetails> nonExcludedWorkers = wait(getWorkers(self->dbInfo, GetWorkersRequest::… in checkUsingDesiredClasses()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/ |
| H A D | QuietDatabase.actor.cpp | 33 ACTOR Future<vector<WorkerDetails>> getWorkers( Reference<AsyncVar<ServerDBInfo>> dbInfo, int flags… in getWorkers() function
36 …etails> w = wait( brokenPromiseToNever( dbInfo->get().clusterInterface.getWorkers.getReply( GetWor… in getWorkers()
49 state vector<WorkerDetails> workers = wait( getWorkers( dbInfo ) ); in getMasterWorker()
72 state vector<WorkerDetails> workers = wait( getWorkers( dbInfo ) ); in getDataDistributorWorker()
131 state std::vector<WorkerDetails> workers = wait(getWorkers(dbInfo)); in getMaxTLogQueueSize()
192 state Future<std::vector<WorkerDetails>> workersFuture = getWorkers(dbInfo); in getMaxStorageServerQueueSize()
|
| H A D | ClusterRecruitmentInterface.h | 43 RequestStream< struct GetWorkersRequest > getWorkers; member
57 getWorkers.getEndpoint( TaskClusterController ); in initEndpoints()
65 …ation, recruitRemoteFromConfiguration, recruitStorage, registerWorker, getWorkers, registerMaster,… in serialize()
|
| H A D | QuietDatabase.h | 38 Future<vector<WorkerDetails>> getWorkers( Reference<AsyncVar<ServerDBInfo>> const& dbInfo, int cons…
|
| /dports/net/concourse-fly/concourse-6.7.1/atc/db/ |
| H A D | worker_factory.go | 73 workers, err := getWorkers(f.conn, workersQuery)
82 return getWorkers(f.conn, workersQuery)
103 func getWorkers(conn Conn, query sq.SelectBuilder) ([]Worker, error) { func
327 …workers, err := getWorkers(f.conn, workersQuery.Join("containers c ON c.worker_name = w.name").Whe…
|
| /dports/misc/concourse/concourse-6.7.2/atc/db/ |
| H A D | worker_factory.go | 73 workers, err := getWorkers(f.conn, workersQuery)
82 return getWorkers(f.conn, workersQuery)
103 func getWorkers(conn Conn, query sq.SelectBuilder) ([]Worker, error) { func
327 …workers, err := getWorkers(f.conn, workersQuery.Join("containers c ON c.worker_name = w.name").Whe…
|
| /dports/www/owncloud/owncloud/apps/files_external/3rdparty/google/apiclient-services/src/Google/Service/Dataflow/ |
| H A D | StageExecutionDetails.php | 43 public function getWorkers() function in Google_Service_Dataflow_StageExecutionDetails
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/jest-worker/build/base/ |
| H A D | BaseWorkerPool.d.ts | 17 getWorkers(): Array<WorkerInterface>;
|
| /dports/graphics/lightzone/LightZone-4.1.8-3-g36e87773/lightcrafts/src/com/lightcrafts/jai/utils/ |
| H A D | LCTileScheduler.java | 439 synchronized(threads = scheduler.getWorkers(isPrefetch)) { in run()
904 synchronized(getWorkers(isPrefetch)) { in scheduleJob() method
1356 LinkedList<Thread> thr = getWorkers(isPrefetch); in createThreadGroup()
1381 LinkedList<Thread> thr = getWorkers(isPrefetch); in getNumThreads()
1440 LinkedList<Thread> getWorkers(boolean isPrefetch) { in getWorkers() method in LCTileScheduler
1490 synchronized(getWorkers(isPrefetch)) { in terminateAll() method
|
| /dports/graphics/lightzone/LightZone-4.1.8-3-g36e87773/lightcrafts/extsrc/com/lightcrafts/media/jai/util/ |
| H A D | SunTileScheduler.java | 451 synchronized(threads = scheduler.getWorkers(isPrefetch)) { in run()
1019 synchronized(getWorkers(isPrefetch)) { in scheduleJob() method
1492 Vector thr = getWorkers(isPrefetch); in createThreadGroup()
1519 Vector thr = getWorkers(isPrefetch); in getNumThreads()
1580 Vector getWorkers(boolean isPrefetch) { in getWorkers() method in SunTileScheduler
1632 synchronized(getWorkers(isPrefetch)) { in terminateAll() method
|
| /dports/biology/ugene/ugene-40.1/src/corelibs/U2Designer/src/dashboard/ |
| H A D | ParametersDashboardWidget.h | 63 const QList<WorkerParametersInfo> &getWorkers() const { in getWorkers() function
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbclient/ |
| H A D | ManagementAPI.actor.h | 160 ACTOR Future<vector<ProcessData>> getWorkers( Database cx );
161 ACTOR Future<vector<ProcessData>> getWorkers( Transaction* tr );
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/jest-worker/build/ |
| H A D | types.d.ts | 21 getWorkers(): Array<WorkerInterface>; method
|
| /dports/devel/hadoop/hadoop-1.2.1/contrib/hod/hodlib/Hod/ |
| H A D | nodePool.py | 84 def getWorkers(self): member in NodePool
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/hod/hodlib/Hod/ |
| H A D | nodePool.py | 84 def getWorkers(self): member in NodePool
|
| /dports/devel/py-buildbot/buildbot-3.4.1/buildbot/db/ |
| H A D | workers.py | 122 workers = yield self.getWorkers(_workerid=workerid,
129 def getWorkers(self, _workerid=None, _name=None, masterid=None, member in WorkersConnectorComponent
|
| /dports/devel/hadoop/hadoop-1.2.1/contrib/hod/hodlib/GridServices/ |
| H A D | service.py | 48 def getWorkers(self): member in Service
|
| H A D | mapred.py | 137 def getWorkers(self): member in MapReduce
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/hod/hodlib/GridServices/ |
| H A D | service.py | 48 def getWorkers(self): member in Service
|
| /dports/devel/py-buildbot/buildbot-3.4.1/buildbot/data/ |
| H A D | workers.py | 98 workers_dicts = yield self.master.db.workers.getWorkers(
|