Home | History | Annotate | Download | only in netmgr

Lines Matching defs:csock

359 	isc_nmsocket_t *csock = &sock->children[tid];
361 	isc__nmsocket_init(csock, mgr, isc_nm_tcpdnssocket, iface);
362 	csock->parent = sock;
363 	csock->accept_cb = sock->accept_cb;
364 	csock->accept_cbarg = sock->accept_cbarg;
365 	csock->recv_cb = sock->recv_cb;
366 	csock->recv_cbarg = sock->recv_cbarg;
367 	csock->extrahandlesize = sock->extrahandlesize;
368 	csock->backlog = sock->backlog;
369 	csock->tid = tid;
374 	csock->pquota = sock->pquota;
375 	isc_quota_cb_init(&csock->quotacb, quota_accept_cb, csock);
379 	csock->fd = isc__nm_tcpdns_lb_socket(mgr, iface->type.sa.sa_family);
383 		csock->fd = isc__nm_tcpdns_lb_socket(mgr,
386 		csock->fd = dup(fd);
389 	REQUIRE(csock->fd >= 0);
391 	ievent = isc__nm_get_netievent_tcpdnslisten(mgr, csock);
946 	isc_nmsocket_t *csock = NULL;
967 	csock = isc_mem_get(ssock->mgr->mctx, sizeof(isc_nmsocket_t));
968 	isc__nmsocket_init(csock, ssock->mgr, isc_nm_tcpdnssocket,
970 	csock->tid = ssock->tid;
971 	csock->extrahandlesize = ssock->extrahandlesize;
972 	isc__nmsocket_attach(ssock, &csock->server);
973 	csock->recv_cb = ssock->recv_cb;
974 	csock->recv_cbarg = ssock->recv_cbarg;
975 	csock->quota = quota;
976 	csock->accepting = true;
978 	worker = &csock->mgr->workers[csock->tid];
980 	r = uv_tcp_init(&worker->loop, &csock->uv_handle.tcp);
982 	uv_handle_set_data(&csock->uv_handle.handle, csock);
984 	r = uv_timer_init(&worker->loop, &csock->read_timer);
986 	uv_handle_set_data((uv_handle_t *)&csock->read_timer, csock);
988 	r = uv_accept(&ssock->uv_handle.stream, &csock->uv_handle.stream);
994 	r = uv_tcp_getpeername(&csock->uv_handle.tcp,
1002 	result = isc_sockaddr_fromsockaddr(&csock->peer,
1008 	r = uv_tcp_getsockname(&csock->uv_handle.tcp,
1026 	handle = isc__nmhandle_get(csock, NULL, &local);
1034 	csock->accepting = false;
1036 	isc__nm_incstats(csock->mgr, csock->statsindex[STATID_ACCEPT]);
1038 	csock->read_timeout = atomic_load(&csock->mgr->init);
1040 	csock->closehandle_cb = isc__nm_resume_processing;
1047 	isc_nmhandle_attach(handle, &csock->recv_handle);
1048 	result = isc__nm_process_sock_buffer(csock);
1050 		isc_nmhandle_detach(&csock->recv_handle);
1059 	csock->read_timeout = (atomic_load(&csock->keepalive)
1060 				       ? atomic_load(&csock->mgr->keepalive)
1061 				       : atomic_load(&csock->mgr->idle));
1068 	isc__nmsocket_detach(&csock);
1074 	atomic_store(&csock->active, false);
1076 	isc__nm_failed_accept_cb(csock, result);
1078 	isc__nmsocket_prep_destroy(csock);
1080 	isc__nmsocket_detach(&csock);
1311 	isc_nmsocket_t *csock = NULL;
1320 		csock = &sock->children[i];
1321 		REQUIRE(VALID_NMSOCK(csock));
1330 		atomic_store(&csock->active, false);
1331 		enqueue_stoplistening(csock);
1334 	csock = &sock->children[isc_nm_tid()];
1335 	atomic_store(&csock->active, false);
1336 	stop_tcpdns_child(csock);