| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_channel_test.cc | 94 std::vector<string> workers; in TEST() local
105 std::vector<string> workers; in TEST() local
116 std::vector<string> workers; in TEST() local
178 std::vector<string> workers; in TEST() local
187 std::vector<string> workers; in TEST() local
196 std::vector<string> workers; in TEST() local
260 std::vector<string> workers; in TEST() local
271 std::vector<string> workers, workers2; in TEST() local
285 std::vector<string> workers; in TEST() local
330 std::vector<string> workers; in TEST() local
[all …]
|
| D | grpc_channel.cc | 207 void ListWorkers(std::vector<string>* workers) override { in ListWorkers()
214 std::vector<string>* workers) override { in ListWorkersInJob()
276 void ListWorkers(std::vector<string>* workers) override { in ListWorkers()
284 std::vector<string>* workers) override { in ListWorkersInJob()
|
| /external/kotlinx.atomicfu/atomicfu/src/nativeTest/kotlin/kotlinx/atomicfu/locks/ |
| D | SynchronizedTest.kt | 17 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
44 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
71 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
96 val workers = Array(nWorkers) { Worker.start() } in <lambda>() constant
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_cache_wrapper.h | 32 void ListWorkers(std::vector<string>* workers) const override { in ListWorkers()
36 std::vector<string>* workers) const override { in ListWorkersInJob()
|
| D | rpcbench_test.cc | 45 std::vector<string>* workers, in MakeGRPCCluster()
104 std::vector<string> workers; member
|
| /external/tensorflow/tensorflow/python/keras/engine/ |
| D | training_generator_v1.py | 50 workers=1, argument
365 def _validate_arguments(is_sequence, is_dataset, use_multiprocessing, workers, argument
488 workers=1, argument
569 workers=1, argument
602 workers=1, argument
624 workers=1, argument
|
| /external/libchrome/ipc/ |
| D | ipc_sync_channel_unittest.cc | 265 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/libaom/av1/common/ |
| D | thread_common.c | 369 static inline void sync_lf_workers(AVxWorker *const workers, in sync_lf_workers()
434 AVxWorker *workers, int num_workers, in loop_filter_rows_mt()
493 int partial_frame, AVxWorker *workers, in av1_loop_filter_frame_mt()
897 static inline void sync_lr_workers(AVxWorker *const workers, in sync_lr_workers()
921 AVxWorker *workers, int num_workers, in foreach_rest_unit_in_planes_mt()
982 AVxWorker *workers, int num_workers, in av1_loop_restoration_filter_frame_mt()
1007 static inline void launch_cdef_workers(AVxWorker *const workers, in launch_cdef_workers()
1020 static inline void sync_cdef_workers(AVxWorker *const workers, in sync_cdef_workers()
1137 AVxWorkerHook hook, AVxWorker *const workers, AV1CdefSync *const cdef_sync, in prepare_cdef_frame_workers()
1233 AVxWorker *const workers, AV1CdefSync *const cdef_sync, in av1_cdef_frame_mt()
|
| /external/cronet/tot/ipc/ |
| D | ipc_sync_channel_unittest.cc | 265 void RunTest(std::vector<Worker*> workers) { in RunTest()
324 std::vector<Worker*> workers; in Simple() local
401 std::vector<Worker*> workers; in TwoStep() local
436 std::vector<Worker*> workers; in DelayReply() local
495 std::vector<Worker*> workers; in NoHang() local
557 std::vector<Worker*> workers; in Unblock() local
639 std::vector<Worker*> workers; in Recursive() local
654 std::vector<Worker*> workers; in RecursiveNoHang() local
734 std::vector<Worker*> workers; in Multiple() local
831 std::vector<Worker*> workers; in QueuedReply() local
[all …]
|
| /external/cronet/stable/ipc/ |
| D | ipc_sync_channel_unittest.cc | 265 void RunTest(std::vector<Worker*> workers) { in RunTest()
324 std::vector<Worker*> workers; in Simple() local
401 std::vector<Worker*> workers; in TwoStep() local
436 std::vector<Worker*> workers; in DelayReply() local
495 std::vector<Worker*> workers; in NoHang() local
557 std::vector<Worker*> workers; in Unblock() local
639 std::vector<Worker*> workers; in Recursive() local
654 std::vector<Worker*> workers; in RecursiveNoHang() local
734 std::vector<Worker*> workers; in Multiple() local
831 std::vector<Worker*> workers; in QueuedReply() local
[all …]
|
| /external/snakeyaml/src/test/java/org/yaml/snakeyaml/env/ |
| D | ApplicationProperties.java | 30 private Integer workers; field in ApplicationProperties
|
| /external/aws-sdk-java-v2/services/sqs/src/it/java/software/amazon/awssdk/services/sqs/ |
| D | SqsConcurrentPerformanceIntegrationTest.java | 56 List<WorkerThread> workers = new ArrayList<WorkerThread>(); in testIdleConnectionReaping() local
|
| /external/tensorflow/tensorflow/python/keras/utils/ |
| D | data_utils.py | 605 def start(self, workers=1, max_queue_size=10): argument
656 def _get_executor_init(self, workers): argument
693 def _get_executor_init(self, workers): argument
832 def _get_executor_init(self, workers): argument
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | blocking_counter_test.cc | 42 std::vector<std::thread> workers; in TEST() local
|
| /external/cronet/tot/third_party/rust/chromium_crates_io/vendor/ryu-1.0.18/tests/ |
| D | exhaustive.rs | 14 let mut workers = Vec::new(); in test_exhaustive() localVariable
|
| /external/rust/android-crates-io/crates/ryu/tests/ |
| D | exhaustive.rs | 16 let mut workers = Vec::new(); in test_exhaustive() localVariable
|
| /external/cronet/stable/third_party/rust/chromium_crates_io/vendor/ryu-1.0.18/tests/ |
| D | exhaustive.rs | 14 let mut workers = Vec::new(); in test_exhaustive() localVariable
|
| /external/pytorch/torch/csrc/api/include/torch/data/ |
| D | dataloader_options.h | 58 size_t workers; member
|
| /external/tensorflow/tensorflow/python/training/ |
| D | sync_replicas_optimizer_test.py | 32 def get_workers(num_workers, replicas_to_aggregate, workers): argument
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/ |
| D | run_performance_tests.py | 117 workers, argument
144 def create_quit_jobspec(workers, remote_host=None): argument
|
| /external/grpc-grpc/tools/run_tests/ |
| D | run_performance_tests.py | 113 workers, argument
150 def create_quit_jobspec(workers, remote_host=None): argument
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | blocking_counter_test.cc | 42 std::vector<std::thread> workers; in TEST() local
|
| /external/abseil-cpp/absl/synchronization/ |
| D | blocking_counter_test.cc | 42 std::vector<std::thread> workers; in TEST() local
|
| /external/webrtc/tools_webrtc/ |
| D | gtest-parallel-wrapper.py | 93 def _ParseWorkersOption(workers): argument
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | resource_quota_end2end_stress_test.cc | 135 std::vector<std::thread> workers; in MakeGrpcCalls() local
200 std::vector<std::thread> workers; in TestExceedingConnectionQuota() local
|