| /aosp_15_r20/external/libtextclassifier/java/tests/instrumentation/src/com/android/textclassifier/downloader/ |
| H A 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 …]
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/internal/fuzz/ |
| D | worker.go | 46 type worker struct { struct
47 dir string // working directory, same as package directory
48 binPath string // path to test executable
49 args []string // arguments for test executable
50 env []string // environment for test executable
52 coordinator *coordinator
54 memMu chan *sharedMem // mutex guarding shared memory with worker; persists across processes.
56 cmd *exec.Cmd // current worker process
57 client *workerClient // used to communicate with worker process
58 waitErr error // last error returned by wait, set before termC is closed.
[all …]
|
| /aosp_15_r20/external/libchrome/base/task_scheduler/ |
| H A 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 …]
|
| H A 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 …]
|
| H A 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()
|
| /aosp_15_r20/external/cronet/base/task/thread_pool/ |
| H A D | thread_group_impl.cc | 46 for (auto worker : workers_to_wake_up_) { in ~ScopedCommandsExecutor() local
51 void ScheduleWakeUp(scoped_refptr<WorkerThreadWaitableEvent> worker) { in ScheduleWakeUp()
183 WorkerThread* worker) { in OnMainEntry()
192 WorkerThreadWaitableEvent* worker = in OnMainExit() local
231 WorkerThreadWaitableEvent* worker = in CanGetWorkLockRequired() local
260 WorkerThread* worker) { in GetWork()
275 WorkerThread* worker) { in SwapProcessedTask()
337 const WorkerThread* worker) { in CanCleanupLockRequired()
353 WorkerThreadWaitableEvent* worker = in CleanupLockRequired() local
373 WorkerThreadWaitableEvent* worker = in OnWorkerBecomesIdleLockRequired() local
[all …]
|
| H A D | thread_group_semaphore.cc | 189 WorkerThread* worker) { in OnMainEntry()
198 WorkerThreadSemaphore* worker = in OnMainExit() local
237 WorkerThreadSemaphore* worker = in CanGetWorkLockRequired() local
261 WorkerThread* worker) { in GetWork()
277 WorkerThread* worker) { in SwapProcessedTask()
353 const WorkerThread* worker) { in CanCleanupLockRequired()
361 WorkerThreadSemaphore* worker = in CleanupLockRequired() local
416 for (const auto& worker : workers_copy) { in JoinForTesting() local
440 scoped_refptr<WorkerThreadSemaphore> worker = in CreateAndRegisterWorkerLockRequired() local
463 WorkerThread* worker) { in GetWorkerDelegate()
|
| H A D | worker_thread_waitable_event_unittest.cc | 94 void OnMainEntry(WorkerThread* worker) override {} in OnMainEntry()
95 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
99 WorkerThread* worker) override { in SwapProcessedTask()
177 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
219 WorkerThread* worker) override { in SwapProcessedTask()
223 void OnMainExit(WorkerThread* worker) override { in OnMainExit()
227 bool CanCleanup(WorkerThread* worker) { in CanCleanup()
396 WorkerType* worker) { in GetControls()
470 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
482 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
[all …]
|
| H A D | pooled_single_thread_task_runner_manager.cc | 115 void set_worker(WorkerThreadWaitableEvent* worker) { in set_worker()
129 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
145 WorkerThread* worker) override { in SwapProcessedTask()
241 RegisteredTaskSource GetWorkLockRequired(WorkerThread* worker) in GetWorkLockRequired()
313 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
322 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
453 WorkerThreadWaitableEvent* worker, in PooledSingleThreadTaskRunner()
644 for (auto& worker : workers_to_update) { in DidUpdateCanRunPolicy() local
692 WorkerThreadWaitableEvent*& worker = in CreateTaskRunnerImpl() local
728 for (const auto& worker : local_workers) { in JoinForTesting() local
[all …]
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/ops/ |
| H A 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 …]
|
| /aosp_15_r20/external/ltp/testcases/kernel/fs/read_all/ |
| H A 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()
|
| /aosp_15_r20/external/libaom/av1/ |
| H A 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 …]
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/unittest/service-core/appsearch/src/com/android/adservices/service/appsearch/ |
| D | AppSearchConsentWorkerTest.java | 494 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in runRecordNotificationDisplayedTestFailure() local
512 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in runRecordNotificationDisplayedTestFailureTimeout() local
560 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testSetCurrentPrivacySandboxFeature_failure() local
576 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testSetCurrentPrivacySandboxFeature_failure_timeout() local
619 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testRecordUserManualInteractionWithConsent_failure() local
638 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testRecordUserManualInteractionWithConsent_failure_timeout() local
679 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testRecordBlockedTopic_failure() local
697 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testRecordBlockedTopic_failure_timeout() local
748 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testRecordUnblockedTopic_failure() local
798 AppSearchConsentWorker worker = AppSearchConsentWorker.getInstance(); in testClearBlockedTopics_failure() local
[all …]
|
| /aosp_15_r20/external/libvpx/vpx_util/ |
| H A 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()
|
| /aosp_15_r20/external/libaom/aom_util/ |
| H A 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()
|
| /aosp_15_r20/external/crosvm/swap/tests/ |
| H A 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 …]
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| H A D | SchedulerTest.kt | 46 val worker = scheduler.createWorker() in <lambda>() constant
111 val worker = it.createWorker() in <lambda>() constant
148 val worker = it.createWorker() in <lambda>() constant
187 val worker = scheduler.createWorker() in <lambda>() constant
198 val worker = it.createWorker() in <lambda>() constant
383 val worker = scheduler.createWorker() in <lambda>() constant
418 val worker = scheduler.createWorker() in <lambda>() constant
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| H A D | SchedulerTest.kt | 46 val worker = scheduler.createWorker() in <lambda>() constant
111 val worker = it.createWorker() in <lambda>() constant
148 val worker = it.createWorker() in <lambda>() constant
187 val worker = scheduler.createWorker() in <lambda>() constant
198 val worker = it.createWorker() in <lambda>() constant
383 val worker = scheduler.createWorker() in <lambda>() constant
418 val worker = scheduler.createWorker() in <lambda>() constant
|
| /aosp_15_r20/external/webp/src/utils/ |
| H A 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()
|
| /aosp_15_r20/packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| D | DefaultDialerExecutorFactory.java | 63 @NonNull Worker<InputT, OutputT> worker) { in createUiTaskBuilder()
75 @NonNull Worker<InputT, OutputT> worker) { in createNonUiTaskBuilder()
82 private final Worker<InputT, OutputT> worker; field in DefaultDialerExecutorFactory.BaseTaskBuilder
92 Worker<InputT, OutputT> worker, in BaseTaskBuilder()
125 Worker<InputT, OutputT> worker, in UiTaskBuilder()
153 Worker<InputT, OutputT> worker, in NonUiTaskBuilder()
203 private final Worker<InputT, OutputT> worker; field in DefaultDialerExecutorFactory.NonUiDialerExecutor
213 Worker<InputT, OutputT> worker, in NonUiDialerExecutor()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/native/test/ |
| H A 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
|
| /aosp_15_r20/external/virglrenderer/server/ |
| H A 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()
|
| /aosp_15_r20/out/soong/.intermediates/frameworks/base/packages/StatementService/StatementService/android_common/kotlin_headers/ |
| D | StatementService.jar | META-INF/
META-INF/MANIFEST.MF
META-INF/frameworks__base__packages__StatementService__android_common__StatementService.kotlin_module
com ... |
| /aosp_15_r20/packages/modules/OnDevicePersonalization/tests/cts/endtoend/src/com/android/ondevicepersonalization/cts/e2e/ |
| D | IsolatedWorkerTest.java | 86 IsolatedWorker worker = new TestWorker(); in testOnExecute() local
95 IsolatedWorker worker = new TestWorker(); in testOnRender() local
105 IsolatedWorker worker = new TestWorker(); in testOnDownloadCompleted() local
115 IsolatedWorker worker = new TestWorker(); in testOnEvent() local
127 IsolatedWorker worker = new TestWorker(); in testOnTrainingExamples() local
141 IsolatedWorker worker = new TestWorker(); in testOnWebTrigger() local
|
| /aosp_15_r20/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/ |
| H A 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()
|