HomeSort by: relevance | last modified time | path
    Searched defs:worker (Results 1 - 25 of 25) sorted by relevancy

  /src/sys/external/bsd/drm2/dist/drm/i915/gt/uc/
intel_guc_ct.h 60 struct work_struct worker; /* handler for incoming requests */ member in struct:intel_guc_ct::__anon5003
  /src/sys/external/bsd/drm2/dist/include/drm/
drm_flip_work.h 72 * @worker: worker which calls @func
80 struct work_struct worker; member in struct:drm_flip_work
  /src/usr.sbin/npf/npftest/libnpftest/
npf_perf_test.c 28 worker(void *arg) function
71 KTHREAD_MPSAFE, NULL, worker, (void *)(uintptr_t)i,
  /src/tests/rump/rumpkern/h_client/
h_reconcli.c 52 worker(void *arg) function
106 pthread_create(&w1, NULL, worker, NULL);
107 pthread_create(&w2, NULL, worker, NULL);
108 pthread_create(&w3, NULL, worker, NULL);
109 pthread_create(&w4, NULL, worker, NULL);
  /src/external/bsd/zstd/dist/lib/common/
threading.c 45 static unsigned __stdcall worker(void *arg) function
95 *thread = (HANDLE)_beginthreadex(NULL, 0, worker, &thread_param, 0, NULL);
  /src/sys/net/npf/
npf_worker.c 53 lwp_t * worker[]; member in struct:npf_worker
63 #define WFLAG_INITED 0x02 // worker setup the instance
72 const size_t len = offsetof(npf_workerinfo_t, worker[nworkers]);
91 NULL, npf_worker, winfo, &winfo->worker[i], "npfgc%u", i)) {
118 lwp_t *worker; local
120 if ((worker = winfo->worker[i]) != NULL) {
121 kthread_join(worker);
127 kmem_free(winfo, offsetof(npf_workerinfo_t, worker[nworkers]));
162 * npf_worker_enlist: add the NPF instance for worker(s) to process
    [all...]
  /src/external/bsd/iscsi/dist/include/
target.h 81 iscsi_worker_t worker; member in struct:target_session_t
  /src/external/bsd/unbound/dist/daemon/
worker.h 2 * daemon/worker.h - worker that handles a pending list of requests.
39 * This file describes the worker structure that holds a list of
46 #include "libunbound/worker.h"
66 /** worker commands */
68 /** make the worker quit */
80 /** for fast-reload, poll to make sure worker has released data */
88 struct worker { struct
99 /** pipe, for commands for this worker */
101 /** the event base this worker works with *
    [all...]
daemon.c 70 #include "daemon/worker.h"
187 * @param wrk: worker that handles signals.
190 signal_handling_playback(struct worker* wrk)
451 daemon->env->worker = NULL;
467 daemon->env->worker = NULL;
512 * Clear and delete per-worker alloc caches, and free memory maintained in
536 * Allocate empty worker structures. With backptr and thread-number,
573 daemon->workers = (struct worker**)calloc((size_t)daemon->num,
574 sizeof(struct worker*));
591 fatal_exit("could not create worker");
642 struct worker* worker = (struct worker*)arg; local
    [all...]
remote.h 55 struct worker;
92 /** the worker for this remote control */
93 struct worker* worker; member in struct:daemon_remote
174 /** the worker that the event is added in */
175 struct worker* worker; member in struct:fast_reload_printq
220 /** the event that listens on the remote service worker to the
223 /** if the event that listens on the remote service worker has
231 /** the worker that the service_event is added in *
232 struct worker* worker; member in struct:fast_reload_thread
    [all...]
cachedump.c 46 #include "daemon/worker.h"
254 /** The worker. */
255 struct worker* worker; member in struct:dump_info
269 *dump_info->worker->env.now);
275 dump_rrset_cache(RES* ssl, struct worker* worker)
277 struct rrset_cache* r = worker->env.rrset_cache;
279 dump_info.worker = worker;
    [all...]
worker.c 2 * daemon/worker.c - worker that handles a pending list of requests.
39 * This file implements the worker that handles callbacks on events, for
46 #include "daemon/worker.h"
117 worker_mem_report(struct worker* ATTR_UNUSED(worker),
132 front = listen_get_mem(worker->front);
133 back = outnet_get_mem(worker->back);
134 msg = slabhash_get_mem(worker->env.msg_cache);
135 rrset = slabhash_get_mem(&worker->env.rrset_cache->table)
248 struct worker* worker = e->qstate->env->worker; local
456 struct worker* worker = (struct worker*)arg; local
1451 struct worker* worker = (struct worker*)arg; local
2073 struct worker* worker = (struct worker*)arg; local
2119 struct worker* worker = (struct worker*)arg; local
2136 struct worker* worker = (struct worker*)arg; local
2150 struct worker* worker = (struct worker*)calloc(1, local
2462 struct worker* worker = q->env->worker; local
2482 struct worker* worker = (struct worker*)arg; local
2498 struct worker* worker = (struct worker*)arg; local
2506 struct worker* worker = (struct worker*)arg; local
    [all...]
remote.c 61 #include "daemon/worker.h"
250 rc->worker = NULL;
409 n->com = comm_point_create_raw(rc->worker->base, fd, 0,
419 struct listen_port* ports, struct worker* worker)
422 rc->worker = worker;
480 n->c = comm_point_create_raw(rc->worker->base, newfd, 0,
685 for(i=1; i<rc->worker->daemon->num; i++) {
686 worker_send_cmd(rc->worker->daemon->workers[i]
1754 struct worker* worker; member in struct:cache_lookup_info
2179 struct worker* worker; member in struct:del_info
7143 struct worker* worker = fr->worker; local
7797 struct worker* worker = fr->worker; local
7829 struct worker* worker = fast_reload_thread->worker; local
8240 struct worker* worker = fast_reload_thread->worker; local
    [all...]
  /src/usr.sbin/nfsd/
nfsd.c 123 worker(void *dummy) function
530 error = pthread_create(&workers[i], NULL, worker, NULL);
  /src/external/bsd/unbound/dist/winrc/
win_svc.c 50 #include "daemon/worker.h"
462 * should get registered in the worker-0 waiting loop. */
547 struct worker* worker = (struct worker*)arg; local
549 worker->need_to_exit = 1;
550 comm_base_exit(worker->base);
626 struct worker* worker = (struct worker*)arg local
    [all...]
  /src/sbin/dump/
tape.c 83 * are exported to several worker processes. While one worker writes the
95 #define WORKERS 3 /* 1 worker writing, 1 reading, 1 for slack */
96 struct worker { struct
102 int fd; /* FD for this worker */
103 int pid; /* PID for this worker */
104 int sent; /* 1 == we've sent this worker requests */
108 struct worker *wp;
295 /* Read results back from next worker */
460 struct worker *twp
    [all...]
  /src/sys/external/bsd/drm2/dist/drm/nouveau/
nouveau_drv.h 115 struct list_head worker; member in struct:nouveau_cli
  /src/external/bsd/unbound/dist/services/
authzone.h 58 struct worker;
123 /** the zone has expired (enabled by the xfer worker), fallback
140 /** store the env (worker thread specific) for the zonemd callbacks
142 * worker has already picked up the zonemd verification task and
143 * this worker does not have to do it as well. */
194 * owner by a worker (worker-num). A worker can pick up a task and then do
195 * it. This means the events (timeouts, sockets) are for that worker.
198 * They don't have locks themselves, the worker (that owns it) uses it
299 struct worker* worker; member in struct:auth_nextprobe
325 struct worker* worker; member in struct:auth_probe
373 struct worker* worker; member in struct:auth_transfer
    [all...]
  /src/external/bsd/unbound/dist/util/
module.h 168 struct worker;
486 /** internal data for daemon - worker thread. */
487 struct worker* worker; member in struct:module_env
488 /** the worker event base */
  /src/external/gpl3/gcc.old/dist/gcc/
omp-offload.cc 534 operate on adjacent iterations. At the worker and gang level,
943 { "gang", "worker", "vector" };
981 vector_length, however the worker- or vector- single
1177 const char *worker local
1178 = loop->mask & GOMP_DIM_MASK (GOMP_DIM_WORKER) ? " worker" : "";
1185 "assigned OpenACC%s%s%s%s loop parallelism\n", gang, worker,
1569 that we put worker there. The std doesn't contemplate
1570 specifying all three. We choose to put worker and vector on
2229 { "gang", "worker", "vector" };
2332 Eventually (in particular, for worker-private level?), bot
    [all...]
tree-predcom.cc 2494 pcom_worker *worker; member in struct:epcc_data
2501 pcom_worker *worker = dta->worker; local
2507 worker->execute_pred_commoning (dta->tmp_vars);
3436 dta.worker = this;
  /src/external/gpl3/gcc.old/dist/libgomp/plugin/
plugin-nvptx.c 781 int gang, worker, vector; local
791 worker = block_size / warp_size;
801 /* The worker size must not exceed the hardware. */
803 || (default_dims[GOMP_DIM_WORKER] > worker && gang))
804 default_dims[GOMP_DIM_WORKER] = worker;
883 /* If we need a per-worker barrier ... . */
  /src/external/gpl3/gcc.old/dist/gcc/config/nvptx/
nvptx.cc 149 used for both worker-neutering and worker broadcasting, and
159 /* Buffer needed for worker reductions. This has to be distinct from
160 the worker broadcast array, as both may be live concurrently. */
166 PTX_WARP_SIZE. This has to be distinct from the worker broadcast
179 /* Global lock variable, needed for 128bit worker & gang reductions. */
1335 /* Emit code to initialize OpenACC worker broadcast and synchronization
2102 /* Structure used when generating a worker-level spill or fill. */
2108 unsigned offset; /* Offset into worker buffer. */
2124 worker broadcast array. PM indicates what is to be done, RE
3629 bool worker = mask & GOMP_DIM_MASK (GOMP_DIM_WORKER); local
5008 bool worker = (GOMP_DIM_MASK (GOMP_DIM_WORKER) == mask) != 0; local
5163 bool worker = (par->mask & GOMP_DIM_MASK (GOMP_DIM_WORKER)); local
    [all...]
  /src/external/gpl3/gcc.old/dist/gcc/config/sh/
sh.cc 4868 rtx_insn *worker = mova;
4874 worker = NEXT_INSN (worker);
4875 gcc_assert (worker
4876 && !LABEL_P (worker)
4877 && !JUMP_P (worker));
4878 } while (NOTE_P (worker)
4879 || recog_memoized (worker) != CODE_FOR_casesi_worker_1);
4880 wpat = PATTERN (worker);
4884 PATTERN (worker) = (gen_casesi_worker_
4858 rtx_insn *worker = mova; local
    [all...]
  /src/external/gpl3/gcc.old/dist/gcc/fortran/
gfortran.h 1559 unsigned async:1, gang:1, worker:1, vector:1, seq:1, independent:1; member in struct:gfc_omp_clauses

Completed in 65 milliseconds