Lines Matching defs:worker
119 isc__networker_t *worker = arg;
120 isc_loop_t *loop = worker->loop;
122 worker->shuttingdown = true;
124 isc__netmgr_log(worker->netmgr, ISC_LOG_DEBUG(1),
125 "Shutting down network manager worker on loop %p(%d)",
130 isc__networker_detach(&worker);
215 isc__networker_t *worker = &netmgr->workers[i];
217 *worker = (isc__networker_t){
223 isc_nm_attach(netmgr, &worker->netmgr);
225 isc_mem_attach(loop->mctx, &worker->mctx);
227 isc_mempool_create(worker->mctx, sizeof(isc_nmsocket_t),
228 &worker->nmsocket_pool);
229 isc_mempool_setfreemax(worker->nmsocket_pool,
232 isc_mempool_create(worker->mctx, sizeof(isc__nm_uvreq_t),
233 &worker->uvreq_pool);
234 isc_mempool_setfreemax(worker->uvreq_pool, ISC_NM_UVREQS_MAX);
236 isc_loop_attach(loop, &worker->loop);
237 isc_loop_teardown(loop, networker_teardown, worker);
238 isc_refcount_init(&worker->references, 1);
442 isc__networker_t *worker = sock->worker;
464 isc_mem_cput(sock->worker->mctx, sock->children,
507 ISC_LIST_UNLINK(worker->active_sockets, sock, active_link);
509 isc_mempool_put(worker->nmsocket_pool, sock);
512 isc__networker_detach(&worker);
578 isc_async_run(sock->worker->loop, nmsocket_cleanup, sock);
685 isc___nmsocket_init(isc_nmsocket_t *sock, isc__networker_t *worker,
691 REQUIRE(worker != NULL);
695 .tid = worker->loop->tid,
715 ISC_LIST_APPEND(worker->active_sockets, sock, active_link);
722 isc__networker_attach(worker, &sock->worker);
794 REQUIRE(buf->base == sock->worker->recvbuf);
796 sock->worker->recvbuf_inuse = false;
801 isc_nmhandle_t *handle = isc_mem_get(sock->worker->mctx,
923 isc_mem_put(sock->worker->mctx, handle, sizeof(*handle));
994 isc_job_run(sock->worker->loop, &handle->job, isc__nm_closehandle_job,
1332 * worker's receive buffer to a socket, and marks it as "in use".
1337 isc__networker_t *worker = NULL;
1347 worker = sock->worker;
1348 INSIST(!worker->recvbuf_inuse);
1349 INSIST(worker->recvbuf != NULL);
1363 buf->base = worker->recvbuf;
1365 worker->recvbuf_inuse = true;
1419 isc__nm_closing(isc__networker_t *worker) {
1420 return worker->shuttingdown;
1426 isc__nm_closing(sock->worker) ||
1500 netmgr = sock->worker->netmgr;
1563 return handle->sock->worker->netmgr;
1571 isc__networker_t *worker = sock->worker;
1573 isc__nm_uvreq_t *req = isc_mempool_get(worker->uvreq_pool);
1612 isc_mempool_put(sock->worker->uvreq_pool, req);
1736 isc_async_run(handle->sock->worker->loop, cancelread_cb, handle);
1860 isc_job_run(sock->worker->loop, &uvreq->job, isc___nm_connectcb, uvreq);
1889 isc_job_run(sock->worker->loop, &uvreq->job, isc___nm_readcb, uvreq);
1914 isc_job_run(sock->worker->loop, &uvreq->job, isc___nm_sendcb, uvreq);
2038 if (sock->statsindex != NULL && sock->worker->netmgr->stats != NULL) {
2039 isc_stats_increment(sock->worker->netmgr->stats,
2049 if (sock->statsindex != NULL && sock->worker->netmgr->stats != NULL) {
2050 isc_stats_decrement(sock->worker->netmgr->stats,
2476 isc__networker_t *worker = &listener->worker->netmgr->workers[tid];
2478 isc_mem_put(worker->loop->mctx, data, sizeof(*data));
2491 (size_t)isc_loopmgr_nloops(listener->worker->netmgr->loopmgr);
2492 /* Update the TLS context reference for every worker thread. */
2494 isc__networker_t *worker =
2495 &listener->worker->netmgr->workers[i];
2496 settlsctx_data_t *data = isc_mem_cget(worker->loop->mctx, 1,
2502 isc_async_run(worker->loop, settlsctx_cb, data);
2576 isc__networker_destroy(isc__networker_t *worker) {
2577 isc_nm_t *netmgr = worker->netmgr;
2578 worker->netmgr = NULL;
2581 "Destroying network manager worker on loop %p(%d)",
2582 worker->loop, isc_tid());
2584 isc_loop_detach(&worker->loop);
2586 isc_mempool_destroy(&worker->uvreq_pool);
2587 isc_mempool_destroy(&worker->nmsocket_pool);
2589 isc_mem_putanddetach(&worker->mctx, worker->recvbuf,
2940 isc__nm_dump_active(isc__networker_t *worker) {
2944 for (sock = ISC_LIST_HEAD(worker->active_sockets); sock != NULL;
2960 isc__networker_t *worker = &netmgr->workers[i];
2962 if (!ISC_LIST_EMPTY(worker->active_sockets)) {
2963 fprintf(stderr, "Worker #%zu (%p)\n", i, worker);
2964 isc__nm_dump_active(worker);