Lines Matching defs:netmgr
1 /* $NetBSD: netmgr.c,v 1.15 2025/01/26 16:25:43 christos Exp $ */
34 #include <isc/netmgr.h>
50 #include "netmgr-int.h"
124 isc__netmgr_log(worker->netmgr, ISC_LOG_DEBUG(1),
135 isc_nm_t *netmgr = (void *)arg;
137 if (atomic_compare_exchange_strong_acq_rel(&netmgr->shuttingdown,
140 isc__netmgr_log(netmgr, ISC_LOG_DEBUG(1),
159 isc_nm_t *netmgr = NULL;
177 netmgr = isc_mem_get(mctx, sizeof(*netmgr));
178 *netmgr = (isc_nm_t){
183 isc_mem_attach(mctx, &netmgr->mctx);
184 isc_refcount_init(&netmgr->references, 1);
185 atomic_init(&netmgr->maxudp, 0);
186 atomic_init(&netmgr->shuttingdown, false);
187 atomic_init(&netmgr->recv_tcp_buffer_size, 0);
188 atomic_init(&netmgr->send_tcp_buffer_size, 0);
189 atomic_init(&netmgr->recv_udp_buffer_size, 0);
190 atomic_init(&netmgr->send_udp_buffer_size, 0);
192 netmgr->load_balance_sockets = true;
194 netmgr->load_balance_sockets = false;
201 atomic_init(&netmgr->init, 30000);
202 atomic_init(&netmgr->idle, 30000);
203 atomic_init(&netmgr->keepalive, 30000);
204 atomic_init(&netmgr->advertised, 30000);
206 netmgr->workers = isc_mem_cget(mctx, netmgr->nloops,
207 sizeof(netmgr->workers[0]));
209 isc_loopmgr_teardown(loopmgr, netmgr_teardown, netmgr);
211 netmgr->magic = NM_MAGIC;
213 for (size_t i = 0; i < netmgr->nloops; i++) {
214 isc_loop_t *loop = isc_loop_get(netmgr->loopmgr, i);
215 isc__networker_t *worker = &netmgr->workers[i];
223 isc_nm_attach(netmgr, &worker->netmgr);
241 *netmgrp = netmgr;
1494 isc_nm_t *netmgr = NULL;
1500 netmgr = sock->worker->netmgr;
1508 value ? atomic_load_relaxed(&netmgr->keepalive)
1509 : atomic_load_relaxed(&netmgr->idle);
1511 value ? atomic_load_relaxed(&netmgr->keepalive)
1512 : atomic_load_relaxed(&netmgr->idle);
1563 return handle->sock->worker->netmgr;
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];
2491 (size_t)isc_loopmgr_nloops(listener->worker->netmgr->loopmgr);
2495 &listener->worker->netmgr->workers[i];
2577 isc_nm_t *netmgr = worker->netmgr;
2578 worker->netmgr = NULL;
2580 isc__netmgr_log(netmgr, ISC_LOG_DEBUG(1),
2591 isc_nm_detach(&netmgr);
2597 isc__netmgr_log(const isc_nm_t *netmgr, int level, const char *fmt, ...) {
2610 level, "netmgr %p: %s", netmgr, msgbuf);
2852 * Dump all active sockets in netmgr. We output to stderr
2956 isc__nm_dump_active_manager(isc_nm_t *netmgr) {
2959 for (i = 0; i < netmgr->nloops; i++) {
2960 isc__networker_t *worker = &netmgr->workers[i];