Cross Reference: /bind-9.6-ESV-R11/lib/dns/dispatch.c

Lines Matching defs:ev
304 static inline void free_event(dns_dispatch_t *disp, dns_dispatchevent_t *ev);
1064 free_event(dns_dispatch_t *disp, dns_dispatchevent_t *ev) {
1065 	if (disp->failsafe_ev == ev) {
1072 	isc_mempool_put(disp->mgr->epool, ev);
1077 	dns_dispatchevent_t *ev;
1079 	ev = isc_mempool_get(disp->mgr->epool);
1080 	if (ev == NULL)
1082 	ISC_EVENT_INIT(ev, sizeof(*ev), 0, NULL, 0,
1085 	return (ev);
1089 udp_exrecv(isc_task_t *task, isc_event_t *ev) {
1090 	dispsocket_t *dispsock = ev->ev_arg;
1095 	udp_recv(ev, dispsock->disp, dispsock);
1099 udp_shrecv(isc_task_t *task, isc_event_t *ev) {
1100 	dns_dispatch_t *disp = ev->ev_arg;
1105 	udp_recv(ev, disp, NULL);
1124 	isc_socketevent_t *ev = (isc_socketevent_t *)ev_in;
1150 	if (dispsock == NULL && ev->ev_type == ISC_SOCKEVENT_RECVDONE) {
1161 	    (ev->result == ISC_R_CANCELED || dispsock->resp == NULL)) {
1177 		free_buffer(disp, ev->region.base, ev->region.length);
1180 		ev = NULL;
1194 			if (ev->result != ISC_R_SUCCESS) {
1204 			free_buffer(disp, ev->region.base, ev->region.length);
1210 	} else if (ev->result != ISC_R_SUCCESS) {
1211 		free_buffer(disp, ev->region.base, ev->region.length);
1213 		if (ev->result != ISC_R_CANCELED)
1216 				     isc_result_totext(ev->result));
1226 	isc_netaddr_fromsockaddr(&netaddr, &ev->address);
1240 		free_buffer(disp, ev->region.base, ev->region.length);
1247 	isc_buffer_init(&source, ev->region.base, ev->region.length);
1248 	isc_buffer_add(&source, ev->n);
1251 		free_buffer(disp, ev->region.base, ev->region.length);
1266 		free_buffer(disp, ev->region.base, ev->region.length);
1276 		bucket = dns_hash(qid, &ev->address, id, disp->localport);
1279 		resp = entry_search(qid, &ev->address, id, disp->localport,
1287 			free_buffer(disp, ev->region.base, ev->region.length);
1290 	} else if (resp->id != id || !isc_sockaddr_equal(&ev->address,
1295 		free_buffer(disp, ev->region.base, ev->region.length);
1314 			free_buffer(disp, ev->region.base, ev->region.length);
1330 			free_buffer(disp, ev->region.base, ev->region.length);
1337 			free_buffer(disp, ev->region.base, ev->region.length);
1346 		free_buffer(disp, ev->region.base, ev->region.length);
1355 	isc_buffer_init(&rev->buffer, ev->region.base, ev->region.length);
1356 	isc_buffer_add(&rev->buffer, ev->n);
1357 	rev->result = ev->result;
1359 	rev->addr = ev->address;
1360 	rev->pktinfo = ev->pktinfo;
1361 	rev->attributes = ev->attributes;
3173 	dns_dispatchevent_t *ev;
3195 		ev = *sockevent;
3198 		ev = NULL;
3226 	if (ev == NULL && res->item_out) {
3238 		ev = (dns_dispatchevent_t *)ISC_LIST_HEAD(events);
3241 	if (ev != NULL) {
3244 		if (ev->buffer.base != NULL)
3245 			free_buffer(disp, ev->buffer.base, ev->buffer.length);
3246 		free_event(disp, ev);
3261 	ev = ISC_LIST_HEAD(res->items);
3262 	while (ev != NULL) {
3263 		ISC_LIST_UNLINK(res->items, ev, ev_link);
3264 		if (ev->buffer.base != NULL)
3265 			free_buffer(disp, ev->buffer.base, ev->buffer.length);
3266 		free_event(disp, ev);
3267 		ev = ISC_LIST_HEAD(res->items);
3284 	dns_dispatchevent_t *ev;
3312 	ev = disp->failsafe_ev;
3313 	ISC_EVENT_INIT(ev, sizeof(*ev), 0, NULL, DNS_EVENT_DISPATCH,
3315 	ev->result = disp->shutdown_why;
3316 	ev->buffer.base = NULL;
3317 	ev->buffer.length = 0;
3321 		    ev, resp->task);
3323 	isc_task_send(resp->task, ISC_EVENT_PTR(&ev));