| /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 | 41 VPxWorker *const worker = (VPxWorker *)ptr; in thread_loop() local
93 static void change_state(VPxWorker *const worker, VPxWorkerStatus new_status) { in change_state()
118 static void init(VPxWorker *const worker) { in init()
123 static int sync(VPxWorker *const worker) { in sync()
131 static int reset(VPxWorker *const worker) { in reset()
169 static void execute(VPxWorker *const worker) { in execute()
175 static void launch(VPxWorker *const worker) { in launch()
183 static void end(VPxWorker *const worker) { in end()
|
| /external/libaom/aom_util/ |
| D | aom_thread.c | 46 AVxWorker *const worker = (AVxWorker *)ptr; in thread_loop() local
98 static void change_state(AVxWorker *const worker, AVxWorkerStatus new_status) { in change_state()
123 static void init(AVxWorker *const worker) { in init()
128 static int sync(AVxWorker *const worker) { in sync()
136 static int reset(AVxWorker *const worker) { in reset()
195 static void execute(AVxWorker *const worker) { in execute()
201 static void launch(AVxWorker *const worker) { in launch()
209 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 | 13 val worker = Worker.start() in testLaunchInWorker() constant
25 val worker = Worker.start() in testLaunchInWorkerThroughGlobalScope() constant
45 val worker = Worker.start() in testRunBlockingInTerminatedWorker() constant
|
| /external/cronet/stable/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()
77 WorkerThread* worker) override { in SwapProcessedTask()
188 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
200 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
253 WorkerThread* worker) override { in SwapProcessedTask()
489 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
531 WorkerThread* worker) override { in SwapProcessedTask()
535 void OnMainExit(WorkerThread* worker) override { in OnMainExit()
539 bool CanCleanup(WorkerThread* worker) { in CanCleanup()
[all …]
|
| D | thread_group_impl.cc | 46 for (auto worker : workers_to_wake_up_) { in ~ScopedCommandsExecutor() local
51 void ScheduleWakeUp(scoped_refptr<WorkerThread> worker) { in ScheduleWakeUp()
138 const WorkerThread* worker) { in ContainsWorker()
317 void ThreadGroupImpl::WorkerDelegate::OnMainEntry(WorkerThread* worker) { in OnMainEntry()
353 WorkerThread* worker = static_cast<WorkerThread*>(worker_base); in OnMainExit() local
391 WorkerThread* worker = static_cast<WorkerThread*>(worker_base); in CanGetWorkLockRequired() local
417 WorkerThread* worker) { in GetWork()
429 WorkerThread* worker) { in GetWorkLockRequired()
485 WorkerThread* worker) { in SwapProcessedTask()
546 const WorkerThread* worker) { in CanCleanupLockRequired()
[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 | pooled_single_thread_task_runner_manager.cc | 122 void set_worker(WorkerThread* worker) { in set_worker()
136 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
152 WorkerThread* worker) override { in SwapProcessedTask()
248 RegisteredTaskSource GetWorkLockRequired(WorkerThread* worker) in GetWorkLockRequired()
322 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
343 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
474 WorkerThread* worker, in PooledSingleThreadTaskRunner()
664 for (auto& worker : workers_to_update) { in DidUpdateCanRunPolicy() local
712 WorkerThread*& worker = in CreateTaskRunnerImpl() local
748 for (const auto& worker : local_workers) { in JoinForTesting() local
[all …]
|
| /external/cronet/tot/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()
77 WorkerThread* worker) override { in SwapProcessedTask()
188 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
200 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
253 WorkerThread* worker) override { in SwapProcessedTask()
489 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
531 WorkerThread* worker) override { in SwapProcessedTask()
535 void OnMainExit(WorkerThread* worker) override { in OnMainExit()
539 bool CanCleanup(WorkerThread* worker) { in CanCleanup()
[all …]
|
| D | thread_group_impl.cc | 46 for (auto worker : workers_to_wake_up_) { in ~ScopedCommandsExecutor() local
51 void ScheduleWakeUp(scoped_refptr<WorkerThread> worker) { in ScheduleWakeUp()
138 const WorkerThread* worker) { in ContainsWorker()
317 void ThreadGroupImpl::WorkerDelegate::OnMainEntry(WorkerThread* worker) { in OnMainEntry()
353 WorkerThread* worker = static_cast<WorkerThread*>(worker_base); in OnMainExit() local
391 WorkerThread* worker = static_cast<WorkerThread*>(worker_base); in CanGetWorkLockRequired() local
417 WorkerThread* worker) { in GetWork()
429 WorkerThread* worker) { in GetWorkLockRequired()
485 WorkerThread* worker) { in SwapProcessedTask()
546 const WorkerThread* worker) { in CanCleanupLockRequired()
[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 | pooled_single_thread_task_runner_manager.cc | 122 void set_worker(WorkerThread* worker) { in set_worker()
136 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
152 WorkerThread* worker) override { in SwapProcessedTask()
248 RegisteredTaskSource GetWorkLockRequired(WorkerThread* worker) in GetWorkLockRequired()
322 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
343 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
474 WorkerThread* worker, in PooledSingleThreadTaskRunner()
664 for (auto& worker : workers_to_update) { in DidUpdateCanRunPolicy() local
712 WorkerThread*& worker = in CreateTaskRunnerImpl() local
748 for (const auto& worker : local_workers) { in JoinForTesting() local
[all …]
|
| /external/ltp/testcases/kernel/fs/read_all/ |
| D | read_all.c | 66 struct worker { struct
90 static struct worker *workers; argument
241 static void worker_heartbeat(const int worker) in worker_heartbeat()
246 static int worker_elapsed(const int worker) in worker_elapsed()
253 static int worker_ttl(const int worker) in worker_ttl()
258 static void read_test(const int worker, const char *const path) in read_test()
327 static int worker_run(int worker) in worker_run()
377 static void restart_worker(const int worker) in restart_worker()
458 static int try_push_work(const int worker, const char *buf) in try_push_work()
488 static void push_work(const int worker, const char *buf) in push_work()
|
| /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 | 28 struct worker { struct
33 static void *worker(void *p) in worker() argument
|
| /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/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/ |
| D | SpanExporterImpl.java | 74 private final Worker worker; field in SpanExporterImpl
89 Worker worker = new Worker(bufferSize, scheduleDelay); in create() local
121 private SpanExporterImpl(Worker worker) { in SpanExporterImpl()
136 public long applyAsLong(/*@Nullable*/ Worker worker) { in applyAsLong()
146 public long applyAsLong(/*@Nullable*/ Worker worker) { in applyAsLong()
156 public long applyAsLong(/*@Nullable*/ Worker worker) { in applyAsLong()
|
| /external/crosvm/swap/tests/ |
| D | page_handler.rs | 39 let worker = Worker::new(2, 2); in create_success_impl() localVariable
67 let worker = Worker::new(2, 2); in create_partially_overlap_impl() localVariable
110 let worker = Worker::new(2, 2); in create_invalid_range_impl() localVariable
141 let worker = Worker::new(2, 2); in handle_page_fault_zero_success_impl() localVariable
190 let worker = Worker::new(2, 2); in handle_page_fault_invalid_address_impl() localVariable
227 let worker = Worker::new(2, 2); in handle_page_fault_duplicated_page_fault_impl() localVariable
260 let worker = Worker::new(2, 2); in handle_page_remove_success_impl() localVariable
319 let worker = Worker::new(2, 2); in handle_page_remove_invalid_address_impl() localVariable
370 let worker = Worker::new(2, 2); in move_to_staging_data_written_before_enabling_impl() localVariable
479 let worker = Worker::new(2, 2); in move_to_staging_hugepage_chunks_impl() localVariable
[all …]
|
| /external/libaom/av1/ |
| D | av1_dx_iface.c | 122 AVxWorker *const worker = ctx->frame_worker; in decoder_destroy() local
383 AVxWorker *const worker = ctx->frame_worker; in init_buffer_callbacks() local
463 AVxWorker *const worker = ctx->frame_worker; in init_decoder() local
535 AVxWorker *const worker = ctx->frame_worker; in decode_one() local
572 AVxWorker *const worker = ctx->frame_worker; in release_pending_output_frames() local
824 AVxWorker *const worker = ctx->frame_worker; in decoder_get_frame() local
952 AVxWorker *const worker = ctx->frame_worker; in ctrl_set_reference() local
967 AVxWorker *const worker = ctx->frame_worker; in ctrl_copy_reference() local
981 AVxWorker *const worker = ctx->frame_worker; in ctrl_get_reference() local
997 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
|