lib/dns/tcpmsg.c

1 /*	$NetBSD: tcpmsg.c,v 1.1 2024/02/18 20:57:34 christos Exp $	*/
27 #include <dns/tcpmsg.h>
48 	dns_tcpmsg_t *tcpmsg = ev_in->ev_arg;
52 	INSIST(VALID_TCPMSG(tcpmsg));
54 	dev = &tcpmsg->event;
55 	tcpmsg->address = ev->address;
58 		tcpmsg->result = ev->result;
65 	tcpmsg->size = ntohs(tcpmsg->size);
66 	if (tcpmsg->size == 0) {
67 		tcpmsg->result = ISC_R_UNEXPECTEDEND;
70 	if (tcpmsg->size > tcpmsg->maxsize) {
71 		tcpmsg->result = ISC_R_RANGE;
75 	region.base = isc_mem_get(tcpmsg->mctx, tcpmsg->size);
76 	region.length = tcpmsg->size;
78 		tcpmsg->result = ISC_R_NOMEMORY;
81 	XDEBUG(("Allocated %d bytes\n", tcpmsg->size));
83 	isc_buffer_init(&tcpmsg->buffer, region.base, region.length);
84 	result = isc_socket_recv(tcpmsg->sock, &region, 0, task, recv_message,
85 				 tcpmsg);
87 		tcpmsg->result = result;
95 	isc_task_send(tcpmsg->task, &dev);
96 	tcpmsg->task = NULL;
105 	dns_tcpmsg_t *tcpmsg = ev_in->ev_arg;
109 	INSIST(VALID_TCPMSG(tcpmsg));
111 	dev = &tcpmsg->event;
112 	tcpmsg->address = ev->address;
115 		tcpmsg->result = ev->result;
119 	tcpmsg->result = ISC_R_SUCCESS;
120 	isc_buffer_add(&tcpmsg->buffer, ev->n);
122 	XDEBUG(("Received %u bytes (of %d)\n", ev->n, tcpmsg->size));
125 	isc_task_send(tcpmsg->task, &dev);
126 	tcpmsg->task = NULL;
131 dns_tcpmsg_init(isc_mem_t *mctx, isc_socket_t *sock, dns_tcpmsg_t *tcpmsg) {
134 	REQUIRE(tcpmsg != NULL);
136 	tcpmsg->magic = TCPMSG_MAGIC;
137 	tcpmsg->size = 0;
138 	tcpmsg->buffer.base = NULL;
139 	tcpmsg->buffer.length = 0;
140 	tcpmsg->maxsize = 65535; /* Largest message possible. */
141 	tcpmsg->mctx = mctx;
142 	tcpmsg->sock = sock;
143 	tcpmsg->task = NULL;		   /* None yet. */
144 	tcpmsg->result = ISC_R_UNEXPECTED; /* None yet. */
150 dns_tcpmsg_setmaxsize(dns_tcpmsg_t *tcpmsg, unsigned int maxsize) {
151 	REQUIRE(VALID_TCPMSG(tcpmsg));
154 	tcpmsg->maxsize = maxsize;
158 dns_tcpmsg_readmessage(dns_tcpmsg_t *tcpmsg, isc_task_t *task,
163 	REQUIRE(VALID_TCPMSG(tcpmsg));
165 	REQUIRE(tcpmsg->task == NULL); /* not currently in use */
167 	if (tcpmsg->buffer.base != NULL) {
168 		isc_mem_put(tcpmsg->mctx, tcpmsg->buffer.base,
169 			    tcpmsg->buffer.length);
170 		tcpmsg->buffer.base = NULL;
171 		tcpmsg->buffer.length = 0;
174 	tcpmsg->task = task;
175 	tcpmsg->action = action;
176 	tcpmsg->arg = arg;
177 	tcpmsg->result = ISC_R_UNEXPECTED; /* unknown right now */
179 	ISC_EVENT_INIT(&tcpmsg->event, sizeof(isc_event_t), 0, 0,
180 		       DNS_EVENT_TCPMSG, action, arg, tcpmsg, NULL, NULL);
182 	region.base = (unsigned char *)&tcpmsg->size;
184 	result = isc_socket_recv(tcpmsg->sock, &region, 0, tcpmsg->task,
185 				 recv_length, tcpmsg);
188 		tcpmsg->task = NULL;
195 dns_tcpmsg_cancelread(dns_tcpmsg_t *tcpmsg) {
196 	REQUIRE(VALID_TCPMSG(tcpmsg));
198 	isc_socket_cancel(tcpmsg->sock, NULL, ISC_SOCKCANCEL_RECV);
202 dns_tcpmsg_keepbuffer(dns_tcpmsg_t *tcpmsg, isc_buffer_t *buffer) {
203 	REQUIRE(VALID_TCPMSG(tcpmsg));
206 	*buffer = tcpmsg->buffer;
207 	tcpmsg->buffer.base = NULL;
208 	tcpmsg->buffer.length = 0;
213 dns_tcpmsg_freebuffer(dns_tcpmsg_t *tcpmsg) {
214 	REQUIRE(VALID_TCPMSG(tcpmsg));
216 	if (tcpmsg->buffer.base == NULL) {
220 	isc_mem_put(tcpmsg->mctx, tcpmsg->buffer.base, tcpmsg->buffer.length);
221 	tcpmsg->buffer.base = NULL;
222 	tcpmsg->buffer.length = 0;
227 dns_tcpmsg_invalidate(dns_tcpmsg_t *tcpmsg) {
228 	REQUIRE(VALID_TCPMSG(tcpmsg));
230 	tcpmsg->magic = 0;
232 	if (tcpmsg->buffer.base != NULL) {
233 		isc_mem_put(tcpmsg->mctx, tcpmsg->buffer.base,
234 			    tcpmsg->buffer.length);
235 		tcpmsg->buffer.base = NULL;
236 		tcpmsg->buffer.length = 0;