| /aosp_15_r20/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| H A 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 …]
|
| H A 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()
|
| /aosp_15_r20/external/kotlinx.atomicfu/atomicfu/src/nativeTest/kotlin/kotlinx/atomicfu/locks/ |
| H A 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
|
| /aosp_15_r20/external/libchrome/ipc/ |
| H A 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 …]
|
| /aosp_15_r20/external/cronet/ipc/ |
| H A D | ipc_sync_channel_unittest.cc | 267 void RunTest(std::vector<Worker*> workers) { in RunTest()
326 std::vector<Worker*> workers; in Simple() local
403 std::vector<Worker*> workers; in TwoStep() local
438 std::vector<Worker*> workers; in DelayReply() local
497 std::vector<Worker*> workers; in NoHang() local
559 std::vector<Worker*> workers; in Unblock() local
641 std::vector<Worker*> workers; in Recursive() local
656 std::vector<Worker*> workers; in RecursiveNoHang() local
738 std::vector<Worker*> workers; in Multiple() local
835 std::vector<Worker*> workers; in QueuedReply() local
[all …]
|
| /aosp_15_r20/external/libaom/av1/common/ |
| H A 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()
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/keras/engine/ |
| H A 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
|
| H A D | training.py | 898 workers=1, argument
1358 workers=1, argument
1608 workers=1, argument
1951 workers=1, argument
1985 workers=1, argument
2013 workers=1, argument
|
| H A D | training_v1.py | 632 workers=1, argument
823 workers=1, argument
926 workers=1, argument
1232 workers=1, argument
1266 workers=1, argument
1294 workers=1, argument
|
| H A D | data_adapter.py | 787 workers=1, argument
867 def _handle_multiprocessing(self, x, workers, use_multiprocessing, argument
914 workers=1, argument
943 def _handle_multiprocessing(self, x, workers, use_multiprocessing, argument
1105 workers=1, argument
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/keras/utils/ |
| H A 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
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/distributed_runtime/ |
| H A 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()
|
| H A D | rpcbench_test.cc | 45 std::vector<string>* workers, in MakeGRPCCluster()
104 std::vector<string> workers; member
|
| H A D | master.cc | 150 WorkerCacheInterface* worker_cache, std::vector<string>* workers) { in GetRemoteWorkers()
177 std::vector<string> workers; in DeviceFinder() local
197 std::vector<string> workers; in DeviceFinder() local
|
| H A D | test_utils.h | 135 void ListWorkers(std::vector<string>* workers) const override { in ListWorkers()
143 std::vector<string>* workers) const override { in ListWorkersInJob()
|
| /aosp_15_r20/tools/netsim/rust/daemon/src/http_server/ |
| H A D | thread_pool.rs | 23 workers: Vec<Worker>, field
44 let mut workers = Vec::with_capacity(size); in new() localVariable
|
| /aosp_15_r20/frameworks/native/libs/binder/tests/ |
| H A D | binderThroughputTest.cpp | 229 vector<sp<IBinder> > workers; in worker_fx() local
309 void run_main(int iterations, int workers, int payload_size, int cs_pair, in run_main()
370 int workers = 2; in main() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 259 let workers = std::mem::take(&mut shared.worker_threads); in shutdown() localVariable
269 let workers: Vec<(usize, thread::JoinHandle<()>)> = { in shutdown() localVariable
270 let mut workers: Vec<_> = workers.into_iter().collect(); in shutdown() localVariable
|
| /aosp_15_r20/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
|
| /aosp_15_r20/external/grpc-grpc/tools/run_tests/ |
| H A D | run_performance_tests.py | 113 workers, argument
150 def create_quit_jobspec(workers, remote_host=None): argument
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/end2end/ |
| H A 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
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| H A D | MultithreadedDispatchers.kt | 144 val workers = workerPool.close() // no new workers will be created in close() constant
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio-util/src/task/ |
| D | spawn_pinned.rs | 66 let workers = (0..pool_size) in new() localVariable
197 workers: Box<[LocalWorkerHandle]>, field
|
| /aosp_15_r20/external/libvpx/vp9/common/ |
| H A D | vp9_thread_common.c | 161 VPxWorker *workers, int nworkers, in loop_filter_rows_mt()
223 int partial_frame, VPxWorker *workers, in vp9_loop_filter_frame_mt()
|
| /aosp_15_r20/system/libhwbinder/vts/performance/ |
| H A D | Benchmark_throughput.cpp | 208 vector<sp<IBenchmark>> workers; in worker_fx() local
310 int workers = 2; in main() local
|