Home
last modified time | relevance | path

Searched refs:recv_cb (Results 1 - 25 of 27) sorted by relevance

12

/third_party/libuv/src/unix/
H A Dudp.c85 handle->recv_cb = NULL; in uv__udp_finish_close()
184 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
186 handle->recv_cb(handle, UV__ERR(errno), buf, NULL, 0); in uv__udp_recvmmsg()
189 for (k = 0; k < (size_t) nread && handle->recv_cb != NULL; k++) { in uv__udp_recvmmsg()
195 handle->recv_cb(handle, in uv__udp_recvmmsg()
203 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
204 handle->recv_cb(handle, 0, buf, NULL, UV_UDP_MMSG_FREE); in uv__udp_recvmmsg()
220 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
232 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv__udp_recvmsg()
258 handle->recv_cb(handl in uv__udp_recvmsg()
1333 uv__udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloc_cb, uv_udp_recv_cb recv_cb) uv__udp_recv_start() argument
[all...]
/third_party/node/deps/uv/src/unix/
H A Dudp.c121 handle->recv_cb = NULL; in uv__udp_finish_close()
220 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
222 handle->recv_cb(handle, UV__ERR(errno), buf, NULL, 0); in uv__udp_recvmmsg()
225 for (k = 0; k < (size_t) nread && handle->recv_cb != NULL; k++) { in uv__udp_recvmmsg()
231 handle->recv_cb(handle, in uv__udp_recvmmsg()
239 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
240 handle->recv_cb(handle, 0, buf, NULL, UV_UDP_MMSG_FREE); in uv__udp_recvmmsg()
254 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
266 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv__udp_recvmsg()
294 handle->recv_cb(handl in uv__udp_recvmsg()
1381 uv__udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloc_cb, uv_udp_recv_cb recv_cb) uv__udp_recv_start() argument
[all...]
/third_party/curl/lib/vquic/
H A Dvquic.c337 vquic_recv_pkt_cb *recv_cb, void *userp) in recvmmsg_packets()
393 result = recv_cb(bufs[i], mmsg[i].msg_len, in recvmmsg_packets()
413 vquic_recv_pkt_cb *recv_cb, void *userp) in recvmsg_packets()
461 result = recv_cb(buf, (size_t)nread, msg.msg_name, msg.msg_namelen, in recvmsg_packets()
479 vquic_recv_pkt_cb *recv_cb, void *userp) in recvfrom_packets()
521 result = recv_cb(buf, (size_t)nread, &remote_addr, remote_addrlen, in recvfrom_packets()
539 vquic_recv_pkt_cb *recv_cb, void *userp) in vquic_recv_packets()
543 result = recvmmsg_packets(cf, data, qctx, max_pkts, recv_cb, userp); in vquic_recv_packets()
545 result = recvmsg_packets(cf, data, qctx, max_pkts, recv_cb, userp); in vquic_recv_packets()
547 result = recvfrom_packets(cf, data, qctx, max_pkts, recv_cb, user in vquic_recv_packets()
333 recvmmsg_packets(struct Curl_cfilter *cf, struct Curl_easy *data, struct cf_quic_ctx *qctx, size_t max_pkts, vquic_recv_pkt_cb *recv_cb, void *userp) recvmmsg_packets() argument
409 recvmsg_packets(struct Curl_cfilter *cf, struct Curl_easy *data, struct cf_quic_ctx *qctx, size_t max_pkts, vquic_recv_pkt_cb *recv_cb, void *userp) recvmsg_packets() argument
475 recvfrom_packets(struct Curl_cfilter *cf, struct Curl_easy *data, struct cf_quic_ctx *qctx, size_t max_pkts, vquic_recv_pkt_cb *recv_cb, void *userp) recvfrom_packets() argument
535 vquic_recv_packets(struct Curl_cfilter *cf, struct Curl_easy *data, struct cf_quic_ctx *qctx, size_t max_pkts, vquic_recv_pkt_cb *recv_cb, void *userp) vquic_recv_packets() argument
[all...]
H A Dvquic_int.h89 vquic_recv_pkt_cb *recv_cb, void *userp);
/third_party/node/deps/uv/src/win/
H A Dudp.c289 handle->recv_cb(handle, UV_ENOBUFS, &handle->recv_buffer, NULL, 0); in uv__udp_queue_recv()
362 uv_udp_recv_cb recv_cb) { in uv__udp_recv_start()
381 handle->recv_cb = recv_cb; in uv__udp_recv_start()
482 handle->recv_cb(handle, uv_translate_sys_error(err), &buf, NULL, 0); in uv__process_udp_recv_req()
491 handle->recv_cb(handle, in uv__process_udp_recv_req()
506 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv__process_udp_recv_req()
527 handle->recv_cb(handle, bytes, &buf, (const struct sockaddr*) &from, 0); in uv__process_udp_recv_req()
532 handle->recv_cb(handle, in uv__process_udp_recv_req()
539 handle->recv_cb(handl in uv__process_udp_recv_req()
361 uv__udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloc_cb, uv_udp_recv_cb recv_cb) uv__udp_recv_start() argument
[all...]
/third_party/libuv/src/win/
H A Dudp.c308 uv_udp_recv_cb recv_cb) { in uv__udp_recv_start()
326 handle->recv_cb = recv_cb; in uv__udp_recv_start()
426 handle->recv_cb(handle, uv_translate_sys_error(err), &buf, NULL, 0); in uv__process_udp_recv_req()
435 handle->recv_cb(handle, in uv__process_udp_recv_req()
455 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv__process_udp_recv_req()
476 handle->recv_cb(handle, bytes, &buf, (const struct sockaddr*) &from, 0); in uv__process_udp_recv_req()
481 handle->recv_cb(handle, in uv__process_udp_recv_req()
488 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__process_udp_recv_req()
493 handle->recv_cb(handl in uv__process_udp_recv_req()
307 uv__udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloc_cb, uv_udp_recv_cb recv_cb) uv__udp_recv_start() argument
[all...]
/third_party/libuv/test/
H A Dtest-udp-send-unreachable.c77 static void recv_cb(uv_udp_t* handle, in recv_cb() function
134 r = uv_udp_recv_start(&client, alloc_cb, recv_cb); in TEST_IMPL()
167 r = uv_udp_recv_start(&client2, alloc_cb, recv_cb); in TEST_IMPL()
H A Dtest-watcher-cross-stop.c48 static void recv_cb(uv_udp_t* handle, in recv_cb() function
88 ASSERT_OK(uv_udp_recv_start(&sockets[i], alloc_cb, recv_cb)); in TEST_IMPL()
H A Dtest-udp-open.c99 static void recv_cb(uv_udp_t* handle, in recv_cb() function
159 r = uv_udp_recv_start(&client, alloc_cb, recv_cb); in TEST_IMPL()
242 r = uv_udp_recv_start(&client, alloc_cb, recv_cb); in TEST_IMPL()
280 r = uv_udp_recv_start(&server, alloc_cb, recv_cb); in TEST_IMPL()
H A Dtest-udp-mmsg.c71 static void recv_cb(uv_udp_t* handle, in recv_cb() function
120 ASSERT_OK(uv_udp_recv_start(&recver, alloc_cb, recv_cb)); in TEST_IMPL()
H A Dbenchmark-udp-pummel.c109 static void recv_cb(uv_udp_t* handle, in recv_cb() function
178 ASSERT_OK(uv_udp_recv_start(&s->udp_handle, alloc_cb, recv_cb)); in pummel()
H A Dtest-udp-ipv6.c145 static void do_test(uv_udp_recv_cb recv_cb, int bind_flags) { in do_test() argument
172 r = uv_udp_recv_start(&server, alloc_cb, recv_cb); in do_test()
H A Dtest-ipc-send-recv.c88 static void recv_cb(uv_stream_t* handle, in recv_cb() function
108 /* Depending on the OS, the final recv_cb can be called after in recv_cb()
114 /* UV_EOF is only acceptable for the final recv_cb call */ in recv_cb()
168 r = uv_read_start((uv_stream_t*)&ctx.channel, alloc_cb, recv_cb); in connect_cb()
/third_party/libuv/src/
H A Duv-common.c520 uv_udp_recv_cb recv_cb) { in uv_udp_recv_start()
521 if (handle->type != UV_UDP || alloc_cb == NULL || recv_cb == NULL) in uv_udp_recv_start()
524 return uv__udp_recv_start(handle, alloc_cb, recv_cb); in uv_udp_recv_start()
518 uv_udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloc_cb, uv_udp_recv_cb recv_cb) uv_udp_recv_start() argument
H A Duv-common.h195 uv_udp_recv_cb recv_cb);
/third_party/node/deps/uv/src/
H A Duv-common.c486 uv_udp_recv_cb recv_cb) { in uv_udp_recv_start()
487 if (handle->type != UV_UDP || alloc_cb == NULL || recv_cb == NULL) in uv_udp_recv_start()
490 return uv__udp_recv_start(handle, alloc_cb, recv_cb); in uv_udp_recv_start()
484 uv_udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloc_cb, uv_udp_recv_cb recv_cb) uv_udp_recv_start() argument
H A Duv-common.h191 uv_udp_recv_cb recv_cb);
/third_party/mbedtls/programs/ssl/
H A Dssl_test_common_source.c198 int recv_cb(void *ctx, unsigned char *buf, size_t len) in recv_cb() function
H A Dssl_client2.c2111 mbedtls_ssl_set_bio(&ssl, &io_ctx, send_cb, recv_cb, in main()
/third_party/libuv/include/uv/
H A Dunix.h302 uv_udp_recv_cb recv_cb; \
H A Dwin.h472 uv_udp_recv_cb recv_cb; \
/third_party/node/deps/uv/include/uv/
H A Dunix.h302 uv_udp_recv_cb recv_cb; \
H A Dwin.h468 uv_udp_recv_cb recv_cb; \
/third_party/libuv/include/
H A Duv.h672 * must not be freed by the recv_cb callback.
677 * that it should now be freed by the recv_cb callback. When this flag is set
767 uv_udp_recv_cb recv_cb);
/third_party/libuv/include/uv_ndk/
H A Duv.h616 * must not be freed by the recv_cb callback.
621 * that it should now be freed by the recv_cb callback. When this flag is set
711 uv_udp_recv_cb recv_cb);

Completed in 27 milliseconds

12