| /openbsd/src/usr.sbin/unbound/daemon/ |
| D | worker.c | 117 worker_mem_report(struct worker* ATTR_UNUSED(worker), in worker_mem_report() argument
132 front = listen_get_mem(worker->front); in worker_mem_report()
133 back = outnet_get_mem(worker->back); in worker_mem_report()
134 msg = slabhash_get_mem(worker->env.msg_cache); in worker_mem_report()
135 rrset = slabhash_get_mem(&worker->env.rrset_cache->table); in worker_mem_report()
136 infra = infra_get_mem(worker->env.infra_cache); in worker_mem_report()
137 mesh = mesh_get_mem(worker->env.mesh); in worker_mem_report()
138 ac = alloc_get_mem(worker->alloc); in worker_mem_report()
139 superac = alloc_get_mem(&worker->daemon->superalloc); in worker_mem_report()
140 anch = anchors_get_mem(worker->env.anchors); in worker_mem_report()
[all …]
|
| D | stats.c | 96 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker) in server_stats_querymiss() argument
99 stats->sum_query_list_size += worker->env.mesh->all.count; in server_stats_querymiss()
100 if((long long)worker->env.mesh->all.count > stats->max_query_list_size) in server_stats_querymiss()
101 stats->max_query_list_size = (long long)worker->env.mesh->all.count; in server_stats_querymiss()
104 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) in server_stats_prefetch() argument
108 stats->sum_query_list_size += worker->env.mesh->all.count; in server_stats_prefetch()
109 if((long long)worker->env.mesh->all.count > stats->max_query_list_size) in server_stats_prefetch()
110 stats->max_query_list_size = (long long)worker->env.mesh->all.count; in server_stats_prefetch()
113 void server_stats_log(struct ub_server_stats* stats, struct worker* worker, in server_stats_log() argument
132 (unsigned)worker->env.mesh->stats_dropped, in server_stats_log()
[all …]
|
| D | remote.c | 222 rc->worker = NULL; in daemon_remote_clear()
381 n->com = comm_point_create_raw(rc->worker->base, fd, 0, in accept_open()
391 struct listen_port* ports, struct worker* worker) in daemon_remote_open_accept() argument
394 rc->worker = worker; in daemon_remote_open_accept()
452 n->c = comm_point_create_raw(rc->worker->base, newfd, 0, in remote_accept_callback()
652 for(i=1; i<rc->worker->daemon->num; i++) { in distribute_cmd()
653 worker_send_cmd(rc->worker->daemon->workers[i], in distribute_cmd()
655 if(!tube_write_msg(rc->worker->daemon->workers[i]->cmd, in distribute_cmd()
665 do_stop(RES* ssl, struct worker* worker) in do_stop() argument
667 worker->need_to_exit = 1; in do_stop()
[all …]
|
| 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,
80 void server_stats_obtain(struct worker* worker, struct worker* who,
91 void server_stats_compile(struct worker* worker, struct ub_stats_info* s,
100 void server_stats_reply(struct worker* worker, int reset);
|
| D | cachedump.c | 123 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache() argument
125 struct rrset_cache* r = worker->env.rrset_cache; in dump_rrset_cache()
131 *worker->env.now)) { in dump_rrset_cache()
252 dump_msg_lruhash(RES* ssl, struct worker* worker, struct lruhash* h) in dump_msg_lruhash() argument
261 regional_free_all(worker->scratchpad); in dump_msg_lruhash()
264 if(!copy_msg(worker->scratchpad, e, &k, &d)) { in dump_msg_lruhash()
271 if(!dump_msg(ssl, k, d, *worker->env.now)) { in dump_msg_lruhash()
280 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache() argument
282 struct slabhash* sh = worker->env.msg_cache; in dump_msg_cache()
287 if(!dump_msg_lruhash(ssl, worker, sh->array[slab])) { in dump_msg_cache()
[all …]
|
| D | worker.h | 82 struct worker { struct
147 struct worker* worker_create(struct daemon* daemon, int id, int* ports, int n);
158 int worker_init(struct worker* worker, struct config_file *cfg,
164 void worker_work(struct worker* worker);
169 void worker_delete(struct worker* worker);
176 void worker_send_cmd(struct worker* worker, enum worker_commands cmd);
182 void worker_stats_clear(struct worker* worker);
|
| D | cachedump.h | 74 struct worker;
84 int dump_cache(RES* ssl, struct worker* worker);
93 int load_cache(RES* ssl, struct worker* worker);
105 int print_deleg_lookup(RES* ssl, struct worker* worker, uint8_t* nm,
|
| D | remote.h | 54 struct worker;
91 struct worker* worker; member
157 struct listen_port* ports, struct worker* worker);
175 void daemon_remote_exec(struct worker* worker);
|
| D | daemon.c | 190 signal_handling_playback(struct worker* wrk) in signal_handling_playback()
452 daemon->env->worker = NULL; in daemon_privileged()
468 daemon->env->worker = NULL; in daemon_setup_modules()
568 daemon->workers = (struct worker**)calloc((size_t)daemon->num, in daemon_create_workers()
569 sizeof(struct worker*)); in daemon_create_workers()
637 struct worker* worker = (struct worker*)arg; in thread_start() local
639 log_thread_set(&worker->thread_num); in thread_start()
643 tube_close_write(worker->cmd); in thread_start()
644 close_other_pipes(worker->daemon, worker->thread_num); in thread_start()
647 if(worker->daemon->cfg->so_reuseport) in thread_start()
[all …]
|
| D | daemon.h | 49 struct worker;
106 struct worker** workers;
|
| /openbsd/src/usr.sbin/unbound/util/shm_side/ |
| D | shm_main.c | 224 void shm_main_run(struct worker *worker) in shm_main_run() argument
234 …worker->thread_num, worker->daemon, (unsigned)worker->env.now_tv->tv_sec, (unsigned)worker->daemon… in shm_main_run()
237 offset = worker->thread_num + 1; in shm_main_run()
238 stat_total = worker->daemon->shm_info->ptr_arr; in shm_main_run()
239 stat_info = worker->daemon->shm_info->ptr_arr + offset; in shm_main_run()
242 server_stats_compile(worker, stat_info, 0); in shm_main_run()
245 if (worker->thread_num == 0) { in shm_main_run()
252 shm_stat = worker->daemon->shm_info->ptr_ctl; in shm_main_run()
253 shm_stat->time.now_sec = (long long)worker->env.now_tv->tv_sec; in shm_main_run()
254 shm_stat->time.now_usec = (long long)worker->env.now_tv->tv_usec; in shm_main_run()
[all …]
|
| D | shm_main.h | 45 struct worker;
66 void shm_main_run(struct worker *worker);
|
| /openbsd/src/sbin/unwind/libunbound/daemon/ |
| 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,
80 void server_stats_obtain(struct worker* worker, struct worker* who,
91 void server_stats_compile(struct worker* worker, struct ub_stats_info* s,
100 void server_stats_reply(struct worker* worker, int reset);
|
| D | worker.h | 82 struct worker { struct
147 struct worker* worker_create(struct daemon* daemon, int id, int* ports, int n);
158 int worker_init(struct worker* worker, struct config_file *cfg,
164 void worker_work(struct worker* worker);
169 void worker_delete(struct worker* worker);
176 void worker_send_cmd(struct worker* worker, enum worker_commands cmd);
182 void worker_stats_clear(struct worker* worker);
|
| /openbsd/src/gnu/lib/libstdc++/libstdc++/testsuite/thread/ |
| D | pthread5.cc | 93 int worker; in main() local
108 for (worker = 0; worker < NTHREADS; worker++) in main()
110 ids[worker] = worker; in main()
111 if (pthread_create(&threads[worker], &tattr, in main()
112 thread_function, &ids[worker])) in main()
116 for (worker = 0; worker < NTHREADS; worker++) in main()
118 if (pthread_join(threads[worker], static_cast<void **>(&status))) in main()
121 if (*((int *)status) != worker) in main()
|
| /openbsd/src/sys/dev/pci/drm/ |
| D | drm_vblank_work.c | 62 kthread_queue_work(vblank->worker, &work->base); in drm_handle_vblank_works()
152 ret = kthread_queue_work(vblank->worker, &work->base); in drm_vblank_work_schedule()
255 kthread_flush_worker(vblank->worker); in drm_vblank_work_flush_all()
278 struct kthread_worker *worker; in drm_vblank_worker_init() local
282 worker = kthread_create_worker(0, "card%d-crtc%d", in drm_vblank_worker_init()
285 if (IS_ERR(worker)) in drm_vblank_worker_init()
286 return PTR_ERR(worker); in drm_vblank_worker_init()
288 vblank->worker = worker; in drm_vblank_worker_init()
291 sched_set_fifo(worker->task); in drm_vblank_worker_init()
|
| D | drm_flip_work.c | 97 queue_work(wq, &work->worker); in drm_flip_work_commit()
103 struct drm_flip_work *work = container_of(w, struct drm_flip_work, worker); in flip_worker()
143 INIT_WORK(&work->worker, flip_worker); in drm_flip_work_init()
|
| /openbsd/src/gnu/llvm/llvm/docs/ |
| D | HowToAddABuilder.rst | 9 buildbot-worker to private worker builder to LLVM Buildbot Infrastructure.
70 #. Install buildbot-worker (currently we are using buildbot version 2.8.5).
71 Depending on the platform, buildbot-worker could be available to download and
75 #. Create a designated user account, your buildbot-worker will be running under,
78 #. Choose the buildbot-worker root directory (all builds will be placed under
79 it), buildbot-worker access name and password the build master will be using
80 to authenticate your buildbot-worker.
82 #. Create a buildbot-worker in context of that buildbot-worker account. Point it
84 Creating a worker
85 <http://docs.buildbot.net/current/tutorial/firstrun.html#creating-a-worker>`_
[all …]
|
| /openbsd/src/usr.sbin/unbound/services/ |
| D | authzone.h | 58 struct worker;
296 struct worker* worker; member
322 struct worker* worker; member
370 struct worker* worker; member
|
| /openbsd/src/sbin/unwind/libunbound/services/ |
| D | authzone.h | 58 struct worker;
296 struct worker* worker; member
322 struct worker* worker; member
370 struct worker* worker; member
|
| /openbsd/src/usr.sbin/unbound/testcode/ |
| D | testbound.c | 519 struct listen_port* ATTR_UNUSED(ports), struct worker* worker) in daemon_remote_open_accept() argument
521 struct replay_runtime* runtime = (struct replay_runtime*)worker->base; in daemon_remote_open_accept()
522 runtime->daemon = worker->daemon; in daemon_remote_open_accept()
557 void wsvc_setup_worker(struct worker* ATTR_UNUSED(worker)) in wsvc_setup_worker() argument
564 void wsvc_desetup_worker(struct worker* ATTR_UNUSED(worker)) in wsvc_desetup_worker() argument
|
| /openbsd/src/sys/dev/pci/drm/i915/gt/ |
| D | selftest_slpc.c | 20 struct kthread_worker *worker; member
492 threads[i].worker = kthread_create_worker(0, "igt/slpc_parallel:%d", gt->info.id); in live_slpc_tile_interaction()
494 if (IS_ERR(threads[i].worker)) { in live_slpc_tile_interaction()
495 ret = PTR_ERR(threads[i].worker); in live_slpc_tile_interaction()
501 kthread_queue_work(threads[i].worker, &threads[i].work); in live_slpc_tile_interaction()
507 if (IS_ERR_OR_NULL(threads[i].worker)) in live_slpc_tile_interaction()
516 kthread_destroy_worker(threads[i].worker); in live_slpc_tile_interaction()
|
| /openbsd/src/sys/dev/pci/drm/i915/selftests/ |
| D | i915_request.c | 303 struct kthread_worker *worker; member
493 struct kthread_worker *worker; in mock_breadcrumbs_smoketest() local
495 worker = kthread_create_worker(0, "igt/%d", n); in mock_breadcrumbs_smoketest()
496 if (IS_ERR(worker)) { in mock_breadcrumbs_smoketest()
497 ret = PTR_ERR(worker); in mock_breadcrumbs_smoketest()
502 threads[n].worker = worker; in mock_breadcrumbs_smoketest()
509 kthread_queue_work(worker, &threads[n].work); in mock_breadcrumbs_smoketest()
523 kthread_destroy_worker(threads[n].worker); in mock_breadcrumbs_smoketest()
1458 struct kthread_worker *worker; member
1646 struct kthread_worker *worker; in live_parallel_engines() local
[all …]
|
| /openbsd/src/gnu/llvm/llvm/utils/lit/lit/ |
| D | run.py | 7 import lit.worker
69 pool = multiprocessing.Pool(self.workers, lit.worker.initialize,
73 pool.apply_async(lit.worker.execute, args=[test],
|
| D | LitTestCase.py | 5 import lit.worker
31 result = lit.worker._execute(self._test, self._lit_config)
|