Lines Matching defs:worker

81 	isc__networker_t *worker = NULL;
90 	worker = sock->worker;
98 	r = uv_tcp_init(&worker->loop->loop, &sock->uv_handle.tcp);
102 	r = uv_timer_init(&worker->loop->loop, &sock->read_timer);
122 	isc__nm_set_network_buffers(sock->worker->netmgr,
146 	isc__networker_t *worker = NULL;
152 	worker = sock->worker;
165 	} else if (isc__nm_closing(worker)) {
228 	isc__networker_t *worker = NULL;
235 	worker = &mgr->workers[isc_tid()];
237 	if (isc__nm_closing(worker)) {
250 	sock = isc_mempool_get(worker->nmsocket_pool);
251 	isc__nmsocket_init(sock, worker, isc_nm_tcpsocket, local, NULL);
317 	isc_loop_t *loop = sock->worker->loop;
345 	if (sock->worker->netmgr->load_balance_sockets) {
365 	isc__nm_set_network_buffers(sock->worker->netmgr,
417 	isc__networker_t *worker = &mgr->workers[tid];
419 	isc__nmsocket_init(csock, worker, isc_nm_tcpsocket, iface, sock);
441 		isc_async_run(worker->loop, start_tcp_child_job, csock);
452 	isc__networker_t *worker = NULL;
462 	worker = &mgr->workers[0];
463 	sock = isc_mempool_get(worker->nmsocket_pool);
464 	isc__nmsocket_init(sock, worker, isc_nm_tcplistener, iface, NULL);
468 	sock->children = isc_mem_cget(worker->mctx, sock->nchildren,
543 	isc_nmsocket_t *csock = isc_mempool_get(ssock->worker->nmsocket_pool);
544 	isc__nmsocket_init(csock, ssock->worker, isc_nm_tcpsocket,
592 	REQUIRE(!sock->worker->loop->paused);
603 		isc_async_run(sock->worker->loop, stop_tcp_child_job, sock);
681 	netmgr = sock->worker->netmgr;
744 	netmgr = sock->worker->netmgr;
855 		isc_async_run(csock->worker->loop, tcpaccept_cb, csock);
876 	csock->read_timeout = atomic_load_relaxed(&csock->worker->netmgr->init);
878 	r = uv_tcp_init(&csock->worker->loop->loop, &csock->uv_handle.tcp);
882 	r = uv_timer_init(&csock->worker->loop->loop, &csock->read_timer);
1005 	isc_nm_t *netmgr = sock->worker->netmgr;