Home
last modified time | relevance | path

Searched defs:workers (Results 1 – 25 of 87) sorted by relevance

1234

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_channel_test.cc93 std::vector<string> workers; in TEST() local
104 std::vector<string> workers; in TEST() local
115 std::vector<string> workers; in TEST() local
159 std::vector<string> workers; in TEST() local
169 std::vector<string> workers; in TEST() local
178 std::vector<string> workers; in TEST() local
Dgrpc_channel.cc238 void ListWorkers(std::vector<string>* workers) override { in ListWorkers()
245 std::vector<string>* workers) override { in ListWorkersInJob()
305 void ListWorkers(std::vector<string>* workers) override { in ListWorkers()
313 std::vector<string>* workers) override { in ListWorkersInJob()
/external/kotlinx.atomicfu/atomicfu/src/nativeTest/kotlin/kotlinx/atomicfu/locks/
DSynchronizedTest.kt16 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
43 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
70 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
95 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
/external/tensorflow/tensorflow/core/distributed_runtime/
Dworker_cache_wrapper.h32 void ListWorkers(std::vector<string>* workers) const override { in ListWorkers()
36 std::vector<string>* workers) const override { in ListWorkersInJob()
Drpcbench_test.cc45 std::vector<string>* workers, in MakeGRPCCluster()
104 std::vector<string> workers; member
/external/tensorflow/tensorflow/python/keras/engine/
Dtraining_generator_v1.py53 workers=1, argument
368 def _validate_arguments(is_sequence, is_dataset, use_multiprocessing, workers, argument
491 workers=1, argument
572 workers=1, argument
605 workers=1, argument
627 workers=1, argument
/external/libchrome/ipc/
Dipc_sync_channel_unittest.cc265 void RunTest(std::vector<Worker*> workers) { in RunTest()
328 std::vector<Worker*> workers; in Simple() local
407 std::vector<Worker*> workers; in TwoStep() local
442 std::vector<Worker*> workers; in DelayReply() local
506 std::vector<Worker*> workers; in NoHang() local
578 std::vector<Worker*> workers; in Unblock() local
673 std::vector<Worker*> workers; in Recursive() local
698 std::vector<Worker*> workers; in RecursiveNoHang() local
792 std::vector<Worker*> workers; in Multiple() local
902 std::vector<Worker*> workers; in QueuedReply() local
[all …]
/external/webrtc/third_party/abseil-cpp/absl/synchronization/
Dblocking_counter_test.cc42 std::vector<std::thread> workers; in TEST() local
/external/libtextclassifier/abseil-cpp/absl/synchronization/
Dblocking_counter_test.cc42 std::vector<std::thread> workers; in TEST() local
/external/abseil-cpp/absl/synchronization/
Dblocking_counter_test.cc42 std::vector<std::thread> workers; in TEST() local
/external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/
Dblocking_counter_test.cc42 std::vector<std::thread> workers; in TEST() local
/external/openscreen/third_party/abseil/src/absl/synchronization/
Dblocking_counter_test.cc42 std::vector<std::thread> workers; in TEST() local
/external/tensorflow/tensorflow/python/keras/utils/
Ddata_utils.py620 def start(self, workers=1, max_queue_size=10): argument
671 def _get_executor_init(self, workers): argument
710 def _get_executor_init(self, workers): argument
852 def _get_executor_init(self, workers): argument
/external/rust/crates/ryu/tests/
Dexhaustive.rs14 let mut workers = Vec::new(); in test_exhaustive() localVariable
/external/libabigail/src/
Dabg-workers.cc34 namespace workers namespace
137 std::vector<worker> workers; member
/external/tensorflow/tensorflow/python/training/
Dsync_replicas_optimizer_test.py35 def get_workers(num_workers, replicas_to_aggregate, workers): argument
/external/grpc-grpc/tools/run_tests/
Drun_performance_tests.py110 workers, argument
140 def create_quit_jobspec(workers, remote_host=None): argument
/external/angle/third_party/abseil-cpp/absl/synchronization/
Dblocking_counter_test.cc42 std::vector<std::thread> workers; in TEST() local
/external/webrtc/tools_webrtc/
Dgtest-parallel-wrapper.py91 def _ParseWorkersOption(workers): argument
/external/rust/crates/grpcio-sys/grpc/tools/run_tests/
Drun_performance_tests.py116 workers, argument
143 def create_quit_jobspec(workers, remote_host=None): argument
/external/tensorflow/tensorflow/core/data/service/
Ddata_service_test.cc72 std::vector<WorkerInfo> workers; in TEST() local
/external/ltp/testcases/kernel/fs/fs_fill/
Dfs_fill.c25 static struct worker *workers; variable
/external/llvm-project/llvm/utils/lit/lit/
Drun.py19 def __init__(self, tests, lit_config, workers, progress_callback, argument
Ddisplay.py4 def create_display(opts, tests, total_tests, workers): argument
/external/tensorflow/tensorflow/core/util/
Dwork_sharder.cc32 void Shard(int max_parallelism, thread::ThreadPool* workers, int64 total, in Shard()

1234