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

Lines Matching refs:resp
181 	dns_dispentry_t			*resp;
309 				    dns_dispentry_t *resp);
385 request_log(dns_dispatch_t *disp, dns_dispentry_t *resp,
390 request_log(dns_dispatch_t *disp, dns_dispentry_t *resp,
404 	if (VALID_RESPONSE(resp)) {
405 		isc_sockaddr_format(&resp->host, peerbuf, sizeof(peerbuf));
408 			      "dispatch %p response %p %s: %s", disp, resp,
413 			      "dispatch %p req/resp %p: %s", disp, resp,
618  * Find the next entry after 'resp' in 'qid'.  Return NULL if there are
622 linear_next(dns_qid_t *qid, dns_dispentry_t *resp) {
626 	ret = ISC_LIST_NEXT(resp, link);
630 	bucket = resp->bucket;
845 		dispsock->resp = NULL;
965 	if (dispsock->resp != NULL) {
966 		INSIST(dispsock->resp->dispsocket == dispsock);
967 		dispsock->resp->dispsocket = NULL;
1129 	dns_dispentry_t *resp = NULL;
1161 	    (ev->result == ISC_R_CANCELED || dispsock->resp == NULL)) {
1163 		 * dispsock->resp can be NULL if this transaction was canceled
1192 			resp = dispsock->resp;
1193 			id = resp->id;
1275 	if (resp == NULL) {
1279 		resp = entry_search(qid, &ev->address, id, disp->localport,
1283 			     bucket, (resp == NULL ? "not found" : "found"));
1285 		if (resp == NULL) {
1290 	} else if (resp->id != id || !isc_sockaddr_equal(&ev->address,
1291 							 &resp->host)) {
1304 	if (disp != resp->disp) {
1311 		if (disp->socktype != resp->disp->socktype ||
1313 		    isc_sockaddr_getport(&resp->disp->local)) {
1328 		if (isc_sockaddr_pf(&resp->disp->local) == PF_INET6 &&
1333 		isc_sockaddr_anyofpf(&a1, isc_sockaddr_pf(&resp->disp->local));
1335 		if (!isc_sockaddr_eqaddr(&a1, &resp->disp->local) &&
1343 	queue_response = resp->item_out;
1344 	rev = allocate_event(resp->disp);
1352 	 * resp contains the information on the place to send it to.
1363 		ISC_LIST_APPEND(resp->items, rev, ev_link);
1367 			       resp->action, resp->arg, resp, NULL, NULL);
1368 		request_log(disp, resp, LVL(90),
1371 			    resp->task);
1372 		resp->item_out = ISC_TRUE;
1373 		isc_task_send(resp->task, ISC_EVENT_PTR(&rev));
1420 	dns_dispentry_t *resp;
1534 	resp = entry_search(qid, &tcpmsg->address, id, disp->localport, bucket);
1537 		     bucket, (resp == NULL ? "not found" : "found"));
1539 	if (resp == NULL)
1541 	queue_response = resp->item_out;
1548 	 * resp contains the information on the place to send it to.
1557 		ISC_LIST_APPEND(resp->items, rev, ev_link);
1560 			       resp->action, resp->arg, resp, NULL, NULL);
1561 		request_log(disp, resp, LVL(90),
1564 			    resp->task);
1565 		resp->item_out = ISC_TRUE;
1566 		isc_task_send(resp->task, ISC_EVENT_PTR(&rev));
2959 			  dns_messageid_t *idp, dns_dispentry_t **resp,
2975 	REQUIRE(resp != NULL && *resp == NULL);
3003 		oldestresp = oldestsocket->resp;
3094 		dispsocket->resp = res;
3132 	*resp = res;
3143 			 dns_messageid_t *idp, dns_dispentry_t **resp)
3149 					  idp, resp, NULL));
3166 dns_dispatch_removeresponse(dns_dispentry_t **resp,
3180 	REQUIRE(resp != NULL);
3181 	REQUIRE(VALID_RESPONSE(*resp));
3183 	res = *resp;
3184 	*resp = NULL;
3255 		res->dispsocket->resp = NULL;
3285 	dns_dispentry_t *resp;
3298 	for (resp = linear_first(qid);
3299 	     resp != NULL && resp->item_out;
3301 		resp = linear_next(qid, resp);
3306 	if (resp == NULL)
3310 	 * Send the shutdown failsafe event to this resp.
3314 		       resp->action, resp->arg, resp, NULL, NULL);
3319 	request_log(disp, resp, LVL(10),
3321 		    ev, resp->task);
3322 	resp->item_out = ISC_TRUE;
3323 	isc_task_send(resp->task, ISC_EVENT_PTR(&ev));
3336 dns_dispatch_getentrysocket(dns_dispentry_t *resp) {
3337 	REQUIRE(VALID_RESPONSE(resp));
3339 	if (resp->dispsocket != NULL)
3340 		return (resp->dispsocket->socket);