Home | History | Annotate | Download | only in netmgr

Lines Matching refs:uvreq

64 tcpdns_connect_cb(uv_connect_t *uvreq, int status);
194 tcpdns_connect_cb(uv_connect_t *uvreq, int status) {
197 	isc_nmsocket_t *sock = uv_handle_get_data((uv_handle_t *)uvreq->handle);
207 	req = uv_handle_get_data((uv_handle_t *)uvreq);
1093 	isc__nm_uvreq_t *uvreq = NULL;
1097 	uvreq = isc__nm_uvreq_get(sock->mgr, sock);
1098 	*(uint16_t *)uvreq->tcplen = htons(region->length);
1099 	uvreq->uvbuf.base = (char *)region->base;
1100 	uvreq->uvbuf.len = region->length;
1102 	isc_nmhandle_attach(handle, &uvreq->handle);
1104 	uvreq->cb.send = cb;
1105 	uvreq->cbarg = cbarg;
1107 	ievent = isc__nm_get_netievent_tcpdnssend(sock->mgr, sock, uvreq);
1116 	isc__nm_uvreq_t *uvreq = (isc__nm_uvreq_t *)req->data;
1119 	REQUIRE(VALID_UVREQ(uvreq));
1120 	REQUIRE(VALID_NMSOCK(uvreq->sock));
1122 	sock = uvreq->sock;
1124 	isc_nm_timer_stop(uvreq->timer);
1125 	isc_nm_timer_detach(&uvreq->timer);
1129 		isc__nm_failed_send_cb(sock, uvreq,
1134 	isc__nm_sendcb(sock, uvreq, ISC_R_SUCCESS, false);
1152 	isc__nm_uvreq_t *uvreq = ievent->req;
1161 	uv_buf_t bufs[2] = { { .base = uvreq->tcplen, .len = 2 },
1162 			     { .base = uvreq->uvbuf.base,
1163 			       .len = uvreq->uvbuf.len } };
1178 		isc__nm_sendcb(sock, uvreq, ISC_R_SUCCESS, true);
1184 		bufs[0].base = uvreq->tcplen + 1;
1189 		bufs[0].base = uvreq->uvbuf.base + (r - 2);
1190 		bufs[0].len = uvreq->uvbuf.len - (r - 2);
1199 	r = uv_write(&uvreq->uv_req.write, &sock->uv_handle.stream, bufs, nbufs,
1206 	isc_nm_timer_create(uvreq->handle, isc__nmsocket_writetimeout_cb, uvreq,
1207 			    &uvreq->timer);
1209 		isc_nm_timer_start(uvreq->timer, sock->write_timeout);
1216 		isc__nm_failed_send_cb(sock, uvreq, result);