| /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_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 | 15 val worker = Worker.start() in testLaunchInWorker() constant
27 val worker = Worker.start() in testLaunchInWorkerTroughGlobalScope() constant
|
| /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/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/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/libaom/libaom/av1/ |
| D | av1_dx_iface.c | 116 AVxWorker *const worker = ctx->frame_worker; in decoder_destroy() local
373 AVxWorker *const worker = ctx->frame_worker; in init_buffer_callbacks() local
439 AVxWorker *const worker = ctx->frame_worker; in init_decoder() local
504 AVxWorker *const worker = ctx->frame_worker; in decode_one() local
592 AVxWorker *const worker = ctx->frame_worker; in decoder_decode() local
743 AVxWorker *const worker = ctx->frame_worker; in decoder_get_frame() local
863 AVxWorker *const worker = ctx->frame_worker; in ctrl_set_reference() local
878 AVxWorker *const worker = ctx->frame_worker; in ctrl_copy_reference() local
892 AVxWorker *const worker = ctx->frame_worker; in ctrl_get_reference() local
908 AVxWorker *const worker = ctx->frame_worker; in ctrl_get_new_frame_image() local
[all …]
|
| /external/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 27 struct worker { struct
31 static void *worker(void *p) in worker() argument
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/nativeOther/test/ |
| D | Launcher.kt | 13 val worker = Worker.start(name = "main-background") in mainBackground() constant
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_cache.h | 54 virtual void ReleaseWorker(const string& target, WorkerInterface* worker) { in ReleaseWorker()
56 delete worker; in ReleaseWorker() local
|
| /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/libabigail/src/ |
| D | abg-workers.cc | 82 struct worker struct
84 pthread_t tid;
86 worker() in worker() function
|
| /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
|
| /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/rust/crates/grpcio-sys/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
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | CoroutineScheduler.kt | 207 val worker = workers[index] ?: return null // stack is empty in <lambda>() constant
341 val worker = workers[i]!! in <lambda>() constant
451 val worker = parkedWorkersStackPop() ?: return false in <lambda>() constant
482 val worker = Worker(newIndex) in <lambda>() constant
529 val worker = workers[index] ?: continue in <lambda>() constant
907 val worker = workers[currentIndex] in <lambda>() constant
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/ |
| D | SpanExporterImpl.java | 39 private final Worker worker; field in SpanExporterImpl
54 Worker worker = new Worker(bufferSize, scheduleDelay); in create() local
86 private SpanExporterImpl(Worker worker) { in SpanExporterImpl()
|
| /external/libchrome/base/android/java/src/org/chromium/base/ |
| D | CollectionUtil.java | 86 public static <T> void forEach(Collection<? extends T> collection, Callback<T> worker) { in forEach()
94 Map<? extends K, ? extends V> map, Callback<Entry<K, V>> worker) { in forEach()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 35 auto worker = coordination.create_coordinator().get_worker(); variable
92 auto worker = coordination.create_coordinator().get_worker(); variable
149 auto worker = coordination.create_coordinator().get_worker(); variable
206 auto worker = coordination.create_coordinator().get_worker(); variable
|