Cross Reference: /bind-9.11.3/lib/dns/dispatch.c

Lines Matching defs:ev
293 static inline void free_devent(dns_dispatch_t *disp, dns_dispatchevent_t *ev);
940 free_sevent(isc_event_t *ev) {
941 	isc_mempool_t *pool = ev->ev_destroy_arg;
942 	isc_socketevent_t *sev = (isc_socketevent_t *) ev;
950 	isc_socketevent_t *ev;
953 	ev = isc_mempool_get(disp->sepool);
954 	if (ev == NULL)
957 	ISC_EVENT_INIT(ev, sizeof(*ev), 0, NULL, type,
960 	ev->result = ISC_R_UNSET;
961 	ISC_LINK_INIT(ev, ev_link);
962 	ISC_LIST_INIT(ev->bufferlist);
963 	ev->region.base = NULL;
964 	ev->n = 0;
965 	ev->offset = 0;
966 	ev->attributes = 0;
968 	return (ev);
973 free_devent(dns_dispatch_t *disp, dns_dispatchevent_t *ev) {
974 	if (disp->failsafe_ev == ev) {
981 	isc_mempool_put(disp->mgr->depool, ev);
986 	dns_dispatchevent_t *ev;
988 	ev = isc_mempool_get(disp->mgr->depool);
989 	if (ev == NULL)
991 	ISC_EVENT_INIT(ev, sizeof(*ev), 0, NULL, 0,
994 	return (ev);
998 udp_exrecv(isc_task_t *task, isc_event_t *ev) {
999 	dispsocket_t *dispsock = ev->ev_arg;
1004 	udp_recv(ev, dispsock->disp, dispsock);
1008 udp_shrecv(isc_task_t *task, isc_event_t *ev) {
1009 	dns_dispatch_t *disp = ev->ev_arg;
1014 	udp_recv(ev, disp, NULL);
1033 	isc_socketevent_t *ev = (isc_socketevent_t *)ev_in;
1059 	if (dispsock == NULL && ev->ev_type == ISC_SOCKEVENT_RECVDONE) {
1070 	    (ev->result == ISC_R_CANCELED || dispsock->resp == NULL)) {
1086 		free_buffer(disp, ev->region.base, ev->region.length);
1089 		ev = NULL;
1103 			if (ev->result != ISC_R_SUCCESS) {
1113 			free_buffer(disp, ev->region.base, ev->region.length);
1119 	} else if (ev->result != ISC_R_SUCCESS) {
1120 		free_buffer(disp, ev->region.base, ev->region.length);
1122 		if (ev->result != ISC_R_CANCELED)
1125 				     isc_result_totext(ev->result));
1135 	isc_netaddr_fromsockaddr(&netaddr, &ev->address);
1149 		free_buffer(disp, ev->region.base, ev->region.length);
1156 	isc_buffer_init(&source, ev->region.base, ev->region.length);
1157 	isc_buffer_add(&source, ev->n);
1160 		free_buffer(disp, ev->region.base, ev->region.length);
1175 		free_buffer(disp, ev->region.base, ev->region.length);
1185 		bucket = dns_hash(qid, &ev->address, id, disp->localport);
1188 		resp = entry_search(qid, &ev->address, id, disp->localport,
1196 			free_buffer(disp, ev->region.base, ev->region.length);
1199 	} else if (resp->id != id || !isc_sockaddr_equal(&ev->address,
1204 		free_buffer(disp, ev->region.base, ev->region.length);
1223 			free_buffer(disp, ev->region.base, ev->region.length);
1239 			free_buffer(disp, ev->region.base, ev->region.length);
1247 			free_buffer(disp, ev->region.base, ev->region.length);
1256 		free_buffer(disp, ev->region.base, ev->region.length);
1265 	isc_buffer_init(&rev->buffer, ev->region.base, ev->region.length);
1266 	isc_buffer_add(&rev->buffer, ev->n);
1267 	rev->result = ev->result;
1269 	rev->addr = ev->address;
1270 	rev->pktinfo = ev->pktinfo;
1271 	rev->attributes = ev->attributes;
3411 	dns_dispatchevent_t *ev;
3422 	ev = *sockevent;
3426 	if (ev->buffer.base != NULL)
3427 		free_buffer(disp, ev->buffer.base, ev->buffer.length);
3428 	free_devent(disp, ev);
3434 	ev = ISC_LIST_HEAD(resp->items);
3435 	if (ev != NULL) {
3436 		ISC_LIST_UNLINK(resp->items, ev, ev_link);
3437 		ISC_EVENT_INIT(ev, sizeof(*ev), 0, NULL, DNS_EVENT_DISPATCH,
3441 			    ev, ev->buffer.base, ev->buffer.length,
3444 		isc_task_send(resp->task, ISC_EVENT_PTR(&ev));
3458 	dns_dispatchevent_t *ev;
3480 		ev = *sockevent;
3483 		ev = NULL;
3514 	if (ev == NULL && res->item_out) {
3526 		ev = (dns_dispatchevent_t *)ISC_LIST_HEAD(events);
3529 	if (ev != NULL) {
3532 		if (ev->buffer.base != NULL)
3533 			free_buffer(disp, ev->buffer.base, ev->buffer.length);
3534 		free_devent(disp, ev);
3549 	ev = ISC_LIST_HEAD(res->items);
3550 	while (ev != NULL) {
3551 		ISC_LIST_UNLINK(res->items, ev, ev_link);
3552 		if (ev->buffer.base != NULL)
3553 			free_buffer(disp, ev->buffer.base, ev->buffer.length);
3554 		free_devent(disp, ev);
3555 		ev = ISC_LIST_HEAD(res->items);
3572 	dns_dispatchevent_t *ev;
3600 	ev = disp->failsafe_ev;
3601 	ISC_EVENT_INIT(ev, sizeof(*ev), 0, NULL, DNS_EVENT_DISPATCH,
3603 	ev->result = disp->shutdown_why;
3604 	ev->buffer.base = NULL;
3605 	ev->buffer.length = 0;
3609 		    ev, resp->task);
3611 	isc_task_send(resp->task, ISC_EVENT_PTR(&ev));