| /third_party/node/test/addons/no-addons/ |
| D | test-worker.js | 22 const worker = new Worker(`require(${JSON.stringify(binding)})`, { constant
31 const worker = new Worker( constant
43 const worker = new Worker(`require(${JSON.stringify(binding)})`, { constant
53 const worker = new Worker(`require(${JSON.stringify(binding)})`, { constant
|
| /third_party/node/test/parallel/ |
| D | test-cluster-worker-constructor.js | 29 let worker; variable
31 worker = new cluster.Worker(); variable
37 worker = new cluster.Worker({ variable
|
| D | test-cluster-dgram-1.js | 79 function setupWorker(worker) { argument
94 function worker() { function
|
| D | test-cluster-dgram-bind-fd.js | 70 function setupWorker(worker) { argument
89 function worker() { function
|
| D | test-cluster-worker-disconnect.js | 45 worker: { property
56 const worker = cluster.fork(); constant
|
| D | test-worker-console-listeners.js | 10 const worker = new Worker(__filename); constant
|
| D | test-worker-fs-stat-watcher.js | 12 const worker = new Worker(__filename); constant
|
| D | test-preload-worker.js | 5 const worker = fixtures.path('worker-preload.js'); constant
|
| D | test-worker-parent-port-ref.js | 11 const worker = new Worker(__filename); constant
|
| /third_party/node/lib/internal/cluster/ |
| D | master.js | 153 function removeWorker(worker) { argument
163 function removeHandlesForWorker(worker) { argument
230 function emitForkNT(worker) { argument
266 function online(worker) { argument
272 function exitedAfterDisconnect(worker, message) { argument
277 function queryServer(worker, message) { argument
333 function listening(worker, message) { argument
348 function close(worker, message) { argument
356 function send(worker, message, handle, cb) { argument
|
| D | round_robin_handle.js | 46 RoundRobinHandle.prototype.add = function(worker, send) { argument
73 RoundRobinHandle.prototype.remove = function(worker) { argument
105 RoundRobinHandle.prototype.handoff = function(worker) { argument
|
| D | shared_handle.js | 27 SharedHandle.prototype.add = function(worker, send) { argument
33 SharedHandle.prototype.remove = function(worker) { argument
|
| /third_party/skia/third_party/externals/libwebp/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()
|
| /third_party/flutter/skia/third_party/externals/libwebp/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()
|
| /third_party/eudev/src/udev/ |
| D | udevd.c | 91 struct worker *worker; member
118 struct worker { struct
124 enum worker_state state; argument
128 /* passed from worker to main process */ argument
146 static void worker_free(struct worker *worker) { in worker_free()
159 struct worker *worker; in workers_free() local
170 _cleanup_free_ struct worker *worker = NULL; in worker_new() local
203 static void worker_attach_event(struct worker *worker, struct event *event) { in worker_attach_event()
428 struct worker *worker; in worker_spawn() local
444 struct worker *worker; in event_run() local
[all …]
|
| /third_party/mindspore/mindspore/core/mindrt/src/thread/ |
| D | threadpool.cc | 133 for (auto &worker : workers_) { in ~ThreadPool() local
153 auto worker = new (std::nothrow) Worker(); in CreateThreads() local
257 for (const auto &worker : assigned) { in CalculateScales() local
269 Worker *worker = workers[i]; in ActiveWorkers() local
279 for (auto &worker : workers_) { in ActiveWorkers() local
285 for (const auto &worker : workers_) { in CurrentWorker() local
339 for (auto worker : workers_) { in SetSpinCountMaxValue() local
347 for (auto worker : workers_) { in SetSpinCountMinValue() local
|
| D | actor_threadpool.cc | 88 for (auto &worker : workers_) { in ~ActorThreadPool() local
94 for (auto &worker : workers_) { in ~ActorThreadPool() local
134 auto worker = reinterpret_cast<ActorWorker *>(workers_[i]); in PushActorToQueue() local
160 auto worker = new (std::nothrow) ActorWorker(); in CreateThreads() local
|
| /third_party/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 27 struct worker { struct
31 static void *worker(void *p) in worker() argument
|
| /third_party/glib/gio/ |
| D | gdbusprivate.c | 428 GDBusWorker *worker; member
443 _g_dbus_worker_ref (GDBusWorker *worker) in _g_dbus_worker_ref()
450 _g_dbus_worker_unref (GDBusWorker *worker) in _g_dbus_worker_unref()
475 _g_dbus_worker_emit_disconnected (GDBusWorker *worker, in _g_dbus_worker_emit_disconnected()
484 _g_dbus_worker_emit_message_received (GDBusWorker *worker, in _g_dbus_worker_emit_message_received()
492 _g_dbus_worker_emit_message_about_to_be_sent (GDBusWorker *worker, in _g_dbus_worker_emit_message_about_to_be_sent()
505 _g_dbus_worker_queue_or_deliver_received_message (GDBusWorker *worker, in _g_dbus_worker_queue_or_deliver_received_message()
525 GDBusWorker *worker = user_data; in unfreeze_in_idle_cb() local
548 _g_dbus_worker_unfreeze (GDBusWorker *worker) in _g_dbus_worker_unfreeze()
572 GDBusWorker *worker = user_data; in _g_dbus_worker_do_read_cb() local
[all …]
|
| /third_party/skia/third_party/externals/spirv-cross/include/spirv_cross/ |
| D | thread_group.hpp | 39 for (auto &worker : workers) in run() local
45 for (auto &worker : workers) in wait() local
106 std::thread worker; member
|
| /third_party/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
|
| /third_party/nghttp2/src/ |
| D | shrpx_connection_handler.cc | 176 for (auto &worker : workers_) { in set_ticket_keys_to_worker() local
186 for (auto &worker : workers_) { in worker_reopen_log_files() local
198 for (auto &worker : workers_) { in worker_replace_downstream() local
300 auto worker = std::make_unique<Worker>( in create_worker_thread() local
315 for (auto &worker : workers_) { in create_worker_thread() local
333 for (auto &worker : workers_) { in join_worker() local
355 for (auto &worker : workers_) { in graceful_shutdown_worker() local
406 Worker *worker; in handle_connection() local
|
| /third_party/skia/third_party/externals/freetype/src/sdf/ |
| D | ftbsdf.c | 570 bsdf_approximate_edge( BSDF_Worker* worker ) in bsdf_approximate_edge()
644 BSDF_Worker* worker ) in bsdf_init_distance_map()
907 first_pass( BSDF_Worker* worker ) in first_pass()
976 second_pass( BSDF_Worker* worker ) in second_pass()
1047 edt8( BSDF_Worker* worker ) in edt8()
1092 finalize_sdf( BSDF_Worker* worker, in finalize_sdf()
1230 BSDF_Worker worker; in bsdf_raster_render() local
|
| /third_party/node/test/node-api/test_worker_terminate_finalization/ |
| D | test.js | 11 const worker = new Worker(__filename); constant
|
| /third_party/node/test/es-module/ |
| D | test-esm-loader-side-effect.mjs | 24 const worker = new Worker(fileURLToPath(import.meta.url)); constant
|