| /external/libtextclassifier/java/tests/instrumentation/src/com/android/textclassifier/downloader/ |
| D | ModelDownloadWorkerTest.java | 191 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed() local
209 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_modelAlreadyExists() local
226 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_manifestAlreadyExists() local
258 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_downloadMultipleModels() local
302 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_shareSingleModelDownloadForMultipleManifest() local
344 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_shareManifest() local
375 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadFailed_failedToDownloadManifest() local
391 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadFailed_failedToDownloadModel() local
402 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadFailed_modelDownloadManagerDisabled() local
412 ModelDownloadWorker worker = createWorker(WORKER_MAX_RUN_ATTEMPT_COUNT); in downloadFailed_reachWorkerMaxRunAttempts() local
[all …]
|
| /external/libvpx/libvpx/vpx_util/ |
| D | vpx_thread.c | 33 VPxWorker *const worker = (VPxWorker *)ptr; in thread_loop() local
54 static void change_state(VPxWorker *const worker, VPxWorkerStatus new_status) { in change_state()
79 static void init(VPxWorker *const worker) { in init()
84 static int sync(VPxWorker *const worker) { in sync()
92 static int reset(VPxWorker *const worker) { in reset()
130 static void execute(VPxWorker *const worker) { in execute()
136 static void launch(VPxWorker *const worker) { in launch()
144 static void end(VPxWorker *const worker) { in end()
|
| /external/libaom/libaom/aom_util/ |
| D | aom_thread.c | 42 AVxWorker *const worker = (AVxWorker *)ptr; in thread_loop() local
85 static void change_state(AVxWorker *const worker, AVxWorkerStatus new_status) { in change_state()
110 static void init(AVxWorker *const worker) { in init()
115 static int sync(AVxWorker *const worker) { in sync()
123 static int reset(AVxWorker *const worker) { in reset()
161 static void execute(AVxWorker *const worker) { in execute()
167 static void launch(AVxWorker *const worker) { in launch()
175 static void end(AVxWorker *const worker) { in end()
|
| /external/tensorflow/tensorflow/python/ops/ |
| D | batch_ops_test.py | 67 def worker(): function
110 def worker(): function
145 def worker(): function
202 def worker(): function
230 def worker(): function
258 def worker(): function
285 def worker(): function
369 def worker(): function
405 def worker(): function
510 def worker(): function
[all …]
|
| /external/libchrome/base/task_scheduler/ |
| D | scheduler_worker_unittest.cc | 62 void OnMainEntry(const SchedulerWorker* worker) override {} in OnMainEntry()
63 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) override { in GetWork()
150 void OnMainEntry(const SchedulerWorker* worker) override { in OnMainEntry()
162 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) override { in GetWork()
428 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) in GetWork()
466 void OnMainExit(SchedulerWorker* worker) override { in OnMainExit()
470 bool CanCleanup(SchedulerWorker* worker) { in CanCleanup()
520 auto worker = MakeRefCounted<SchedulerWorker>(ThreadPriority::NORMAL, in TEST() local
542 auto worker = MakeRefCounted<SchedulerWorker>(ThreadPriority::NORMAL, in TEST() local
565 auto worker = MakeRefCounted<SchedulerWorker>(ThreadPriority::NORMAL, in TEST() local
[all …]
|
| D | scheduler_worker_pool_impl.cc | 56 const SchedulerWorker* worker) { in ContainsWorker()
235 SchedulerWorker* worker = in Start() local
335 for (const auto& worker : workers_copy) in JoinForTesting() local
386 const SchedulerWorker* worker) { in OnMainEntry()
419 SchedulerWorker* worker) { in GetWork()
581 SchedulerWorker* worker) { in CleanupLockRequired()
605 OnWorkerBecomesIdleLockRequired(SchedulerWorker* worker) { in OnWorkerBecomesIdleLockRequired()
619 SchedulerWorker* worker) { in OnMainExit()
808 SchedulerWorker* worker = idle_workers_stack_.Pop(); in WakeUpOneWorkerLockRequired() local
847 SchedulerWorker* worker) { in AddToIdleWorkersStackLockRequired()
[all …]
|
| D | scheduler_worker_stack.cc | 20 void SchedulerWorkerStack::Push(SchedulerWorker* worker) { in Push()
30 SchedulerWorker* const worker = stack_.back(); in Pop() local
47 void SchedulerWorkerStack::Remove(const SchedulerWorker* worker) { in Remove()
|
| D | scheduler_single_thread_task_runner_manager.cc | 83 void set_worker(SchedulerWorker* worker) { in set_worker()
104 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) override { in GetWork()
188 void OnMainEntry(const SchedulerWorker* worker) override { in OnMainEntry()
194 scoped_refptr<Sequence> GetWork(SchedulerWorker* worker) override { in GetWork()
283 SchedulerWorker* worker, in SchedulerSingleThreadTaskRunner()
479 SchedulerWorker*& worker = in CreateTaskRunnerWithTraitsImpl() local
518 for (const auto& worker : local_workers) in JoinForTesting() local
574 scoped_refptr<SchedulerWorker> worker = MakeRefCounted<SchedulerWorker>( in CreateAndRegisterSchedulerWorker() local
600 SchedulerWorker* worker) { in UnregisterSchedulerWorker()
|
| /external/opencensus-java/exporters/stats/stackdriver/src/test/java/io/opencensus/exporter/stats/stackdriver/ |
| D | StackdriverExporterWorkerTest.java | 130 StackdriverExporterWorker worker = in export() local
177 StackdriverExporterWorker worker = in doNotExportForEmptyViewData() local
197 StackdriverExporterWorker worker = in doNotExportIfFailedToRegisterView() local
214 StackdriverExporterWorker worker = in skipDifferentViewWithSameName() local
241 StackdriverExporterWorker worker = in doNotCreateMetricDescriptorForRegisteredView() local
260 StackdriverExporterWorker worker = in doNotCreateMetricDescriptorForIntervalView() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/test/ |
| D | WorkerTest.kt | 15 val worker = Worker.start() in testLaunchInWorker() constant
27 val worker = Worker.start() in testLaunchInWorkerThroughGlobalScope() constant
|
| /external/webp/src/utils/ |
| D | thread_utils.c | 205 WebPWorker* const worker = (WebPWorker*)ptr; in ThreadLoop() local
231 static void ChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) { in ChangeState()
263 static void Init(WebPWorker* const worker) { in Init()
268 static int Sync(WebPWorker* const worker) { in Sync()
276 static int Reset(WebPWorker* const worker) { in Reset()
316 static void Execute(WebPWorker* const worker) { in Execute()
322 static void Launch(WebPWorker* const worker) { in Launch()
330 static void End(WebPWorker* const worker) { in End()
|
| /external/libaom/libaom/av1/ |
| D | av1_dx_iface.c | 116 AVxWorker *const worker = ctx->frame_worker; in decoder_destroy() local
379 AVxWorker *const worker = ctx->frame_worker; in init_buffer_callbacks() local
445 AVxWorker *const worker = ctx->frame_worker; in init_decoder() local
511 AVxWorker *const worker = ctx->frame_worker; in decode_one() local
600 AVxWorker *const worker = ctx->frame_worker; in decoder_decode() local
752 AVxWorker *const worker = ctx->frame_worker; in decoder_get_frame() local
872 AVxWorker *const worker = ctx->frame_worker; in ctrl_set_reference() local
887 AVxWorker *const worker = ctx->frame_worker; in ctrl_copy_reference() local
901 AVxWorker *const worker = ctx->frame_worker; in ctrl_get_reference() local
917 AVxWorker *const worker = ctx->frame_worker; in ctrl_get_new_frame_image() local
[all …]
|
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| D | WorkerProcessTest.java | 110 Process worker = createWorkerProcess(FakeWorkers.Exit.class, "0").startWorker(); in shutdownHook_waitFor() local
118 Process worker = createWorkerProcess( in shutdownHook_exitValueThrows() local
134 Process worker = createWorkerProcess(FakeWorkers.Exit.class, "0").startWorker(); in shutdownHook_exitValue() local
147 Process worker = createWorkerProcess( in shutdownHook_destroy() local
|
| /external/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 27 struct worker { struct
31 static void *worker(void *p) in worker() function
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | SchedulerTest.kt | 49 val worker = scheduler.createWorker() in <lambda>() constant
114 val worker = it.createWorker() in <lambda>() constant
151 val worker = it.createWorker() in <lambda>() constant
190 val worker = scheduler.createWorker() in <lambda>() constant
201 val worker = it.createWorker() in <lambda>() constant
386 val worker = scheduler.createWorker() in <lambda>() constant
421 val worker = scheduler.createWorker() in <lambda>() constant
|
| D | SchedulerStressTest.kt | 32 val worker = scheduler.createWorker() in <lambda>() constant
71 val worker = scheduler.createWorker() in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | SchedulerTest.kt | 49 val worker = scheduler.createWorker() in <lambda>() constant
114 val worker = it.createWorker() in <lambda>() constant
151 val worker = it.createWorker() in <lambda>() constant
190 val worker = scheduler.createWorker() in <lambda>() constant
201 val worker = it.createWorker() in <lambda>() constant
386 val worker = scheduler.createWorker() in <lambda>() constant
421 val worker = scheduler.createWorker() in <lambda>() constant
|
| D | SchedulerStressTest.kt | 32 val worker = scheduler.createWorker() in <lambda>() constant
71 val worker = scheduler.createWorker() in <lambda>() constant
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_cache.h | 55 virtual void ReleaseWorker(const string& target, WorkerInterface* worker) { in ReleaseWorker()
57 delete worker; in ReleaseWorker() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/nativeOther/test/ |
| D | Launcher.kt | 13 val worker = Worker.start(name = "main-background") in mainBackground() constant
|
| /external/libabigail/src/ |
| D | abg-workers.cc | 82 struct worker struct
84 pthread_t tid;
86 worker() in worker() function
|
| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 34 void Run(VPxWorker *worker) { in Run()
201 void Init(VPxWorker *const worker) { memset(worker, 0, sizeof(*worker)); } in Init()
203 int Sync(VPxWorker *const worker) { return !worker->had_error; } in Sync()
205 void Execute(VPxWorker *const worker) { in Execute()
209 void Launch(VPxWorker *const worker) { Execute(worker); } in Launch()
|
| /external/apache-xml/src/main/java/org/apache/xml/utils/ |
| D | ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task) in waitThread()
87 public void waitThread(Thread worker, Runnable task) in waitThread()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/nativeDarwin/test/ |
| D | Launcher.kt | 14 val worker = Worker.start(name = "main-background") in mainBackground() constant
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | pollset_windows.cc | 51 static void remove_worker(grpc_pollset_worker* worker, in remove_worker()
76 grpc_pollset_worker* worker) { in push_front_worker()
112 grpc_pollset_worker worker; in pollset_work() local
|