| /src/external/mpl/bind/dist/lib/isc/netmgr/ |
| proxyudp.c | 864 isc__nm_uvreq_t *uvreq = isc__nm_uvreq_get(sock); local
865 isc_nmhandle_attach(handle, &uvreq->handle);
866 uvreq->cb.send = cb;
867 uvreq->cbarg = cbarg;
869 isc__nm_failed_send_cb(sock, uvreq, result, true);
|
| tcp.c | 64 tcp_connect_cb(uv_connect_t *uvreq, int status);
142 tcp_connect_cb(uv_connect_t *uvreq, int status) {
145 isc_nmsocket_t *sock = uv_handle_get_data((uv_handle_t *)uvreq->handle);
155 req = uv_handle_get_data((uv_handle_t *)uvreq);
1023 isc__nm_uvreq_t *uvreq = NULL; local
1029 uvreq = isc__nm_uvreq_get(sock);
1031 *(uint16_t *)uvreq->tcplen = htons(region->length);
1033 uvreq->uvbuf.base = (char *)region->base;
1034 uvreq->uvbuf.len = region->length;
1036 isc_nmhandle_attach(handle, &uvreq->handle)
1098 isc__nm_uvreq_t *uvreq = (isc__nm_uvreq_t *)req->data; local
[all...] |
| udp.c | 627 isc__nm_uvreq_t *uvreq = uv_handle_get_data((uv_handle_t *)req); local
630 REQUIRE(VALID_UVREQ(uvreq));
631 REQUIRE(VALID_NMHANDLE(uvreq->handle));
633 sock = uvreq->sock;
640 isc__nm_failed_send_cb(sock, uvreq, isc_uverr2result(status),
645 isc__nm_sendcb(sock, uvreq, result, false);
672 isc__nm_uvreq_t *uvreq = NULL; local
699 uvreq = isc__nm_uvreq_get(sock);
700 uvreq->uvbuf.base = (char *)region->base;
701 uvreq->uvbuf.len = region->length
[all...] |
| proxystream.c | 1081 isc__nm_uvreq_t *uvreq = isc__nm_uvreq_get(sock); local
1082 isc_nmhandle_attach(handle, &uvreq->handle);
1083 uvreq->cb.send = cb;
1084 uvreq->cbarg = cbarg;
1086 isc__nm_failed_send_cb(sock, uvreq, result, fail_async);
|
| streamdns.c | 989 isc__nm_uvreq_t *uvreq = NULL; local
1004 uvreq = isc__nm_uvreq_get(sock);
1005 isc_nmhandle_attach(handle, &uvreq->handle);
1006 uvreq->cb.send = cb;
1007 uvreq->cbarg = cbarg;
1008 uvreq->uvbuf.base = (char *)region->base;
1009 uvreq->uvbuf.len = region->length;
1012 isc__nm_failed_send_cb(sock, uvreq, ISC_R_CANCELED, true);
1022 send_req = streamdns_get_send_req(sock, mctx, uvreq);
1023 data.base = (unsigned char *)uvreq->uvbuf.base
[all...] |
| tlsstream.c | 1081 isc__nm_uvreq_t *uvreq = NULL; local
1091 uvreq = isc__nm_uvreq_get(sock);
1092 isc_nmhandle_attach(handle, &uvreq->handle);
1093 uvreq->cb.send = cb;
1094 uvreq->cbarg = cbarg;
1095 uvreq->uvbuf.base = (char *)region->base;
1096 uvreq->uvbuf.len = region->length;
1098 *(uint16_t *)uvreq->tcplen = htons(region->length);
1101 isc_job_run(sock->worker->loop, &uvreq->job, tls_send_direct, uvreq);
[all...] |
| netmgr.c | 1101 uv_connect_t *uvreq = uv_handle_get_data((uv_handle_t *)timer); local
1102 isc_nmsocket_t *sock = uv_handle_get_data((uv_handle_t *)uvreq->handle);
1103 isc__nm_uvreq_t *req = uv_handle_get_data((uv_handle_t *)uvreq);
1854 isc__nm_uvreq_t *uvreq = arg; local
1856 uvreq->cb.connect(uvreq->handle, uvreq->result, uvreq->cbarg);
1857 isc__nm_uvreq_put(&uvreq);
1861 isc__nm_connectcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
1880 isc__nm_uvreq_t *uvreq = arg; local
1909 isc__nm_uvreq_t *uvreq = arg; local
[all...] |
| http.c | 2663 isc__nm_uvreq_t *uvreq = NULL; local
2672 uvreq = isc__nm_uvreq_get(sock);
2673 isc_nmhandle_attach(handle, &uvreq->handle);
2674 uvreq->cb.send = cb;
2675 uvreq->cbarg = cbarg;
2677 uvreq->uvbuf.base = (char *)region->base;
2678 uvreq->uvbuf.len = region->length;
2680 isc_job_run(sock->worker->loop, &uvreq->job, http_send_cb, uvreq);
|
| /src/external/mpl/dhcp/bind/dist/lib/isc/netmgr/ |
| udp.c | 500 isc__nm_uvreq_t *uvreq = NULL; local
548 uvreq = isc__nm_uvreq_get(rsock->mgr, rsock);
549 uvreq->uvbuf.base = (char *)region->base;
550 uvreq->uvbuf.len = region->length;
552 isc_nmhandle_attach(handle, &uvreq->handle);
554 uvreq->cb.send = cb;
555 uvreq->cbarg = cbarg;
560 .req = uvreq,
568 ievent->req = uvreq;
583 isc__nm_uvreq_t *uvreq = ievent->req local
604 isc__nm_uvreq_t *uvreq = uv_handle_get_data((uv_handle_t *)req); local
[all...] |
| tcp.c | 66 tcp_connect_cb(uv_connect_t *uvreq, int status);
224 tcp_connect_cb(uv_connect_t *uvreq, int status) {
227 isc_nmsocket_t *sock = uv_handle_get_data((uv_handle_t *)uvreq->handle);
237 req = uv_handle_get_data((uv_handle_t *)uvreq);
1084 isc__nm_uvreq_t *uvreq = NULL; local
1088 uvreq = isc__nm_uvreq_get(sock->mgr, sock);
1089 uvreq->uvbuf.base = (char *)region->base;
1090 uvreq->uvbuf.len = region->length;
1092 isc_nmhandle_attach(handle, &uvreq->handle);
1094 uvreq->cb.send = cb
1106 isc__nm_uvreq_t *uvreq = (isc__nm_uvreq_t *)req->data; local
1135 isc__nm_uvreq_t *uvreq = ievent->req; local
[all...] |
| tcpdns.c | 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; local
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)
1116 isc__nm_uvreq_t *uvreq = (isc__nm_uvreq_t *)req->data; local
1152 isc__nm_uvreq_t *uvreq = ievent->req; local
[all...] |
| netmgr.c | 1204 isc__nm_uvreq_t *uvreq = NULL; local
1272 while ((uvreq = isc_astack_pop(sock->inactivereqs)) != NULL) {
1273 isc_mem_put(sock->mgr->mctx, uvreq, sizeof(*uvreq));
1918 uv_connect_t *uvreq = uv_handle_get_data((uv_handle_t *)timer); local
1919 isc_nmsocket_t *sock = uv_handle_get_data((uv_handle_t *)uvreq->handle);
1920 isc__nm_uvreq_t *req = uv_handle_get_data((uv_handle_t *)uvreq);
2555 isc__nm_connectcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
2558 REQUIRE(VALID_UVREQ(uvreq));
2559 REQUIRE(VALID_NMHANDLE(uvreq->handle))
2579 isc__nm_uvreq_t *uvreq = ievent->req; local
2620 isc__nm_uvreq_t *uvreq = ievent->req; local
2664 isc__nm_uvreq_t *uvreq = ievent->req; local
[all...] |
