Lines Matching defs:resp
165 dns_dispentry_t *resp;
298 dns_dispentry_t *resp);
383 request_log(dns_dispatch_t *disp, dns_dispentry_t *resp,
388 request_log(dns_dispatch_t *disp, dns_dispentry_t *resp,
402 if (VALID_RESPONSE(resp)) {
403 isc_sockaddr_format(&resp->host, peerbuf, sizeof(peerbuf));
406 "dispatch %p response %p %s: %s", disp, resp,
411 "dispatch %p req/resp %p: %s", disp, resp,
455 * Find the next entry after 'resp' in 'qid'. Return NULL if there are
459 linear_next(dns_qid_t *qid, dns_dispentry_t *resp) {
463 ret = ISC_LIST_NEXT(resp, link);
467 bucket = resp->bucket;
699 dispsock->resp = NULL;
831 if (dispsock->resp != NULL) {
832 INSIST(dispsock->resp->dispsocket == dispsock);
833 dispsock->resp->dispsocket = NULL;
1038 dns_dispentry_t *resp = NULL;
1070 (ev->result == ISC_R_CANCELED || dispsock->resp == NULL)) {
1072 * dispsock->resp can be NULL if this transaction was canceled
1101 resp = dispsock->resp;
1102 id = resp->id;
1184 if (resp == NULL) {
1188 resp = entry_search(qid, &ev->address, id, disp->localport,
1192 bucket, (resp == NULL ? "not found" : "found"));
1194 if (resp == NULL) {
1199 } else if (resp->id != id || !isc_sockaddr_equal(&ev->address,
1200 &resp->host)) {
1213 if (disp != resp->disp) {
1220 if (disp->socktype != resp->disp->socktype ||
1222 isc_sockaddr_getport(&resp->disp->local)) {
1237 if (isc_sockaddr_pf(&resp->disp->local) == PF_INET6 &&
1242 isc_sockaddr_anyofpf(&a1, isc_sockaddr_pf(&resp->disp->local));
1244 if (!isc_sockaddr_eqaddr(&disp->local, &resp->disp->local) &&
1245 !isc_sockaddr_eqaddr(&a1, &resp->disp->local) &&
1253 queue_response = resp->item_out;
1254 rev = allocate_devent(resp->disp);
1262 * resp contains the information on the place to send it to.
1273 ISC_LIST_APPEND(resp->items, rev, ev_link);
1277 resp->action, resp->arg, resp, NULL, NULL);
1278 request_log(disp, resp, LVL(90),
1281 resp->task);
1282 resp->item_out = ISC_TRUE;
1283 isc_task_send(resp->task, ISC_EVENT_PTR(&rev));
1329 dns_dispentry_t *resp;
1443 resp = entry_search(qid, &tcpmsg->address, id, disp->localport, bucket);
1446 bucket, (resp == NULL ? "not found" : "found"));
1448 if (resp == NULL)
1450 queue_response = resp->item_out;
1457 * resp contains the information on the place to send it to.
1466 ISC_LIST_APPEND(resp->items, rev, ev_link);
1469 resp->action, resp->arg, resp, NULL, NULL);
1470 request_log(disp, resp, LVL(90),
1473 resp->task);
1474 resp->item_out = ISC_TRUE;
1475 isc_task_send(resp->task, ISC_EVENT_PTR(&rev));
3175 dns_messageid_t *idp, dns_dispentry_t **resp,
3179 idp, resp, sockmgr));
3186 dns_messageid_t *idp, dns_dispentry_t **resp,
3202 REQUIRE(resp != NULL && *resp == NULL);
3230 oldestresp = oldestsocket->resp;
3325 dispsocket->resp = res;
3373 *resp = res;
3384 dns_messageid_t *idp, dns_dispentry_t **resp)
3390 idp, resp, NULL));
3409 dns_dispatch_getnext(dns_dispentry_t *resp, dns_dispatchevent_t **sockevent) {
3413 REQUIRE(VALID_RESPONSE(resp));
3416 disp = resp->disp;
3419 REQUIRE(resp->item_out == ISC_TRUE);
3420 resp->item_out = ISC_FALSE;
3434 ev = ISC_LIST_HEAD(resp->items);
3436 ISC_LIST_UNLINK(resp->items, ev, ev_link);
3438 resp->action, resp->arg, resp, NULL, NULL);
3439 request_log(disp, resp, LVL(90),
3442 resp->task);
3443 resp->item_out = ISC_TRUE;
3444 isc_task_send(resp->task, ISC_EVENT_PTR(&ev));
3451 dns_dispatch_removeresponse(dns_dispentry_t **resp,
3465 REQUIRE(resp != NULL);
3466 REQUIRE(VALID_RESPONSE(*resp));
3468 res = *resp;
3469 *resp = NULL;
3543 res->dispsocket->resp = NULL;
3573 dns_dispentry_t *resp;
3586 for (resp = linear_first(qid);
3587 resp != NULL && resp->item_out;
3589 resp = linear_next(qid, resp);
3594 if (resp == NULL)
3598 * Send the shutdown failsafe event to this resp.
3602 resp->action, resp->arg, resp, NULL, NULL);
3607 request_log(disp, resp, LVL(10),
3609 ev, resp->task);
3610 resp->item_out = ISC_TRUE;
3611 isc_task_send(resp->task, ISC_EVENT_PTR(&ev));
3624 dns_dispatch_getentrysocket(dns_dispentry_t *resp) {
3625 REQUIRE(VALID_RESPONSE(resp));
3627 if (resp->dispsocket != NULL)
3628 return (resp->dispsocket->socket);