| /external/libvpx/libvpx/vpx_util/ |
| D | vpx_thread.c | 30 static void execute(VPxWorker *const worker); // Forward declaration.
33 VPxWorker *const worker = (VPxWorker *)ptr; in thread_loop() local
36 pthread_mutex_lock(&worker->impl_->mutex_); in thread_loop()
37 while (worker->status_ == OK) { // wait in idling mode in thread_loop()
38 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_); in thread_loop()
40 if (worker->status_ == WORK) { in thread_loop()
41 execute(worker); in thread_loop()
42 worker->status_ = OK; in thread_loop()
43 } else if (worker->status_ == NOT_OK) { // finish the worker in thread_loop()
47 pthread_cond_signal(&worker->impl_->condition_); in thread_loop()
[all …]
|
| /external/libaom/libaom/aom_util/ |
| D | aom_thread.c | 39 static void execute(AVxWorker *const worker); // Forward declaration.
42 AVxWorker *const worker = (AVxWorker *)ptr; in thread_loop() local
44 if (worker->thread_name != NULL) { in thread_loop()
51 strncpy(thread_name, worker->thread_name, sizeof(thread_name)); in thread_loop()
56 if (worker->thread_name != NULL) { in thread_loop()
60 strncpy(thread_name, worker->thread_name, sizeof(thread_name)); in thread_loop()
67 pthread_mutex_lock(&worker->impl_->mutex_); in thread_loop()
68 while (worker->status_ == OK) { // wait in idling mode in thread_loop()
69 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_); in thread_loop()
71 if (worker->status_ == WORK) { in thread_loop()
[all …]
|
| /external/webp/src/utils/ |
| D | thread_utils.c | 205 WebPWorker* const worker = (WebPWorker*)ptr; in ThreadLoop() local
206 WebPWorkerImpl* const impl = (WebPWorkerImpl*)worker->impl_; in ThreadLoop()
210 while (worker->status_ == OK) { // wait in idling mode in ThreadLoop()
213 if (worker->status_ == WORK) { in ThreadLoop()
214 WebPGetWorkerInterface()->Execute(worker); in ThreadLoop()
215 worker->status_ = OK; in ThreadLoop()
216 } else if (worker->status_ == NOT_OK) { // finish the worker in ThreadLoop()
227 static void ChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) { in ChangeState() argument
231 WebPWorkerImpl* const impl = (WebPWorkerImpl*)worker->impl_; in ChangeState()
235 if (worker->status_ >= OK) { in ChangeState()
[all …]
|
| D | thread_utils.h | 52 void (*Init)(WebPWorker* const worker);
55 int (*Reset)(WebPWorker* const worker);
58 int (*Sync)(WebPWorker* const worker);
62 void (*Launch)(WebPWorker* const worker);
67 void (*Execute)(WebPWorker* const worker);
70 void (*End)(WebPWorker* const worker);
|
| /external/drm_hwcomposer/tests/ |
| D | worker_test.cpp | 57 TestWorker worker; member
60 worker.Init(); in SetUp()
70 ASSERT_TRUE(worker.initialized()); in TEST_F()
72 int val = worker.value; in TEST_F()
76 ASSERT_EQ(val, worker.value); in TEST_F()
78 worker.Control(true); in TEST_F()
82 worker.Lock(); in TEST_F()
83 val = worker.value; in TEST_F()
85 ASSERT_EQ(val, worker.value); in TEST_F()
86 worker.Unlock(); in TEST_F()
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | pollset_windows.cc | 51 static void remove_worker(grpc_pollset_worker* worker, in remove_worker() argument
53 worker->links[type].prev->links[type].next = worker->links[type].next; in remove_worker()
54 worker->links[type].next->links[type].prev = worker->links[type].prev; in remove_worker()
55 worker->links[type].next = worker->links[type].prev = worker; in remove_worker()
76 grpc_pollset_worker* worker) { in push_front_worker() argument
77 worker->links[type].prev = root; in push_front_worker()
78 worker->links[type].next = worker->links[type].prev->links[type].next; in push_front_worker()
79 worker->links[type].prev->links[type].next = in push_front_worker()
80 worker->links[type].next->links[type].prev = worker; in push_front_worker()
112 grpc_pollset_worker worker; in pollset_work() local
[all …]
|
| D | ev_epoll1_linux.cc | 187 #define SET_KICK_STATE(worker, kick_state) \ argument
189 (worker)->state = (kick_state); \
190 (worker)->kick_state_mutator = __LINE__; \
458 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert() argument
460 pollset->root_worker = worker; in worker_insert()
461 worker->next = worker->prev = worker; in worker_insert()
464 worker->next = pollset->root_worker; in worker_insert()
465 worker->prev = worker->next->prev; in worker_insert()
466 worker->next->prev = worker; in worker_insert()
467 worker->prev->next = worker; in worker_insert()
[all …]
|
| D | ev_epollex_linux.cc | 1020 grpc_pollset_worker* worker, pwlinks link) { argument
1022 *root_worker = worker;
1023 worker->links[link].next = worker->links[link].prev = worker;
1026 worker->links[link].next = *root_worker;
1027 worker->links[link].prev = worker->links[link].next->links[link].prev;
1028 worker->links[link].next->links[link].prev = worker;
1029 worker->links[link].prev->links[link].next = worker;
1038 grpc_pollset_worker* worker, argument
1040 if (worker == *root_worker) {
1041 if (worker == worker->links[link].next) {
[all …]
|
| D | ev_epollsig_linux.cc | 986 static grpc_error* pollset_worker_kick(grpc_pollset_worker* worker) { argument
990 if (gpr_atm_no_barrier_cas(&worker->is_kicked, static_cast<gpr_atm>(0),
994 (void*)worker, (long int)worker->pt_id);
995 int err_num = pthread_kill(worker->pt_id, grpc_wakeup_signal);
1009 static void remove_worker(grpc_pollset* p, grpc_pollset_worker* worker) { argument
1010 worker->prev->next = worker->next;
1011 worker->next->prev = worker->prev;
1024 static void push_back_worker(grpc_pollset* p, grpc_pollset_worker* worker) { argument
1025 worker->next = &p->root_worker;
1026 worker->prev = worker->next->prev;
[all …]
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | worker_service.proto | 23 import "tensorflow/core/protobuf/worker.proto";
30 // A worker service keeps track of multiple "registered graphs". Each
32 // only the nodes that should execute on this worker (and any
39 // See worker.proto for details.
42 // See worker.proto for details.
46 // See worker.proto for details.
50 // See worker.proto for details.
53 // See worker.proto for details.
56 // See worker.proto for details.
59 // See worker.proto for details.
[all …]
|
| /external/ltp/testcases/kernel/io/direct_io/ |
| D | dma_thread_diotest.c | 155 static worker_t *worker; variable
161 worker_t *worker = (worker_t *)arg; in worker_thread() local
162 int offset = worker->offset; in worker_thread()
163 int fd = worker->fd; in worker_thread()
164 unsigned char *buffer = worker->buffer; in worker_thread()
165 int pattern = worker->pattern; in worker_thread()
166 int length = worker->length; in worker_thread()
177 worker->worker_number, strerror(errno)); in worker_thread()
261 worker[j].fd = SAFE_OPEN(cleanup, filename, in dma_thread_diotest_verify()
263 worker[j].pattern = n; in dma_thread_diotest_verify()
[all …]
|
| /external/libaom/libaom/av1/ |
| D | av1_dx_iface.c | 127 AVxWorker *const worker = &ctx->frame_workers[i]; in decoder_destroy() local
129 (FrameWorkerData *)worker->data1; in decoder_destroy()
130 aom_get_worker_interface()->end(worker); in decoder_destroy()
385 AVxWorker *const worker = &ctx->frame_workers[i]; in init_buffer_callbacks() local
386 FrameWorkerData *const frame_worker_data = (FrameWorkerData *)worker->data1; in init_buffer_callbacks()
464 AVxWorker *const worker = &ctx->frame_workers[i]; in init_decoder() local
466 winterface->init(worker); in init_decoder()
467 worker->thread_name = "aom frameworker"; in init_decoder()
468 worker->data1 = aom_memalign(32, sizeof(FrameWorkerData)); in init_decoder()
469 if (worker->data1 == NULL) { in init_decoder()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 35 auto worker = coordination.create_coordinator().get_worker(); variable
41 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anond4f2187e0602()
48 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::… in __anond4f2187e0902()
55 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anond4f2187e0c02()
92 auto worker = coordination.create_coordinator().get_worker(); variable
98 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anond4f2187e1202()
105 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::… in __anond4f2187e1502()
112 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anond4f2187e1802()
149 auto worker = coordination.create_coordinator().get_worker(); variable
155 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anond4f2187e1e02()
[all …]
|
| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 34 void Run(VPxWorker *worker) { in Run() argument
37 vpx_get_worker_interface()->execute(worker); in Run()
39 vpx_get_worker_interface()->launch(worker); in Run()
200 void Init(VPxWorker *const worker) { memset(worker, 0, sizeof(*worker)); } in Init() argument
202 int Sync(VPxWorker *const worker) { return !worker->had_error; } in Sync() argument
204 void Execute(VPxWorker *const worker) { in Execute() argument
205 worker->had_error |= !worker->hook(worker->data1, worker->data2); in Execute()
208 void Launch(VPxWorker *const worker) { Execute(worker); } in Launch() argument
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-scheduler.hpp | 200 class worker : public worker_base class
202 typedef worker this_type;
205 friend bool operator==(const worker&, const worker&);
211 worker() in worker() function in rxcpp::schedulers::worker
214 worker(composite_subscription cs, detail::const_worker_interface_ptr i) in worker() function in rxcpp::schedulers::worker
219 worker(composite_subscription cs, worker o) in worker() function in rxcpp::schedulers::worker
326 inline bool operator==(const worker& lhs, const worker& rhs) { in operator ==()
329 inline bool operator!=(const worker& lhs, const worker& rhs) { in operator !=()
342 explicit weak_worker(worker& owner) in weak_worker()
348 worker lock() const { in lock()
[all …]
|
| /external/tensorflow/tensorflow/contrib/batching/python/ops/ |
| D | batch_ops_test.py | 54 def worker(): function
58 worker_thread = threading.Thread(target=worker)
95 def worker(): function
99 worker_thread = threading.Thread(target=worker)
128 def worker(): function
133 worker_thread = threading.Thread(target=worker)
181 def worker(): function
184 worker_thread = threading.Thread(target=worker)
203 def worker(): function
206 worker_thread = threading.Thread(target=worker)
[all …]
|
| /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
55 return new SpanExporterImpl(worker); in create()
64 worker.addSpan(span); in addSpan()
69 worker.registerHandler(name, handler); in registerHandler()
74 worker.unregisterHandler(name); in unregisterHandler()
78 worker.flush(); in flush()
86 private SpanExporterImpl(Worker worker) { in SpanExporterImpl() argument
88 new DaemonThreadFactory("ExportComponent.ServiceExporterThread").newThread(worker); in SpanExporterImpl()
90 this.worker = worker; in SpanExporterImpl()
|
| /external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| D | WorkerMain.java | 17 package com.google.caliper.worker;
50 Worker worker = workerComponent.getWorker(); in main() local
55 worker.setUpBenchmark(); in main()
57 worker.bootstrap(); in main()
62 worker.preMeasure(isInWarmup); in main()
65 ShouldContinueMessage message = log.notifyMeasurementEnding(worker.measure()); in main()
69 worker.postMeasure(); in main()
76 worker.tearDownBenchmark(); in main()
|
| /external/v8/tools/profviz/ |
| D | profviz.js | 44 var worker = null;
48 worker = new Worker("worker.js");
51 worker.postMessage({ "call" : "load scripts",
54 worker.addEventListener("message", function(event) {
77 worker.postMessage({ 'call' : 'run', 'args' : args });
81 if (worker) worker.terminate();
231 worker.run(file, kResX, kResY, distortion, range[0], range[1]);
276 worker = new plotWorker();
277 worker.reset();
285 var worker; variable
|
| /external/perfetto/ui/src/common/ |
| D | wasm_engine_proxy.ts | 74 private readonly worker: Worker; property in WasmEngineProxy
80 constructor(args: {id: string, worker: Worker}) {
85 this.worker = args.worker;
86 this.worker.onmessage = this.onMessage.bind(this);
101 this.worker.postMessage(request);
112 this.worker.postMessage(request);
140 this.worker.postMessage(request);
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-buffer_time_count.hpp | 91 , worker(coordinator.get_worker()) in buffer_with_time_or_count_subscriber_values()
98 rxsc::worker worker; member
109 auto produce_time = state->worker.now() + state->period; in buffer_with_time_or_count_observer()
115 localState->worker.unsubscribe(); in buffer_with_time_or_count_observer()
125 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_or_count_observer()
128 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_or_count_observer()
137 …localState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulab… in buffer_with_time_or_count_observer()
138 localState->worker.schedule(produce_buffer(new_id, produce_time, localState)); in buffer_with_time_or_count_observer()
151 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in produce_buffer()
152 state->worker.schedule(produce_buffer(new_id, produce_time, state)); in produce_buffer()
[all …]
|
| D | rx-window_time_count.hpp | 91 , worker(coordinator.get_worker()) in window_with_time_or_count_subscriber_values()
99 rxsc::worker worker; member
111 auto produce_time = state->worker.now(); in window_with_time_or_count_observer()
117 localState->worker.unsubscribe(); in window_with_time_or_count_observer()
127 localState->worker.schedule(selectedDisposer.get()); in window_with_time_or_count_observer()
130 localState->worker.schedule(selectedDisposer.get()); in window_with_time_or_count_observer()
139 …localState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulab… in window_with_time_or_count_observer()
140 localState->worker.schedule(release_window(new_id, produce_time, localState)); in window_with_time_or_count_observer()
155 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in release_window()
156 state->worker.schedule(release_window(new_id, produce_time, state)); in release_window()
[all …]
|
| D | rx-delay.hpp | 83 , worker(coordinator.get_worker()) in delay_subscriber_values()
84 , expected(worker.now()) in delay_subscriber_values()
90 rxsc::worker worker; member
103 localState->worker.unsubscribe(); in delay_observer()
113 localState->worker.schedule(selectedDisposer.get()); in delay_observer()
116 …localState->worker.schedule(localState->worker.now() + localState->period, selectedDisposer.get()); in delay_observer()
131 … localState->worker.schedule(localState->worker.now() + localState->period, selectedWork.get()); in on_next()
145 localState->worker.schedule(selectedWork.get()); in on_error()
159 … localState->worker.schedule(localState->worker.now() + localState->period, selectedWork.get()); in on_completed()
|
| D | rx-timeout.hpp | 92 , worker(coordinator.get_worker()) in timeout_subscriber_values()
100 rxsc::worker worker; member
114 localState->worker.unsubscribe(); in timeout_observer()
124 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()
127 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()
132 auto produce_time = localState->worker.now() + localState->period; in timeout_observer()
134 localState->worker.schedule(produce_time, produce_timeout(new_id, localState)); in timeout_observer()
142 localState->worker.schedule(selectedWork.get()); in timeout_observer()
167 auto produce_time = localState->worker.now() + localState->period; in on_next()
170 localState->worker.schedule(produce_time, produce_timeout(new_id, localState)); in on_next()
[all …]
|
| /external/perfetto/docs/ |
| D | ftrace.md | 26 worker #0 [splice ...] [wakeup] [block ............] [splice]
28 worker #1 [splice ...] [wakeup] [block ........] [splice]
30 worker #2 [splice ..........................................]
37 granularity. This call allows every per-cpu worker to sleep until there
40 When a worker wakes up, it will attempt to move as many pages as
44 will block the calling worker until the main thread has drained the
47 When at least one worker has woken up, we schedule a drain operation
50 every worker having pending data. After this, each waiting worker is
|