Searched refs:NUM_WORKERS (Results 1 – 3 of 3) sorted by relevance
| /external/tensorflow/tensorflow/python/distribute/ |
| D | distribute_coordinator_test.py | 61 NUM_WORKERS = 3 variable
169 NUM_WORKERS, num_ps=NUM_PS)
183 self._barrier = distribute_coordinator._Barrier(NUM_WORKERS)
428 self.assertEqual(self._result_correct, NUM_WORKERS)
439 self.assertEqual(self._result_correct, NUM_WORKERS)
451 self.assertEqual(len(self._worker_context[WORKER]), NUM_WORKERS)
457 (_bytes_to_str(self._workers[0].target), NUM_WORKERS, True, True))
460 (_bytes_to_str(self._workers[1].target), NUM_WORKERS, False, True))
463 (_bytes_to_str(self._workers[2].target), NUM_WORKERS, False, True))
475 self.assertEqual(len(self._strategy_property[WORKER]), NUM_WORKERS)
[all …]
|
| /external/ltp/testcases/realtime/func/prio-preempt/ |
| D | prio-preempt.c | 72 #define NUM_WORKERS 27 macro
82 static pthread_mutex_t mutex[NUM_WORKERS + 1];
83 static pthread_cond_t cond[NUM_WORKERS + 1];
84 static int t_after_wait[NUM_WORKERS];
189 if (tid == NUM_WORKERS - 1) { in worker_thread()
262 for (i = 0, pri_boost = 10; i < NUM_WORKERS; i++, pri_boost += 2) { in master_thread()
272 while (threads_running < NUM_WORKERS) in master_thread()
318 printf("Worker Threads: %d\n\n", NUM_WORKERS); in main()
|
| /external/tensorflow/tensorflow/contrib/distribute/python/ |
| D | cross_device_ops_test.py | 433 NUM_WORKERS = 3 variable
445 num_workers=NUM_WORKERS, num_ps=0)
506 NUM_WORKERS, num_gpus, collective_keys=collective_keys)
|