/frameworks/support/work/workmanager/src/main/java/androidx/work/impl/workers/ |
CombineContinuationsWorker.java | 17 package androidx.work.impl.workers;
|
ConstraintTrackingWorker.java | 17 package androidx.work.impl.workers; 52 "androidx.work.impl.workers.ConstraintTrackingWorker.ARGUMENT_CLASS_NAME";
|
/frameworks/support/work/workmanager-test/src/androidTest/java/androidx/work/test/workers/ |
TestWorker.java | 17 package androidx.work.test.workers;
|
/external/jemalloc/msvc/projects/vc2015/test_threads/ |
test_threads.cpp | 31 vector<thread> workers; local 41 workers.emplace_back([tid=i]() { 76 for (thread& t : workers) {
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
grpc_channel_test.cc | 92 std::vector<string> workers; local 93 cc->ListWorkers(&workers); 98 workers); 138 std::vector<string> workers; local 139 cc->ListWorkers(&workers); 140 std::sort(workers.begin(), workers.end()); 144 workers);
|
/external/ltp/testcases/kernel/fs/fs_fill/ |
fs_fill.c | 37 static struct worker *workers; variable in typeref:struct:worker 83 SAFE_PTHREAD_CREATE(&threads[i], NULL, worker, &workers[i]); 107 workers = SAFE_MALLOC(sizeof(struct worker) * nthreads); 110 snprintf(workers[i].dir, sizeof(workers[i].dir), 112 SAFE_MKDIR(workers[i].dir, 0700); 120 free(workers);
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
cluster_function_library_runtime.cc | 128 std::vector<string> workers; local 129 worker_session_->worker_cache->ListWorkers(&workers); 132 " Available workers: ", str_util::Join(workers, ", "));
|
rpcbench_test.cc | 45 std::vector<string>* workers, 49 workers->clear(); 53 workers->push_back(strings::StrCat("grpc://localhost:", port[i])); 94 LOG(ERROR) << "W '" << (*workers)[0] << "'"; 96 options_copy.target = (*workers)[0]; 104 std::vector<string> workers; member in struct:tensorflow::Cluster 111 MakeGRPCCluster(options, kWorkers, &workers, &devices); 112 LOG(ERROR) << "C " << workers.size() << " " << devices.size() << " " 113 << workers[0] << " " << workers[1] local [all...] |
master.cc | 30 // RunGraph on the workers. 146 WorkerCacheInterface* worker_cache, std::vector<string>* workers) { 148 *workers = finder.targets_; 168 // Enumerates all known workers' target. A target name is a 170 std::vector<string> workers; local 171 worker_cache->ListWorkers(&workers); 173 std::swap(workers, targets_); 175 for (const string& name : workers) { 196 // Talk to all workers to get the list of available devices. 208 // to hear from workers, log a list of the workers who have no [all...] |
/external/compiler-rt/lib/asan/tests/ |
asan_mac_test.cc | 176 pthread_t workers[kNumWorkers], forker; local 178 PTHREAD_CREATE(&workers[i], 0, MallocIntrospectionLockWorker, 0); 182 PTHREAD_JOIN(workers[i], 0);
|
/external/libvpx/libvpx/test/ |
vp9_thread_test.cc | 102 VPxWorker workers[kNumWorkers]; local 107 vpx_get_worker_interface()->init(&workers[n]); 109 workers[n].hook = ThreadHook; 110 workers[n].data1 = &hook_data[n]; 111 workers[n].data2 = &return_value[n]; 116 EXPECT_NE(vpx_get_worker_interface()->reset(&workers[n]), 0); 121 Run(&workers[n]); 125 vpx_get_worker_interface()->end(&workers[n]); 197 // Note any worker that requires synchronization between other workers will
|
/external/tensorflow/tensorflow/core/kernels/ |
ctc_loss_op.cc | 160 DeviceBase::CpuWorkerThreads workers = variable 166 &gradient_list_t, &workers));
|
meta_support.cc | 155 auto& workers = *(tf_context->device()->tensorflow_cpu_worker_threads()); local 156 TensorflowGemmContext context(workers.num_threads, workers.workers); 168 auto& workers = *(tf_context->device()->tensorflow_cpu_worker_threads()); local 169 TensorflowGemmContext context(workers.num_threads, workers.workers);
|
/external/desugar/test/java/com/google/devtools/build/android/desugar/runtime/ |
ConcurrentWeakIdentityHashMapTest.java | 129 List<Worker> workers = local 134 // Assign tasks to workers. 135 Iterator<Worker> workIterator = workers.iterator(); 138 workIterator = workers.iterator(); 144 // Execute all the workers. 145 ExecutorService executorService = Executors.newFixedThreadPool(workers.size()); 146 workers.forEach(executorService::execute);
|
/external/fio/ |
workqueue.h | 55 struct submit_worker *workers; member in struct:workqueue
|
/external/icu/android_icu4j/src/main/tests/android/icu/dev/test/util/ |
VersionInfoTest.java | 373 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; local 376 // Create workers 377 for (int i = 0; i < workers.length; i++) { 378 workers[i] = new GetInstanceWorker(i, results[i]); 381 // Start workers 382 for (int i = 0; i < workers.length; i++) { 383 workers[i].start(); 387 for (int i = 0; i < workers.length; i++) { 389 workers[i].join();
|
/external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/util/ |
VersionInfoTest.java | 370 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; local 373 // Create workers 374 for (int i = 0; i < workers.length; i++) { 375 workers[i] = new GetInstanceWorker(i, results[i]); 378 // Start workers 379 for (int i = 0; i < workers.length; i++) { 380 workers[i].start(); 384 for (int i = 0; i < workers.length; i++) { 386 workers[i].join();
|
/external/ltp/testcases/kernel/io/direct_io/ |
dma_thread_diotest.c | 134 static int workers; variable 231 workers = sysconf(_SC_NPROCESSORS_ONLN); 232 if (workers > MAX_WORKERS) 233 workers = MAX_WORKERS; 260 for (j = 0; j < workers; j++) { 270 for (j = 0; j < workers; j++) { 277 worker[workers - 1].length = 278 READSIZE - PAGE_SIZE * (workers - 1); 288 for (j = 0; j < workers; j++) { 298 for (j = 0; j < workers; j++) [all...] |
/external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_timedwait/ |
stress2.c | 191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member in struct:celldata 337 /* create the workers */ 340 pthread_create(&(cd->workers[i]), &ta, worker, arg); 356 /* wait for the workers to be ready */ 387 ret = pthread_cancel(cd->workers[randval]); 404 ret = pthread_join(cd->workers[i], &w_ret);
|
/external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_wait/ |
stress.c | 191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member in struct:celldata 337 /* create the workers */ 340 pthread_create(&(cd->workers[i]), &ta, worker, arg); 356 /* wait for the workers to be ready */ 387 ret = pthread_cancel(cd->workers[randval]); 404 ret = pthread_join(cd->workers[i], &w_ret);
|
stress2.c | 191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member in struct:celldata 337 /* create the workers */ 340 pthread_create(&(cd->workers[i]), &ta, worker, arg); 356 /* wait for the workers to be ready */ 387 ret = pthread_cancel(cd->workers[randval]); 404 ret = pthread_join(cd->workers[i], &w_ret);
|
/external/tensorflow/tensorflow/contrib/verbs/ |
rdma_mgr.cc | 41 std::vector<string> workers; local 43 &workers); 44 num_remote_workers_ = workers.size() - 1; 46 for (size_t i = 0; i < workers.size(); i++) { 47 if (local_worker_.compare(workers[i]) != 0) { 49 {workers[i], 50 new RdmaChannel(rdma_adapter_, local_worker_, workers[i])});
|
/external/tensorflow/tensorflow/core/framework/ |
device_base.h | 111 thread::ThreadPool* workers = nullptr; member in struct:tensorflow::DeviceBase::CpuWorkerThreads
|
/frameworks/base/tests/JankBench/app/src/main/jni/ |
Bench.cpp | 88 int workers = mWorkers.getWorkerCount(); local 90 mIpKernel = new float *[workers]; 91 mSrcBuf = new float *[workers]; 92 mOutBuf = new float *[workers]; 94 for (int i = 0; i < workers; i++) {
|
/frameworks/support/work/workmanager/src/androidTest/java/androidx/work/impl/workers/ |
ConstraintTrackingWorkerTest.java | 17 package androidx.work.impl.workers;
|