HomeSort by relevance Sort by last modified time
    Searched defs:workers (Results 1 - 25 of 76) sorted by null

1 2 3 4

  /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;

Completed in 1564 milliseconds

1 2 3 4