| /external/rust/crates/rayon-core/src/sleep/ |
| D | mod.rs | 40 worker_index: usize, field
73 pub(super) fn start_looking(&self, worker_index: usize, latch: &CoreLatch) -> IdleState { in start_looking()
75 worker: worker_index, in start_looking()
82 worker_index, in start_looking()
91 worker: idle_state.worker_index, in work_found()
112 idle_state.jobs_counter = self.announce_sleepy(idle_state.worker_index); in no_work_found()
125 fn announce_sleepy(&self, worker_index: usize) -> JobsEventCounter { in announce_sleepy()
131 worker: worker_index, in announce_sleepy()
144 let worker_index = idle_state.worker_index; in sleep() localVariable
148 worker: worker_index, in sleep()
[all …]
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/ |
| D | data_service_test_base.py | 140 def restart_worker(self, worker_index=0, use_same_port=True): argument
142 worker = self.workers[worker_index]
147 self.workers[worker_index] = server_lib.WorkerServer(
156 def num_tasks_on_worker(self, worker_index=0): argument
157 return self.workers[worker_index]._num_tasks()
|
| D | data_service_ops_ft_test.py | 216 for worker_index in range(num_workers):
217 cluster.restart_worker(worker_index=worker_index)
222 for worker_index in range(num_workers):
223 cluster.restart_worker(worker_index=worker_index)
|
| D | rebatch_dataset_test.py | 87 for worker_index in range(4):
91 worker_index)
106 def get_batch_sizes_for_worker(worker_index): argument
110 worker_index))
|
| /external/tensorflow/tensorflow/python/distribute/coordinator/ |
| D | cluster_coordinator.py | 395 replica_args = _select_worker_slice(worker.worker_index, self._args)
396 replica_kwargs = _select_worker_slice(worker.worker_index, self._kwargs)
732 def __init__(self, worker_index, device_name, cluster): argument
733 self.worker_index = worker_index
743 name="WorkerClosureProcessingLoop-%d" % self.worker_index,
779 "processing closure: %r:%s", self.worker_index, e, e)
793 delay_secs = min(delay_secs * self.worker_index, delay_cap)
796 self.worker_index, delay_secs)
|
| /external/libwebsockets/lib/misc/threadpool/ |
| D | threadpool.c | 69 int worker_index; member
518 __func__, tp->name, pool->worker_index, buf); in lws_threadpool_worker()
607 __func__, tp->name, pool->worker_index, in lws_threadpool_worker()
620 __func__, tp->name, pool->worker_index, in lws_threadpool_worker()
683 tp->pool_list[n].worker_index = n; in lws_threadpool_create()
|
| /external/tensorflow/tensorflow/python/data/experimental/ops/ |
| D | distribute.py | 354 num_replicas_per_worker, worker_index): argument
440 offset = worker_index * num_replicas_per_worker
|
| /external/tensorflow/tensorflow/python/distribute/ |
| D | input_lib.py | 512 def compute_devices_for_worker(self, worker_index): argument
513 return self._fed_devices[worker_index]
666 def out_of_range_fn(worker_index, device): argument
670 data = self._iterators[worker_index].get_next(device)
1061 def rebatch_fn(dataset, worker_index): argument
1066 batch_size, num_workers, num_replicas_per_worker, worker_index)
|
| /external/rust/crates/rayon-core/src/ |
| D | registry.rs | 414 fn pop_injected_job(&self, worker_index: usize) -> Option<JobRef> { in pop_injected_job()
419 worker: worker_index, in pop_injected_job()
|