/netbsd-current/external/bsd/unbound/dist/daemon/ |
H A D | cachedump.h | 74 struct worker; 80 * @param worker: worker that is available (buffers, etc) and has 84 int dump_cache(RES* ssl, struct worker* worker); 89 * @param worker: worker that is available (buffers, etc) and has 93 int load_cache(RES* ssl, struct worker* worker); 98 * @param worker [all...] |
H A D | stats.h | 46 struct worker; 64 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker); 67 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker); 70 void server_stats_log(struct ub_server_stats* stats, struct worker* worker, 75 * @param worker: the worker that is executing (the first worker) [all...] |
H A D | 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 233 worker_send_cmd(struct worker* worker, enum worker_commands cmd) argument 246 struct worker* worker = e->qstate->env->worker; local 279 worker_err_ratelimit(struct worker* worker, int err) argument 308 worker_check_request(sldns_buffer* pkt, struct worker* worker, struct check_request_result* out) argument 376 struct worker* worker = (struct worker*)arg; local 463 answer_norec_from_cache(struct worker* worker, struct query_info* qinfo, uint16_t id, uint16_t flags, struct comm_reply* repinfo, struct edns_data* edns) argument 586 apply_respip_action(struct worker* worker, const struct query_info* qinfo, struct respip_client_info* cinfo, struct reply_info* rep, struct sockaddr_storage* addr, socklen_t addrlen, struct ub_packed_rrset_key** alias_rrset, struct reply_info** encode_repp, struct auth_zones* az) argument 642 answer_from_cache(struct worker* worker, struct query_info* qinfo, struct respip_client_info* cinfo, int* need_drop, int* is_expired_answer, int* is_secure_answer, struct ub_packed_rrset_key** alias_rrset, struct reply_info** partial_repp, struct reply_info* rep, uint16_t id, uint16_t flags, struct comm_reply* repinfo, struct edns_data* edns) argument 826 reply_and_prefetch(struct worker* worker, struct query_info* qinfo, uint16_t flags, struct comm_reply* repinfo, time_t leeway, int noreply, int rpz_passthru, struct edns_option* opt_list) argument 873 chaos_replystr(sldns_buffer* pkt, char** str, int num, struct edns_data* edns, struct worker* worker, struct comm_reply* repinfo) argument 924 chaos_replyonestr(sldns_buffer* pkt, const char* str, struct edns_data* edns, struct worker* worker, struct comm_reply* repinfo) argument 1110 deny_refuse(struct comm_point* c, enum acl_access acl, enum acl_access deny, enum acl_access refuse, struct worker* worker, struct comm_reply* repinfo, struct acl_addr* acladdr, int ede, struct check_request_result* check_result) argument 1298 deny_refuse_all(struct comm_point* c, enum acl_access* acl, struct worker* worker, struct comm_reply* repinfo, struct acl_addr** acladdr, int ede, int check_proxy, struct check_request_result* check_result) argument 1320 deny_refuse_non_local(struct comm_point* c, enum acl_access acl, struct worker* worker, struct comm_reply* repinfo, struct acl_addr* acladdr, int ede, struct check_request_result* check_result) argument 1341 check_ip_ratelimit(struct worker* worker, struct sockaddr_storage* addr, socklen_t addrlen, int has_cookie, sldns_buffer* pkt) argument 1367 struct worker* worker = (struct worker*)arg; local 1989 struct worker* worker = (struct worker*)arg; local 2021 worker_restart_timer(struct worker* worker) argument 2035 struct worker* worker = (struct worker*)arg; local 2052 struct worker* worker = (struct worker*)arg; local 2066 struct worker* worker = (struct worker*)calloc(1, local 2096 worker_init(struct worker* worker, struct config_file *cfg, struct listen_port* ports, int do_sigs) argument 2332 worker_work(struct worker* worker) argument 2338 worker_delete(struct worker* worker) argument 2389 struct worker* worker = q->env->worker; local 2409 struct worker* worker = (struct worker*)arg; local 2414 worker_stats_clear(struct worker* worker) argument 2425 struct worker* worker = (struct worker*)arg; local 2433 struct worker* worker = (struct worker*)arg; local [all...] |
H A D | 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 */ 82 struct worker { struct 93 /** pipe, for commands for this worker */ 95 /** the event base this worker works with */ 101 /** ports to be used by this worker [all...] |
H A D | remote.h | 54 struct worker; 90 /** the worker for this remote control */ 91 struct worker* worker; member in struct:daemon_remote 153 * @param worker: worker with communication base. and links to command channels. 157 struct listen_port* ports, struct worker* worker); 173 * @param worker: this worker (th [all...] |
H A D | stats.c | 49 #include "daemon/worker.h" 96 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker) argument 99 stats->sum_query_list_size += worker->env.mesh->all.count; 100 if((long long)worker->env.mesh->all.count > stats->max_query_list_size) 101 stats->max_query_list_size = (long long)worker->env.mesh->all.count; 104 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) argument 108 stats->sum_query_list_size += worker->env.mesh->all.count; 109 if((long long)worker 113 server_stats_log(struct ub_server_stats* stats, struct worker* worker, int threadnum) argument 140 set_subnet_stats(struct worker* worker, struct ub_server_stats* svr, int reset) argument 165 set_neg_cache_stats(struct worker* worker, struct ub_server_stats* svr, int reset) argument 189 get_rrset_bogus(struct worker* worker, int reset) argument 207 get_queries_ratelimit(struct worker* worker, int reset) argument 226 get_dnscrypt_cache_miss(struct worker* worker, int reset) argument 242 get_dnscrypt_replay(struct worker* worker, int reset) argument 257 server_stats_compile(struct worker* worker, struct ub_stats_info* s, int reset) argument 377 server_stats_obtain(struct worker* worker, struct worker* who, struct ub_stats_info* s, int reset) argument 424 server_stats_reply(struct worker* worker, int reset) argument [all...] |
H A D | cachedump.c | 46 #include "daemon/worker.h" 123 dump_rrset_cache(RES* ssl, struct worker* worker) argument 125 struct rrset_cache* r = worker->env.rrset_cache; 131 *worker->env.now)) { 224 /** copy msg to worker pad */ 252 dump_msg_lruhash(RES* ssl, struct worker* worker, struct lruhash* h) argument 261 regional_free_all(worker->scratchpad); 263 /* make copy of rrset in worker buffe 280 dump_msg_cache(RES* ssl, struct worker* worker) argument 297 dump_cache(RES* ssl, struct worker* worker) argument 382 move_into_cache(struct ub_packed_rrset_key* k, struct packed_rrset_data* d, struct worker* worker) argument 442 load_rrset(RES* ssl, sldns_buffer* buf, struct worker* worker) argument 526 load_rrset_cache(RES* ssl, struct worker* worker) argument 582 load_ref(RES* ssl, sldns_buffer* buf, struct worker* worker, struct regional *region, struct ub_packed_rrset_key** rrset, int* go_on) argument 627 load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker) argument 704 load_msg_cache(RES* ssl, struct worker* worker) argument 717 load_cache(RES* ssl, struct worker* worker) argument 728 print_dp_details(RES* ssl, struct worker* worker, struct delegpt* dp) argument 832 print_deleg_lookup(RES* ssl, struct worker* worker, uint8_t* nm, size_t nmlen, int ATTR_UNUSED(nmlabs)) argument [all...] |
H A D | remote.c | 58 #include "daemon/worker.h" 214 rc->worker = NULL; 373 n->com = comm_point_create_raw(rc->worker->base, fd, 0, 383 struct listen_port* ports, struct worker* worker) 386 rc->worker = worker; 444 n->c = comm_point_create_raw(rc->worker->base, newfd, 0, 638 do_stop(RES* ssl, struct worker* worker) argument 382 daemon_remote_open_accept(struct daemon_remote* rc, struct listen_port* ports, struct worker* worker) argument 647 do_reload(RES* ssl, struct worker* worker, int reuse_cache) argument 764 print_mem(RES* ssl, struct worker* worker, struct daemon* daemon, struct ub_stats_info* s) argument 847 print_uptime(RES* ssl, struct worker* worker, int reset) argument 1084 do_stats(RES* ssl, struct worker* worker, int reset) argument 1395 do_view_zone_add(RES* ssl, struct worker* worker, char* arg) argument 1428 do_view_zone_remove(RES* ssl, struct worker* worker, char* arg) argument 1451 do_view_data_add(RES* ssl, struct worker* worker, char* arg) argument 1476 do_view_datas_add(RES* ssl, struct worker* worker, char* arg) argument 1498 do_view_data_remove(RES* ssl, struct worker* worker, char* arg) argument 1521 do_view_datas_remove(RES* ssl, struct worker* worker, char* arg) argument 1542 do_lookup(RES* ssl, struct worker* worker, char* arg) argument 1555 do_cache_remove(struct worker* worker, uint8_t* nm, size_t nmlen, uint16_t t, uint16_t c) argument 1580 do_flush_type(RES* ssl, struct worker* worker, char* arg) argument 1603 do_flush_stats(RES* ssl, struct worker* worker) argument 1614 struct worker* worker; member in struct:del_info 1658 do_flush_infra(RES* ssl, struct worker* worker, char* arg) argument 1692 do_flush_requestlist(RES* ssl, struct worker* worker) argument 1751 do_flush_zone(RES* ssl, struct worker* worker, char* arg) argument 1829 do_flush_bogus(RES* ssl, struct worker* worker) argument 1904 do_flush_negative(RES* ssl, struct worker* worker) argument 2068 do_forward(RES* ssl, struct worker* worker, char* args) argument 2144 do_forward_add(RES* ssl, struct worker* worker, char* args) argument 2172 do_forward_remove(RES* ssl, struct worker* worker, char* args) argument 2189 do_stub_add(RES* ssl, struct worker* worker, char* args) argument 2230 do_stub_remove(RES* ssl, struct worker* worker, char* args) argument 2248 do_insecure_add(RES* ssl, struct worker* worker, char* arg) argument 2269 do_insecure_remove(RES* ssl, struct worker* worker, char* arg) argument 2284 do_insecure_list(RES* ssl, struct worker* worker) argument 2300 do_status(RES* ssl, struct worker* worker) argument 2408 do_dump_requestlist(RES* ssl, struct worker* worker) argument 2502 do_dump_infra(RES* ssl, struct worker* worker) argument 2514 do_log_reopen(RES* ssl, struct worker* worker) argument 2523 do_auth_zone_reload(RES* ssl, struct worker* worker, char* arg) argument 2602 do_auth_zone_transfer(RES* ssl, struct worker* worker, char* arg) argument 2622 do_set_option(RES* ssl, struct worker* worker, char* arg) argument 2651 do_get_option(RES* ssl, struct worker* worker, char* arg) argument 2663 do_list_forwards(RES* ssl, struct worker* worker) argument 2691 do_list_stubs(RES* ssl, struct worker* worker) argument 2771 do_list_local_data(RES* ssl, struct worker* worker, struct local_zones* zones) argument 2810 do_view_list_local_zones(RES* ssl, struct worker* worker, char* arg) argument 2826 do_view_list_local_data(RES* ssl, struct worker* worker, char* arg) argument 2894 do_ratelimit_list(RES* ssl, struct worker* worker, char* arg) argument 2913 do_ip_ratelimit_list(RES* ssl, struct worker* worker, char* arg) argument 2932 do_rpz_enable_disable(RES* ssl, struct worker* worker, char* arg, int enable) argument 2969 do_rpz_enable(RES* ssl, struct worker* worker, char* arg) argument 2976 do_rpz_disable(RES* ssl, struct worker* worker, char* arg) argument 3009 execute_cmd(struct daemon_remote* rc, RES* ssl, char* cmd, struct worker* worker) argument 3194 daemon_remote_exec(struct worker* worker) argument [all...] |
/netbsd-current/external/bsd/unbound/dist/winrc/ |
H A D | win_svc.h | 49 struct worker; 73 * Setup lead worker events. 74 * @param worker: the worker 76 void wsvc_setup_worker(struct worker* worker); 79 * Desetup lead worker events. 80 * @param worker: the worker 82 void wsvc_desetup_worker(struct worker* worke [all...] |
H A D | win_svc.c | 50 #include "daemon/worker.h" 432 * should get registered in the worker-0 waiting loop. */ 517 struct worker* worker = (struct worker*)arg; local 519 worker->need_to_exit = 1; 520 comm_base_exit(worker->base); 596 struct worker* worker = (struct worker*)ar local 607 wsvc_setup_worker(struct worker* worker) argument [all...] |
/netbsd-current/external/gpl3/gdb/dist/gdb/testsuite/gdb.base/ |
H A D | premature-dummy-frame-removal.c | 24 worker (void) function 35 worker ();
|
/netbsd-current/external/bsd/unbound/dist/util/shm_side/ |
H A D | shm_main.h | 45 struct worker; 66 void shm_main_run(struct worker *worker);
|
H A D | shm_main.c | 55 #include "daemon/worker.h" 224 void shm_main_run(struct worker *worker) argument 233 verbose(VERB_DETAIL, "SHM run - worker [%d] - daemon [%p] - timenow(%u) - timeboot(%u)", 234 worker->thread_num, worker->daemon, (unsigned)worker->env.now_tv->tv_sec, (unsigned)worker->daemon->time_boot.tv_sec); 237 offset = worker->thread_num + 1; 238 stat_total = worker [all...] |
/netbsd-current/external/mit/libuv/dist/docs/code/multi-echo-server/ |
H A D | main.c | 42 struct child_worker *worker = &workers[round_robin_counter]; local 43 uv_write2(write_req, (uv_stream_t*) &worker->pipe, &dummy_buf, 1, (uv_stream_t*) client, NULL); 54 strcpy(worker_path + (strlen(worker_path) - strlen("multi-echo-server")), "worker"); 75 struct child_worker *worker = &workers[cpu_count]; local 76 uv_pipe_init(loop, &worker->pipe, 1); 80 child_stdio[0].data.stream = (uv_stream_t*) &worker->pipe; 85 worker->options.stdio = child_stdio; 86 worker->options.stdio_count = 3; 88 worker->options.exit_cb = close_process_handle; 89 worker [all...] |
/netbsd-current/external/gpl3/gdb/dist/gdb/testsuite/gdb.server/ |
H A D | stop-reply-no-thread-multi.c | 44 worker (void *data) function 65 if (pthread_create (&thr, NULL, worker, NULL) != 0)
|
/netbsd-current/external/mpl/dhcp/bind/dist/lib/isc/netmgr/ |
H A D | netmgr.c | 154 process_netievent(isc__networker_t *worker, isc__netievent_t *ievent); 156 process_queue(isc__networker_t *worker, netievent_type_t type); 158 wait_for_priority_queue(isc__networker_t *worker); 160 drain_queue(isc__networker_t *worker, netievent_type_t type); 163 isc__nm_async_stop(isc__networker_t *worker, isc__netievent_t *ev0); 165 isc__nm_async_pause(isc__networker_t *worker, isc__netievent_t *ev0); 167 isc__nm_async_resume(isc__networker_t *worker, isc__netievent_t *ev0); 169 isc__nm_async_detach(isc__networker_t *worker, isc__netievent_t *ev0); 171 isc__nm_async_close(isc__networker_t *worker, isc__netievent_t *ev0); 330 isc__networker_t *worker local 387 isc__networker_t *worker = &mgr->workers[i]; local 399 isc__networker_t *worker = &mgr->workers[i]; local 439 enqueue_pause(isc__networker_t *worker) argument 446 isc__nm_async_pause(isc__networker_t *worker, isc__netievent_t *ev0) argument 466 isc__networker_t *worker = &mgr->workers[i]; local 490 enqueue_resume(isc__networker_t *worker) argument 497 isc__nm_async_resume(isc__networker_t *worker, isc__netievent_t *ev0) argument 515 isc__networker_t *worker = &mgr->workers[i]; local 715 isc__networker_t *worker = (isc__networker_t *)worker0; local 787 process_all_queues(isc__networker_t *worker) argument 823 isc__networker_t *worker = (isc__networker_t *)handle->loop->data; local 835 isc__nm_async_stop(isc__networker_t *worker, isc__netievent_t *ev0) argument 846 isc__networker_t *worker = NULL; local 877 isc__nm_async_task(isc__networker_t *worker, isc__netievent_t *ev0) argument 897 wait_for_priority_queue(isc__networker_t *worker) argument 913 drain_queue(isc__networker_t *worker, netievent_type_t type) argument 947 process_netievent(isc__networker_t *worker, isc__netievent_t *ievent) argument 1001 process_queue(isc__networker_t *worker, netievent_type_t type) argument 1101 isc__nm_maybe_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event) argument 1116 isc__nm_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event) argument 1542 isc__networker_t *worker = NULL; local 2099 isc__networker_t *worker = NULL; local 2576 isc__nm_async_connectcb(isc__networker_t *worker, isc__netievent_t *ev0) argument 2617 isc__nm_async_readcb(isc__networker_t *worker, isc__netievent_t *ev0) argument 2661 isc__nm_async_sendcb(isc__networker_t *worker, isc__netievent_t *ev0) argument 2680 isc__nm_async_close(isc__networker_t *worker, isc__netievent_t *ev0) argument 2694 isc__nm_async_detach(isc__networker_t *worker, isc__netievent_t *ev0) argument 2804 isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ev0) argument 3203 isc__networker_t *worker = NULL; local 3231 isc__networker_t *worker = NULL; local [all...] |
H A D | netmgr-int.h | 203 * Single network event loop worker. 681 * A worker is actively waiting for other workers, for example to 964 isc__nm_maybe_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event); 971 isc__nm_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event); 973 * Enqueue an ievent onto a specific worker queue. (This the only safe 1097 isc__nm_async_connectcb(isc__networker_t *worker, isc__netievent_t *ev0); 1106 isc__nm_async_readcb(isc__networker_t *worker, isc__netievent_t *ev0); 1118 isc__nm_async_sendcb(isc__networker_t *worker, isc__netievent_t *ev0); 1125 isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ev0); 1176 isc__nm_async_udplisten(isc__networker_t *worker, isc__netievent_ [all...] |
/netbsd-current/external/gpl3/gdb.old/dist/gdb/testsuite/gdb.mi/ |
H A D | non-stop.c | 31 worker (void *arg) function 61 if (pthread_create (&tid, NULL, worker, (void *) id2))
|
/netbsd-current/external/gpl3/gdb/dist/gdb/testsuite/gdb.mi/ |
H A D | non-stop.c | 31 worker (void *arg) function 61 if (pthread_create (&tid, NULL, worker, (void *) id2))
|
/netbsd-current/tests/rump/rumpkern/h_client/ |
H A D | 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);
|
/netbsd-current/external/mit/libuv/dist/docs/code/ |
H A D | Makefile | 49 all: $(examples) plugin/plugin proc-streams/test cgi/tick multi-echo-server/worker uvwget/uvwget 66 multi-echo-server/worker: multi-echo-server/worker.c 67 gcc $(CFLAGS) -o multi-echo-server/worker multi-echo-server/worker.c $(UV_LIB) $(LIBS) 79 rm -rf multi-echo-server/worker multi-echo-server/worker.dSYM
|
/netbsd-current/external/mit/libuv/dist/test/ |
H A D | test-semaphore.c | 36 static void worker(void* arg) { function 58 ASSERT(0 == uv_thread_create(&thread, worker, &wc)); 83 ASSERT(0 == uv_thread_create(&thread, worker, &wc));
|
H A D | test-barrier.c | 37 static void worker(void* arg) { function 54 ASSERT(0 == uv_thread_create(&thread, worker, &wc)); 76 ASSERT(0 == uv_thread_create(&thread, worker, &wc)); 96 ASSERT(0 == uv_thread_create(&thread, worker, &wc));
|
/netbsd-current/external/mpl/bind/dist/lib/isc/netmgr/ |
H A D | netmgr.c | 145 process_netievent(isc__networker_t *worker, isc__netievent_t *ievent); 147 process_queue(isc__networker_t *worker, netievent_type_t type); 149 wait_for_priority_queue(isc__networker_t *worker); 151 drain_queue(isc__networker_t *worker, netievent_type_t type); 154 isc__nm_async_stop(isc__networker_t *worker, isc__netievent_t *ev0); 156 isc__nm_async_pause(isc__networker_t *worker, isc__netievent_t *ev0); 158 isc__nm_async_resume(isc__networker_t *worker, isc__netievent_t *ev0); 160 isc__nm_async_detach(isc__networker_t *worker, isc__netievent_t *ev0); 162 isc__nm_async_close(isc__networker_t *worker, isc__netievent_t *ev0); 286 isc__networker_t *worker local 343 isc__networker_t *worker = &mgr->workers[i]; local 355 isc__networker_t *worker = &mgr->workers[i]; local 391 enqueue_pause(isc__networker_t *worker) argument 398 isc__nm_async_pause(isc__networker_t *worker, isc__netievent_t *ev0) argument 418 isc__networker_t *worker = &mgr->workers[i]; local 441 enqueue_resume(isc__networker_t *worker) argument 448 isc__nm_async_resume(isc__networker_t *worker, isc__netievent_t *ev0) argument 466 isc__networker_t *worker = &mgr->workers[i]; local 692 isc__networker_t *worker = (isc__networker_t *)worker0; local 764 process_all_queues(isc__networker_t *worker) argument 800 isc__networker_t *worker = (isc__networker_t *)handle->loop->data; local 812 isc__nm_async_stop(isc__networker_t *worker, isc__netievent_t *ev0) argument 823 isc__networker_t *worker = NULL; local 854 isc__nm_async_task(isc__networker_t *worker, isc__netievent_t *ev0) argument 884 wait_for_priority_queue(isc__networker_t *worker) argument 900 drain_queue(isc__networker_t *worker, netievent_type_t type) argument 934 process_netievent(isc__networker_t *worker, isc__netievent_t *ievent) argument 1015 process_queue(isc__networker_t *worker, netievent_type_t type) argument 1142 isc__nm_maybe_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event) argument 1157 isc__nm_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event) argument 1641 isc__networker_t *worker = NULL; local 2224 isc__networker_t *worker = NULL; local 2776 isc__networker_t *worker = &listener->mgr->workers[i]; local 2801 isc__nm_async_sockstop(isc__networker_t *worker, isc__netievent_t *ev0) argument 2856 isc__nm_async_connectcb(isc__networker_t *worker, isc__netievent_t *ev0) argument 2897 isc__nm_async_readcb(isc__networker_t *worker, isc__netievent_t *ev0) argument 2941 isc__nm_async_sendcb(isc__networker_t *worker, isc__netievent_t *ev0) argument 2960 isc__nm_async_close(isc__networker_t *worker, isc__netievent_t *ev0) argument 2974 isc__nm_async_detach(isc__networker_t *worker, isc__netievent_t *ev0) argument 3091 isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ev0) argument 3587 isc__networker_t *worker = NULL; local 3774 isc__nm_async_settlsctx(isc__networker_t *worker, isc__netievent_t *ev0) argument [all...] |
/netbsd-current/sys/net/npf/ |
H A D | 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( [all...] |