Lines Matching refs:tcpmsg
138 dns_tcpmsg_t tcpmsg; member
778 dns_tcpmsg_cancelread(&xfr->tcpmsg); in xfrin_cancelio()
812 dns_tcpmsg_invalidate(&xfr->tcpmsg); in xfrin_reset()
1076 dns_tcpmsg_init(xfr->mctx, xfr->socket, &xfr->tcpmsg); in xfrin_connect_done()
1264 CHECK(dns_tcpmsg_readmessage(&xfr->tcpmsg, xfr->task, xfrin_recv_done, in xfrin_send_done()
1280 dns_tcpmsg_t *tcpmsg; in xfrin_recv_done() local
1288 tcpmsg = ev->ev_sender; in xfrin_recv_done()
1297 CHECK(tcpmsg->result); in xfrin_recv_done()
1300 tcpmsg->buffer.used); in xfrin_recv_done()
1318 result = dns_message_parse(msg, &tcpmsg->buffer, in xfrin_recv_done()
1323 &tcpmsg->address, DNS_LOGCATEGORY_XFER_IN, in xfrin_recv_done()
1460 xfr->nbytes += tcpmsg->buffer.used; in xfrin_recv_done()
1507 CHECK(dns_tcpmsg_readmessage(&xfr->tcpmsg, xfr->task, in xfrin_recv_done()
1611 dns_tcpmsg_invalidate(&xfr->tcpmsg); in maybe_free()