| /third_party/node/lib/internal/cluster/ |
| D | primary.js | 99 for (const worker of ObjectValues(cluster.workers)) {
100 if (worker.state === 'online' || worker.state === 'listening') {
101 process._debugProcess(worker.process.pid);
103 worker.once('online', function() {
142 function removeWorker(worker) { argument
143 assert(worker);
144 delete cluster.workers[worker.id];
152 function removeHandlesForWorker(worker) { argument
153 assert(worker);
156 if (handle.remove(worker))
[all …]
|
| D | round_robin_handle.js | 51 RoundRobinHandle.prototype.add = function(worker, send) { argument
52 assert(this.all.has(worker.id) === false);
53 this.all.set(worker.id, worker);
65 this.handoff(worker); // In case there are connections pending.
78 RoundRobinHandle.prototype.remove = function(worker) { argument
79 const existed = this.all.delete(worker.id);
84 this.free.delete(worker.id);
110 const { 0: workerId, 1: worker } = workerEntry;
112 this.handoff(worker);
116 RoundRobinHandle.prototype.handoff = function(worker) { argument
[all …]
|
| /third_party/skia/third_party/externals/libwebp/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()
231 static void ChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) { in ChangeState() argument
235 WebPWorkerImpl* const impl = (WebPWorkerImpl*)worker->impl_; in ChangeState()
239 if (worker->status_ >= OK) { in ChangeState()
[all …]
|
| /third_party/skia/third_party/externals/freetype/src/sdf/ |
| D | ftbsdf.c | 570 bsdf_approximate_edge( BSDF_Worker* worker ) in bsdf_approximate_edge() argument
578 if ( !worker || !worker->distance_map ) in bsdf_approximate_edge()
584 ed = worker->distance_map; in bsdf_approximate_edge()
586 for ( j = 0; j < worker->rows; j++ ) in bsdf_approximate_edge()
588 for ( i = 0; i < worker->width; i++ ) in bsdf_approximate_edge()
590 index = j * worker->width + i; in bsdf_approximate_edge()
592 if ( bsdf_is_edge( worker->distance_map + index, in bsdf_approximate_edge()
594 worker->width, in bsdf_approximate_edge()
595 worker->rows ) ) in bsdf_approximate_edge()
600 worker->width, in bsdf_approximate_edge()
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-cluster-worker-disconnect.js | 33 cluster.worker.on('disconnect', common.mustCall(() => {
45 worker: { property
56 const worker = cluster.fork(); constant
59 worker.once('listening', common.mustCall(() => {
60 const w = worker.disconnect();
61 assert.strictEqual(worker, w, `${worker.id} did not return a reference`);
73 worker.once('disconnect', common.mustCall(() => {
74 checks.worker.emitDisconnect = true;
75 checks.worker.voluntaryMode = worker.exitedAfterDisconnect;
76 checks.worker.state = worker.state;
[all …]
|
| D | test-cluster-worker-constructor.js | 29 let worker; variable
31 worker = new cluster.Worker(); variable
32 assert.strictEqual(worker.exitedAfterDisconnect, undefined);
33 assert.strictEqual(worker.state, 'none');
34 assert.strictEqual(worker.id, 0);
35 assert.strictEqual(worker.process, undefined);
37 worker = new cluster.Worker({ variable
42 assert.strictEqual(worker.exitedAfterDisconnect, undefined);
43 assert.strictEqual(worker.state, 'online');
44 assert.strictEqual(worker.id, 3);
[all …]
|
| D | test-cluster-concurrent-disconnect.js | 16 const worker = cluster.fork(); constant
17 workers[i] = worker;
18 worker.once('online', common.mustCall(() => {
20 for (const worker of workers)
21 if (worker.isConnected())
22 worker.send(i % 2 ? 'disconnect' : 'destroy');
27 worker.on('error', (err) => {
36 worker.once('disconnect', common.mustCall(() => {
37 for (const worker of workers)
38 if (worker.isConnected())
[all …]
|
| D | test-cluster-basic.js | 72 worker: { property
92 const stateNames = Object.keys(checks.worker.states);
104 checks.cluster.equal[name] = worker === arguments[0];
108 checks.worker.states[state] = (state === worker.state);
114 worker.kill();
121 const worker = cluster.fork(); constant
122 assert.strictEqual(worker.id, 1);
123 assert(worker instanceof cluster.Worker,
127 forEach(checks.worker.events, function(bool, name, index) {
128 worker.on(name, common.mustCall(function() {
[all …]
|
| D | test-cluster-worker-isconnected.js | 7 const worker = cluster.fork(); constant
9 assert.strictEqual(worker.isConnected(), true);
11 worker.on('disconnect', common.mustCall(() => {
12 assert.strictEqual(worker.isConnected(), false);
15 worker.on('message', function(msg) {
17 worker.disconnect();
22 assert.strictEqual(cluster.worker.isConnected(), false);
25 assert.strictEqual(cluster.worker.isConnected(), true);
26 cluster.worker.on('disconnect', common.mustCall(assertNotConnected));
27 cluster.worker.process.on('disconnect', common.mustCall(assertNotConnected));
|
| D | test-cluster-worker-destroy.js | 39 [worker1, worker2].forEach(function(worker) { argument
40 worker.on('disconnect', common.mustCall());
41 worker.on('exit', common.mustCall());
43 } else if (cluster.worker.id === 1) {
45 cluster.worker.process.on('disconnect', function() {
46 cluster.worker.destroy();
49 const w = cluster.worker.disconnect();
50 assert.strictEqual(w, cluster.worker);
53 cluster.worker.destroy();
|
| D | test-cluster-worker-kill.js | 68 const worker = cluster.fork(); constant
71 worker.once('listening', common.mustCall(() => {
72 worker.process.kill(KILL_SIGNAL);
80 cluster.on('exit', common.mustCall((worker) => {
81 results.cluster_exitCode = worker.process.exitCode;
82 results.cluster_signalCode = worker.process.signalCode;
87 worker.on('disconnect', common.mustCall(() => {
89 results.worker_exitedAfter = worker.exitedAfterDisconnect;
90 results.worker_state = worker.state;
94 worker.once('exit', common.mustCall((exitCode, signalCode) => {
[all …]
|
| D | test-worker-debug.js | 65 const worker = new Worker(__filename, { workerData: id });
66 workerCallback(worker);
67 worker.on('error', reject);
68 worker.on('exit', resolve);
138 const worker = runWorker(1);
158 await Promise.all([worker, detached, contextEventPromises]);
164 let worker;
166 const exitPromise = runWorker(2, (w) => { worker = w; });
169 worker.postMessage('resume');
183 const worker = await new Promise((resolve, reject) => {
[all …]
|
| /third_party/node/doc/api/ |
| D | cluster.md | 33 cluster.on('exit', (worker, code, signal) => {
34 console.log(`worker ${worker.process.pid} died`);
62 cluster.on('exit', (worker, code, signal) => {
63 console.log(`worker ${worker.process.pid} died`);
88 On Windows, it is not yet possible to set up a named pipe server in a worker.
94 The worker processes are spawned using the [`child_process.fork()`][] method,
105 overloading a worker process.
119 Node.js process and a cluster worker differs:
123 handle passed to the worker, rather than listening to the worker's
126 the worker to use the supplied handle, rather than talk to the primary
[all …]
|
| /third_party/ltp/testcases/kernel/fs/read_all/ |
| 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() argument
213 tst_atomic_store(atomic_timestamp(), &workers[worker].last_seen); in worker_heartbeat()
216 static int worker_elapsed(const int worker) in worker_elapsed() argument
218 struct worker *const w = workers + worker; in worker_elapsed()
223 static int worker_ttl(const int worker) in worker_ttl() argument
225 return MAX(0, worker_timeout - worker_elapsed(worker)); in worker_ttl()
228 static void read_test(const int worker, const char *const path) in read_test() argument
233 const pid_t pid = workers[worker].pid; in read_test()
[all …]
|
| /third_party/node/test/internet/ |
| D | test-dgram-broadcast-multi-process.js | 81 const worker = fork(process.argv[1], ['child']);
82 workers[worker.pid] = worker;
84 worker.messagesReceived = [];
87 worker.on('exit', (code, signal) => {
91 if (worker.isDone || code === 0) {
97 worker.pid,
113 worker.on('message', (msg) => {
122 worker.messagesReceived.push(msg.message);
124 if (worker.messagesReceived.length === messages.length) {
126 worker.isDone = true;
[all …]
|
| D | test-dgram-multicast-multi-process.js | 46 const worker = fork(__filename, ['child']);
47 workers[worker.pid] = worker;
49 worker.messagesReceived = [];
52 worker.on('exit', function(code) {
55 if (worker.isDone || code === 0) {
61 worker.pid,
72 worker.on('message', function(msg) {
83 worker.messagesReceived.push(msg.message);
85 if (worker.messagesReceived.length === messages.length) {
87 worker.isDone = true;
[all …]
|
| D | test-dgram-multicast-set-interface-lo.js | 112 const worker = fork(process.argv[1], constant
118 workers[worker.pid] = worker;
120 worker.messagesReceived = [];
121 worker.messagesNeeded = messagesNeeded;
124 worker.on('exit', (code) => {
127 if (worker.isDone || code === 0) {
133 worker.pid,
147 worker.on('message', (msg) => {
156 worker.messagesReceived.push(msg.message);
158 if (worker.messagesReceived.length === worker.messagesNeeded.length) {
[all …]
|
| D | test-dgram-multicast-ssmv6-multi-process.js | 40 const worker = fork(__filename, ['child']);
41 workers[worker.pid] = worker;
43 worker.messagesReceived = [];
46 worker.on('exit', function(code) {
49 if (worker.isDone || code === 0) {
55 worker.pid,
66 worker.on('message', function(msg) {
77 worker.messagesReceived.push(msg.message);
79 if (worker.messagesReceived.length === messages.length) {
81 worker.isDone = true;
[all …]
|
| D | test-dgram-multicast-ssm-multi-process.js | 40 const worker = fork(__filename, ['child']);
41 workers[worker.pid] = worker;
43 worker.messagesReceived = [];
46 worker.on('exit', function(code) {
49 if (worker.isDone || code === 0) {
55 worker.pid,
66 worker.on('message', function(msg) {
77 worker.messagesReceived.push(msg.message);
79 if (worker.messagesReceived.length === messages.length) {
81 worker.isDone = true;
[all …]
|
| /third_party/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 …]
|
| /third_party/libuv/docs/code/multi-echo-server/ |
| D | main.c | 42 struct child_worker *worker = &workers[round_robin_counter]; in on_new_connection() local
43 … uv_write2(write_req, (uv_stream_t*) &worker->pipe, &dummy_buf, 1, (uv_stream_t*) client, NULL); in on_new_connection()
75 struct child_worker *worker = &workers[cpu_count]; in setup_workers() local
76 uv_pipe_init(loop, &worker->pipe, 1); in setup_workers()
80 child_stdio[0].data.stream = (uv_stream_t*) &worker->pipe; in setup_workers()
85 worker->options.stdio = child_stdio; in setup_workers()
86 worker->options.stdio_count = 3; in setup_workers()
88 worker->options.exit_cb = close_process_handle; in setup_workers()
89 worker->options.file = args[0]; in setup_workers()
90 worker->options.args = args; in setup_workers()
[all …]
|
| /third_party/nghttp2/src/ |
| D | h2load.cc | 217 client->worker->free_client(client); in writecb()
225 client->worker->free_client(client); in writecb()
239 client->worker->free_client(client); in readcb()
250 auto worker = static_cast<Worker *>(w->data); in rate_period_timeout_w_cb() local
251 auto nclients_per_second = worker->rate; in rate_period_timeout_w_cb()
252 auto conns_remaining = worker->nclients - worker->nconns_made; in rate_period_timeout_w_cb()
256 auto req_todo = worker->nreqs_per_client; in rate_period_timeout_w_cb()
257 if (worker->nreqs_rem > 0) { in rate_period_timeout_w_cb()
259 --worker->nreqs_rem; in rate_period_timeout_w_cb()
262 std::make_unique<Client>(worker->next_client_id++, worker, req_todo); in rate_period_timeout_w_cb()
[all …]
|
| /third_party/node/benchmark/worker/ |
| D | bench-eventlooputil.js | 32 const worker = new Worker(__filename, { argv: ['idle cats'] });
34 spinUntilIdle(worker, () => {
37 worker.performance.eventLoopUtilization();
39 worker.postMessage('bye');
44 const worker = new Worker(__filename, { argv: ['idle cats'] });
46 spinUntilIdle(worker, () => {
47 let elu = worker.performance.eventLoopUtilization();
50 elu = worker.performance.eventLoopUtilization(elu);
52 worker.postMessage('bye');
|
| /third_party/node/test/known_issues/ |
| D | test-inspector-cluster-port-clash.js | 30 const worker = cluster.fork();
31 worker.on('error', (err) => assert.fail(err));
33 worker.on('online', () => {
34 worker.on('message', common.mustCall((message) => {
38 worker.on('exit', common.mustCall((code, signal) => {
42 return assert.fail(`worker ${worker.id} failed to bind port`);
46 worker.on('disconnect', common.mustCall(res));
51 cluster.on('online', common.mustCall((worker) => worker.send('dbgport'), 2));
|
| /third_party/node/test/addons/no-addons/ |
| D | test-worker.js | 22 const worker = new Worker(`require(${JSON.stringify(binding)})`, { constant
26 worker.on('error', common.mustCall(assertError));
31 const worker = new Worker( constant
38 worker.on('error', common.mustCall(assertError));
43 const worker = new Worker(`require(${JSON.stringify(binding)})`, { constant
48 worker.on('error', common.mustCall(assertError));
53 const worker = new Worker(`require(${JSON.stringify(binding)})`, { constant
58 worker.on('error', common.mustCall(assertError));
|