| /src/external/mpl/dhcp/bind/dist/lib/isc/netmgr/ |
| 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...] |
| 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...] |
| netmgr-int.h | 1093 isc__nm_connectcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
1103 isc__nm_readcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
1115 isc__nm_sendcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
|
| /src/external/mpl/bind/dist/lib/isc/netmgr/ |
| udp.c | 626 isc__nm_uvreq_t *uvreq = uv_handle_get_data((uv_handle_t *)req); local
629 REQUIRE(VALID_UVREQ(uvreq));
630 REQUIRE(VALID_NMHANDLE(uvreq->handle));
632 sock = uvreq->sock;
639 isc__nm_failed_send_cb(sock, uvreq, isc_uverr2result(status),
644 isc__nm_sendcb(sock, uvreq, result, false);
671 isc__nm_uvreq_t *uvreq = NULL; local
698 uvreq = isc__nm_uvreq_get(sock);
699 uvreq->uvbuf.base = (char *)region->base;
700 uvreq->uvbuf.len = region->length
[all...] |
| netmgr.c | 1086 uv_connect_t *uvreq = uv_handle_get_data((uv_handle_t *)timer); local
1087 isc_nmsocket_t *sock = uv_handle_get_data((uv_handle_t *)uvreq->handle);
1088 isc__nm_uvreq_t *req = uv_handle_get_data((uv_handle_t *)uvreq);
1839 isc__nm_uvreq_t *uvreq = arg; local
1841 uvreq->cb.connect(uvreq->handle, uvreq->result, uvreq->cbarg);
1842 isc__nm_uvreq_put(&uvreq);
1846 isc__nm_connectcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
1865 isc__nm_uvreq_t *uvreq = arg; local
1894 isc__nm_uvreq_t *uvreq = arg; local
[all...] |
| tcp.c | 63 tcp_connect_cb(uv_connect_t *uvreq, int status);
141 tcp_connect_cb(uv_connect_t *uvreq, int status) {
144 isc_nmsocket_t *sock = uv_handle_get_data((uv_handle_t *)uvreq->handle);
154 req = uv_handle_get_data((uv_handle_t *)uvreq);
1006 isc__nm_uvreq_t *uvreq = NULL; local
1012 uvreq = isc__nm_uvreq_get(sock);
1014 *(uint16_t *)uvreq->tcplen = htons(region->length);
1016 uvreq->uvbuf.base = (char *)region->base;
1017 uvreq->uvbuf.len = region->length;
1019 isc_nmhandle_attach(handle, &uvreq->handle)
1081 isc__nm_uvreq_t *uvreq = (isc__nm_uvreq_t *)req->data; local
[all...] |
| streamdns.c | 977 isc__nm_uvreq_t *uvreq = NULL; local
992 uvreq = isc__nm_uvreq_get(sock);
993 isc_nmhandle_attach(handle, &uvreq->handle);
994 uvreq->cb.send = cb;
995 uvreq->cbarg = cbarg;
996 uvreq->uvbuf.base = (char *)region->base;
997 uvreq->uvbuf.len = region->length;
1000 isc__nm_failed_send_cb(sock, uvreq, ISC_R_CANCELED, true);
1010 send_req = streamdns_get_send_req(sock, mctx, uvreq);
1011 data.base = (unsigned char *)uvreq->uvbuf.base
[all...] |
| tlsstream.c | 1069 isc__nm_uvreq_t *uvreq = NULL; local
1079 uvreq = isc__nm_uvreq_get(sock);
1080 isc_nmhandle_attach(handle, &uvreq->handle);
1081 uvreq->cb.send = cb;
1082 uvreq->cbarg = cbarg;
1083 uvreq->uvbuf.base = (char *)region->base;
1084 uvreq->uvbuf.len = region->length;
1086 *(uint16_t *)uvreq->tcplen = htons(region->length);
1089 isc_job_run(sock->worker->loop, &uvreq->job, tls_send_direct, uvreq);
[all...] |
| 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);
|
| 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);
|
| netmgr-int.h | 834 isc__nm_connectcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
838 isc__nm_readcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
847 isc__nm_sendcb(isc_nmsocket_t *sock, isc__nm_uvreq_t *uvreq,
|
| http.c | 2656 isc__nm_uvreq_t *uvreq = NULL; local
2665 uvreq = isc__nm_uvreq_get(sock);
2666 isc_nmhandle_attach(handle, &uvreq->handle);
2667 uvreq->cb.send = cb;
2668 uvreq->cbarg = cbarg;
2670 uvreq->uvbuf.base = (char *)region->base;
2671 uvreq->uvbuf.len = region->length;
2673 isc_job_run(sock->worker->loop, &uvreq->job, http_send_cb, uvreq);
|
