Lines Matching refs:tcpmsg
227 dns_tcpmsg_t tcpmsg; /*%< for tcp streams */ member
1330 dns_tcpmsg_t *tcpmsg = &disp->tcpmsg; in tcp_recv() local
1362 tcpmsg->result = ISC_R_CANCELED; in tcp_recv()
1365 if (tcpmsg->result != ISC_R_SUCCESS) { in tcp_recv()
1366 switch (tcpmsg->result) { in tcp_recv()
1382 isc_sockaddr_format(&tcpmsg->address, buf, sizeof(buf)); in tcp_recv()
1386 buf, isc_result_totext(tcpmsg->result)); in tcp_recv()
1399 disp->shutdown_why = tcpmsg->result; in tcp_recv()
1413 tcpmsg->result, tcpmsg->buffer.length, in tcp_recv()
1414 tcpmsg->buffer.base); in tcp_recv()
1419 dres = dns_message_peekheader(&tcpmsg->buffer, &id, &flags); in tcp_recv()
1448 bucket = dns_hash(qid, &tcpmsg->address, id, disp->localport); in tcp_recv()
1450 resp = entry_search(qid, &tcpmsg->address, id, disp->localport, bucket); in tcp_recv()
1468 dns_tcpmsg_keepbuffer(tcpmsg, &rev->buffer); in tcp_recv()
1472 rev->addr = tcpmsg->address; in tcp_recv()
1581 res = dns_tcpmsg_readmessage(&disp->tcpmsg, disp->task[0], in startrecv()
2256 dns_tcpmsg_invalidate(&disp->tcpmsg); in dispatch_free()
2349 dns_tcpmsg_init(mgr->mctx, disp->socket, &disp->tcpmsg); in dns_dispatch_createtcp()