Lines Matching defs:mgr
95 worker = &sock->mgr->workers[sock->tid];
115 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_OPENFAIL]);
118 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_OPEN]);
127 isc__nm_incstats(sock->mgr,
137 isc__nm_incstats(sock->mgr,
141 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_CONNECT]);
230 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_CONNECT]);
252 isc_nm_tcpdnsconnect(isc_nm_t *mgr, isc_sockaddr_t *local, isc_sockaddr_t *peer,
261 REQUIRE(VALID_NM(mgr));
267 sock = isc_mem_get(mgr->mctx, sizeof(*sock));
268 isc__nmsocket_init(sock, mgr, isc_nm_tcpdnssocket, local);
275 req = isc__nm_uvreq_get(mgr, sock);
298 ievent = isc__nm_get_netievent_tcpdnsconnect(mgr, sock, req);
303 isc__nm_async_tcpdnsconnect(&mgr->workers[sock->tid],
305 isc__nm_put_netievent_tcpdnsconnect(mgr, ievent);
308 sock->tid = isc_random_uniform(mgr->nlisteners);
309 isc__nm_enqueue_ievent(&mgr->workers[sock->tid],
323 isc__nm_tcpdns_lb_socket(isc_nm_t *mgr, sa_family_t sa_family) {
338 if (mgr->load_balance_sockets) {
350 isc__nm_get_netievent_tcpdnsstop(sock->mgr, sock);
351 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
356 start_tcpdns_child(isc_nm_t *mgr, isc_sockaddr_t *iface, isc_nmsocket_t *sock,
361 isc__nmsocket_init(csock, mgr, isc_nm_tcpdnssocket, iface);
379 csock->fd = isc__nm_tcpdns_lb_socket(mgr, iface->type.sa.sa_family);
381 if (mgr->load_balance_sockets) {
383 csock->fd = isc__nm_tcpdns_lb_socket(mgr,
391 ievent = isc__nm_get_netievent_tcpdnslisten(mgr, csock);
392 isc__nm_maybe_enqueue_ievent(&mgr->workers[tid],
396 isc_nm_listentcpdns(isc_nm_t *mgr, isc_sockaddr_t *iface,
406 REQUIRE(VALID_NM(mgr));
408 sock = isc_mem_get(mgr->mctx, sizeof(*sock));
409 isc__nmsocket_init(sock, mgr, isc_nm_tcpdnslistener, iface);
415 sock->nchildren = mgr->nlisteners;
418 sock->children = isc_mem_get(mgr->mctx, children_size);
434 if (!mgr->load_balance_sockets) {
435 fd = isc__nm_tcpdns_lb_socket(mgr, iface->type.sa.sa_family);
445 start_tcpdns_child(mgr, iface, sock, fd, i);
449 start_tcpdns_child(mgr, iface, sock, fd, isc_nm_tid());
453 if (!mgr->load_balance_sockets) {
489 isc_nm_t *mgr = NULL;
497 mgr = sock->mgr;
520 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_OPENFAIL]);
523 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_OPEN]);
533 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_BINDFAIL]);
537 if (mgr->load_balance_sockets) {
541 isc__nm_incstats(sock->mgr,
550 isc__nm_incstats(sock->mgr, STATID_BINDFAIL);
575 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_BINDFAIL]);
620 isc__nm_incstats(ssock->mgr,
718 ? atomic_load(&sock->mgr->keepalive)
719 : atomic_load(&sock->mgr->idle));
722 ievent = isc__nm_get_netievent_tcpdnsread(sock->mgr, sock);
730 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
863 isc__nm_incstats(sock->mgr,
890 sock->read_timeout = atomic_load(&sock->mgr->idle);
921 isc__nm_get_netievent_tcpdnsaccept(sock->mgr, sock, quota);
922 isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid],
967 csock = isc_mem_get(ssock->mgr->mctx, sizeof(isc_nmsocket_t));
968 isc__nmsocket_init(csock, ssock->mgr, isc_nm_tcpdnssocket,
978 worker = &csock->mgr->workers[csock->tid];
1036 isc__nm_incstats(csock->mgr, csock->statsindex[STATID_ACCEPT]);
1038 csock->read_timeout = atomic_load(&csock->mgr->init);
1060 ? atomic_load(&csock->mgr->keepalive)
1061 : atomic_load(&csock->mgr->idle));
1097 uvreq = isc__nm_uvreq_get(sock->mgr, sock);
1107 ievent = isc__nm_get_netievent_tcpdnssend(sock->mgr, sock, uvreq);
1108 isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid],
1128 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_SENDFAIL]);
1157 ? atomic_load(&sock->mgr->keepalive)
1158 : atomic_load(&sock->mgr->idle));
1215 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_SENDFAIL]);
1236 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_CLOSE]);
1255 isc__nm_incstats(sock->mgr, sock->statsindex[STATID_CLOSE]);
1382 isc__nm_get_netievent_tcpdnsclose(sock->mgr, sock);
1384 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
1466 ievent = isc__nm_get_netievent_tcpdnscancel(sock->mgr, sock, handle);
1467 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
Indexes created Tue Aug 04 00:24:20 UTC 2026