| /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/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/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 | 66 def worker(): function
109 def worker(): function
144 def worker(): function
201 def worker(): function
229 def worker(): function
277 def worker(): function
304 def worker(): function
388 def worker(): function
424 def worker(): function
529 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_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_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_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/kotlinx.coroutines/kotlinx-coroutines-core/native/test/ |
| D | WorkerTest.kt | 16 val worker = Worker.start() in testLaunchInWorker() constant
28 val worker = Worker.start() in testLaunchInWorkerThroughGlobalScope() constant
48 val worker = Worker.start() in testRunBlockingInTerminatedWorker() constant
|
| /external/ltp/testcases/kernel/fs/read_all/ |
| D | read_all.c | 66 struct worker { struct
90 static struct worker *workers; argument
211 static void worker_heartbeat(const int worker) in worker_heartbeat()
216 static int worker_elapsed(const int worker) in worker_elapsed()
223 static int worker_ttl(const int worker) in worker_ttl()
228 static void read_test(const int worker, const char *const path) in read_test()
297 static int worker_run(int worker) in worker_run()
347 static void restart_worker(const int worker) in restart_worker()
428 static int try_push_work(const int worker, const char *buf) in try_push_work()
458 static void push_work(const int worker, const char *buf) in push_work()
|
| /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/cronet/base/task/thread_pool/ |
| D | worker_thread_unittest.cc | 72 void OnMainEntry(WorkerThread* worker) override {} in OnMainEntry()
73 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
164 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
176 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
463 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
506 void OnMainExit(WorkerThread* worker) override { in OnMainExit()
510 bool CanCleanup(WorkerThread* worker) { in CanCleanup()
563 auto worker = in TEST() local
591 auto worker = in TEST() local
618 auto worker = in TEST() local
[all …]
|
| D | worker_thread_set.cc | 23 void WorkerThreadSet::Insert(WorkerThread* worker) { in Insert()
36 WorkerThread* const worker = *set_.begin(); in Take() local
53 void WorkerThreadSet::Remove(const WorkerThread* worker) { in Remove()
|
| D | thread_group_impl.cc | 83 const WorkerThread* worker) { in ContainsWorker()
104 void ScheduleWakeUp(scoped_refptr<WorkerThread> worker) { in ScheduleWakeUp()
108 void ScheduleStart(scoped_refptr<WorkerThread> worker) { in ScheduleStart()
134 void AddWorker(scoped_refptr<WorkerThread> worker) { in AddWorker()
173 [](WorkerThread* worker) { worker->WakeUp(); }); in FlushImpl()
178 workers_to_start_.ForEachWorker([&](WorkerThread* worker) { in FlushImpl()
490 for (const auto& worker : workers_copy) in JoinForTesting() local
533 WorkerThread* worker) { in OnMainEntry()
565 WorkerThread* worker) { in GetWork()
717 WorkerThread* worker) { in CleanupLockRequired()
[all …]
|
| D | pooled_single_thread_task_runner_manager.cc | 114 void set_worker(WorkerThread* worker) { in set_worker()
128 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
208 RegisteredTaskSource GetWorkLockRequired(WorkerThread* worker) in GetWorkLockRequired()
280 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
286 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
418 WorkerThread* worker, in PooledSingleThreadTaskRunner()
608 for (auto& worker : workers_to_update) { in DidUpdateCanRunPolicy() local
656 WorkerThread*& worker = in CreateTaskRunnerImpl() local
692 for (const auto& worker : local_workers) { in JoinForTesting() local
751 scoped_refptr<WorkerThread> worker = MakeRefCounted<WorkerThread>( in CreateAndRegisterWorkerThread() local
[all …]
|
| /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/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 27 struct worker { struct
32 static void *worker(void *p) in worker() function
|
| /external/crosvm/swap/tests/ |
| D | page_handler.rs | 32 let worker = Worker::new(2, 2); in create_success() localVariable
54 let worker = Worker::new(2, 2); in create_partially_overlap() localVariable
91 let worker = Worker::new(2, 2); in create_invalid_range() localVariable
120 let worker = Worker::new(2, 2); in handle_page_fault_zero_success() localVariable
159 let worker = Worker::new(2, 2); in handle_page_fault_invalid_address() localVariable
187 let worker = Worker::new(2, 2); in handle_page_fault_duplicated_page_fault() localVariable
211 let worker = Worker::new(2, 2); in handle_page_remove_success() localVariable
257 let worker = Worker::new(2, 2); in handle_page_remove_invalid_address() localVariable
299 let worker = Worker::new(2, 2); in move_to_staging_data_written_before_enabling() localVariable
394 let worker = Worker::new(2, 2); in move_to_staging_hugepage_chunks() localVariable
[all …]
|
| /external/virglrenderer/server/ |
| D | render_worker.c | 194 struct render_worker *worker) in render_worker_jail_add_worker()
202 struct render_worker *worker) in render_worker_jail_remove_worker()
278 struct render_worker *worker = in render_worker_jail_wait_workers() local
336 struct render_worker *worker = in render_worker_jail_reap_workers() local
368 struct render_worker *worker = calloc(1, sizeof(*worker) + thread_data_size); in render_worker_create() local
397 render_worker_destroy(struct render_worker_jail *jail, struct render_worker *worker) in render_worker_destroy()
418 render_worker_is_record(const struct render_worker *worker) in render_worker_is_record()
|
| /external/libaom/av1/ |
| D | av1_dx_iface.c | 117 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
548 AVxWorker *const worker = ctx->frame_worker; in release_pending_output_frames() local
798 AVxWorker *const worker = ctx->frame_worker; in decoder_get_frame() local
918 AVxWorker *const worker = ctx->frame_worker; in ctrl_set_reference() local
933 AVxWorker *const worker = ctx->frame_worker; in ctrl_copy_reference() local
947 AVxWorker *const worker = ctx->frame_worker; in ctrl_get_reference() local
963 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/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/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
|
| /external/libvpx/test/ |
| D | vp9_thread_test.cc | 34 void Run(VPxWorker *worker) { in Run()
186 void Init(VPxWorker *const worker) { memset(worker, 0, sizeof(*worker)); } in Init()
188 int Sync(VPxWorker *const worker) { return !worker->had_error; } in Sync()
190 void Execute(VPxWorker *const worker) { in Execute()
194 void Launch(VPxWorker *const worker) { Execute(worker); } in Launch()
|