Home
last modified time | relevance | path

Searched refs:recv_cb (Results 1 – 25 of 283) sorted by relevance

12345678910>>...12

/dports/net/mpich/mpich-3.4.3/modules/ucx/src/ucg/builtin/ops/
H A Dbuiltin_comp.c380 *recv_cb = ucg_builtin_comp_recv_one_then_send_cb; in ucg_builtin_step_select_callbacks()
386 *recv_cb = ucg_builtin_comp_recv_many_then_send_pipe_cb; in ucg_builtin_step_select_callbacks()
396 *recv_cb = ucg_builtin_comp_recv_one_then_send_cb; in ucg_builtin_step_select_callbacks()
420 *recv_cb = is_single_msg ? ucg_builtin_comp_recv_one_cb : in ucg_builtin_step_select_callbacks()
430 *recv_cb = ucg_builtin_comp_wait_many_then_send_cb; in ucg_builtin_step_select_callbacks()
488 *recv_cb = nonzero_length ? in ucg_builtin_step_select_callbacks()
496 *recv_cb = nonzero_length ? in ucg_builtin_step_select_callbacks()
504 *recv_cb = nonzero_length ? in ucg_builtin_step_select_callbacks()
534 *recv_cb = ucg_builtin_comp_recv_one_cb; in ucg_builtin_step_select_callbacks()
604 if (step->recv_cb == ucg_builtin_comp_reduce_one_cb) { in ucg_builtin_optimize_bcopy_to_zcopy()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/misc/vmw_vmci/
H A Dvmci_datagram.c30 vmci_datagram_recv_cb recv_cb; member
53 vmci_datagram_recv_cb recv_cb, in dg_create_handle() argument
82 entry->recv_cb = recv_cb; in dg_create_handle()
141 dg_info->entry->recv_cb(dg_info->entry->client_data, &dg_info->msg); in dg_delayed_dispatch()
244 retval = dst_entry->recv_cb(dst_entry->client_data, dg); in dg_dispatch_as_host()
385 dst_entry->recv_cb(dst_entry->client_data, dg); in vmci_datagram_invoke_guest_handler()
406 vmci_datagram_recv_cb recv_cb, in vmci_datagram_create_handle_priv() argument
413 if (recv_cb == NULL) { in vmci_datagram_create_handle_priv()
421 return dg_create_handle(resource_id, flags, priv_flags, recv_cb, in vmci_datagram_create_handle_priv()
440 vmci_datagram_recv_cb recv_cb, in vmci_datagram_create_handle() argument
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/misc/vmw_vmci/
H A Dvmci_datagram.c30 vmci_datagram_recv_cb recv_cb; member
53 vmci_datagram_recv_cb recv_cb, in dg_create_handle() argument
82 entry->recv_cb = recv_cb; in dg_create_handle()
141 dg_info->entry->recv_cb(dg_info->entry->client_data, &dg_info->msg); in dg_delayed_dispatch()
244 retval = dst_entry->recv_cb(dst_entry->client_data, dg); in dg_dispatch_as_host()
385 dst_entry->recv_cb(dst_entry->client_data, dg); in vmci_datagram_invoke_guest_handler()
406 vmci_datagram_recv_cb recv_cb, in vmci_datagram_create_handle_priv() argument
413 if (recv_cb == NULL) { in vmci_datagram_create_handle_priv()
421 return dg_create_handle(resource_id, flags, priv_flags, recv_cb, in vmci_datagram_create_handle_priv()
440 vmci_datagram_recv_cb recv_cb, in vmci_datagram_create_handle() argument
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/misc/vmw_vmci/
H A Dvmci_datagram.c30 vmci_datagram_recv_cb recv_cb; member
53 vmci_datagram_recv_cb recv_cb, in dg_create_handle() argument
82 entry->recv_cb = recv_cb; in dg_create_handle()
141 dg_info->entry->recv_cb(dg_info->entry->client_data, &dg_info->msg); in dg_delayed_dispatch()
244 retval = dst_entry->recv_cb(dst_entry->client_data, dg); in dg_dispatch_as_host()
385 dst_entry->recv_cb(dst_entry->client_data, dg); in vmci_datagram_invoke_guest_handler()
406 vmci_datagram_recv_cb recv_cb, in vmci_datagram_create_handle_priv() argument
413 if (recv_cb == NULL) { in vmci_datagram_create_handle_priv()
421 return dg_create_handle(resource_id, flags, priv_flags, recv_cb, in vmci_datagram_create_handle_priv()
440 vmci_datagram_recv_cb recv_cb, in vmci_datagram_create_handle() argument
[all …]
/dports/net/cjdns/cjdns-cjdns-v21.1/node_build/dependencies/libuv/src/unix/
H A Dudp.c76 handle->recv_cb = NULL; in uv__udp_finish_close()
179 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
209 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
211 handle->recv_cb(handle, -errno, &buf, NULL, 0); in uv__udp_recvmsg()
219 handle->recv_cb(handle, in uv__udp_recvmsg()
230 && handle->recv_cb != NULL); in uv__udp_recvmsg()
428 handle->recv_cb = NULL; in uv_udp_init()
562 uv_udp_recv_cb recv_cb) { in uv__udp_recv_start() argument
565 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
576 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/net/samba412/samba-4.12.15/source3/lib/
H A Dmessages_ctdb_ref.c30 void (*recv_cb)(struct tevent_context *ev, member
46 void (*recv_cb)(struct tevent_context *ev, in messaging_ctdb_ref()
97 result->recv_cb = recv_cb; in messaging_ctdb_ref()
124 r->recv_cb(ev, msg, msg_len, fds, num_fds, in msg_ctdb_ref_recv()
H A Dmessages_dgm_ref.c30 void (*recv_cb)(struct tevent_context *ev, member
49 void (*recv_cb)(struct tevent_context *ev, in messaging_dgm_ref()
113 result->recv_cb = recv_cb; in messaging_dgm_ref()
144 r->recv_cb(ev, msg, msg_len, fds, num_fds, in msg_dgm_ref_recv()
H A Dmessages_ctdb.c55 void (*recv_cb)(struct tevent_context *ev, member
72 state->recv_cb(ev, msg, msg_len, NULL, 0, state->recv_cb_private_data); in messaging_ctdb_recv()
80 void (*recv_cb)(struct tevent_context *ev, in messaging_ctdb_init()
97 ctx->recv_cb = recv_cb; in messaging_ctdb_init()
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/include/uhdlib/transport/
H A Ddpdk_io_service_client.hpp38 recv_callback_t recv_cb) in dpdk_io_if()
39 : is_recv(is_recv), link(link), io_srv(io_srv), recv_cb(recv_cb) in dpdk_io_if()
46 recv_callback_t recv_cb; member
67 recv_callback_t recv_cb, in dpdk_send_io() argument
69 : _dpdk_io_if(false, link, io_srv, recv_cb) in dpdk_send_io()
187 recv_callback_t recv_cb, in dpdk_recv_io() argument
190 : _dpdk_io_if(true, link, io_srv, recv_cb) in dpdk_recv_io()
/dports/archivers/maxcso/maxcso-1.10.0/libuv/src/unix/
H A Dudp.c85 handle->recv_cb = NULL; in uv__udp_finish_close()
159 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
174 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv__udp_recvmsg()
190 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
205 handle->recv_cb(handle, nread, &buf, addr, flags); in uv__udp_recvmsg()
212 && handle->recv_cb != NULL); in uv__udp_recvmsg()
605 handle->recv_cb = NULL; in uv_udp_init_ex()
869 uv_udp_recv_cb recv_cb) { in uv__udp_recv_start() argument
872 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
883 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/net/cjdns/cjdns-cjdns-v21.1/node_build/dependencies/libuv/src/win/
H A Dudp.c246 handle->recv_cb(handle, UV_ENOBUFS, &handle->recv_buffer, NULL, 0); in uv_udp_queue_recv()
319 uv_udp_recv_cb recv_cb) { in uv__udp_recv_start() argument
340 handle->recv_cb = recv_cb; in uv__udp_recv_start()
438 handle->recv_cb(handle, uv_translate_sys_error(err), &buf, NULL, 0); in uv_process_udp_recv_req()
447 handle->recv_cb(handle, in uv_process_udp_recv_req()
461 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv_process_udp_recv_req()
482 handle->recv_cb(handle, bytes, &buf, (const struct sockaddr*) &from, 0); in uv_process_udp_recv_req()
487 handle->recv_cb(handle, in uv_process_udp_recv_req()
494 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv_process_udp_recv_req()
499 handle->recv_cb(handle, uv_translate_sys_error(err), &buf, NULL, 0); in uv_process_udp_recv_req()
/dports/sysutils/R-cran-fs/fs/src/libuv-1.38.1/src/unix/
H A Dudp.c123 handle->recv_cb = NULL; in uv__udp_finish_close()
221 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
232 handle->recv_cb(handle, in uv__udp_recvmmsg()
240 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
241 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
255 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
315 && handle->recv_cb != NULL); in uv__udp_recvmsg()
970 handle->recv_cb = NULL; in uv__udp_init_ex()
1288 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1299 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/devel/cmake-gui/cmake-3.22.1/Utilities/cmlibuv/src/unix/
H A Dudp.c123 handle->recv_cb = NULL; in uv__udp_finish_close()
221 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
232 handle->recv_cb(handle, in uv__udp_recvmmsg()
240 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
255 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
295 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
312 && handle->recv_cb != NULL); in uv__udp_recvmsg()
969 handle->recv_cb = NULL; in uv__udp_init_ex()
1302 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1313 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/devel/cmake-doc/cmake-3.22.1/Utilities/cmlibuv/src/unix/
H A Dudp.c123 handle->recv_cb = NULL; in uv__udp_finish_close()
221 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
232 handle->recv_cb(handle, in uv__udp_recvmmsg()
240 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
255 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
295 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
312 && handle->recv_cb != NULL); in uv__udp_recvmsg()
969 handle->recv_cb = NULL; in uv__udp_init_ex()
1302 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1313 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/devel/py-uvloop/uvloop-0.16.0/vendor/libuv/src/unix/
H A Dudp.c121 handle->recv_cb = NULL; in uv__udp_finish_close()
219 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
230 handle->recv_cb(handle, in uv__udp_recvmmsg()
238 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
253 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
293 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
310 && handle->recv_cb != NULL); in uv__udp_recvmsg()
995 handle->recv_cb = NULL; in uv__udp_init_ex()
1328 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1339 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/devel/libuv/libuv-v1.42.0/src/unix/
H A Dudp.c121 handle->recv_cb = NULL; in uv__udp_finish_close()
219 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
230 handle->recv_cb(handle, in uv__udp_recvmmsg()
238 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
253 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
293 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
310 && handle->recv_cb != NULL); in uv__udp_recvmsg()
995 handle->recv_cb = NULL; in uv__udp_init_ex()
1328 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1339 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/www/R-cran-httpuv/httpuv/src/libuv/src/unix/
H A Dudp.c118 handle->recv_cb = NULL; in uv__udp_finish_close()
213 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
224 handle->recv_cb(handle, in uv__udp_recvmmsg()
232 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
233 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
247 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
307 && handle->recv_cb != NULL); in uv__udp_recvmsg()
975 handle->recv_cb = NULL; in uv_udp_init_ex()
1311 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1322 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/devel/cmake/cmake-3.22.1/Utilities/cmlibuv/src/unix/
H A Dudp.c123 handle->recv_cb = NULL; in uv__udp_finish_close()
221 handle->recv_cb(handle, 0, buf, NULL, 0); in uv__udp_recvmmsg()
232 handle->recv_cb(handle, in uv__udp_recvmmsg()
240 if (handle->recv_cb != NULL) in uv__udp_recvmmsg()
255 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
295 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
312 && handle->recv_cb != NULL); in uv__udp_recvmsg()
969 handle->recv_cb = NULL; in uv__udp_init_ex()
1302 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1313 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/wireless/ath/ath11k/
H A Dce.c25 .recv_cb = ath11k_htc_rx_completion_handler,
34 .recv_cb = ath11k_htc_rx_completion_handler,
59 .recv_cb = ath11k_dp_htt_htc_t2h_msg_handler,
100 .recv_cb = ath11k_htc_rx_completion_handler,
127 .recv_cb = ath11k_htc_rx_completion_handler,
136 .recv_cb = ath11k_htc_rx_completion_handler,
205 .recv_cb = ath11k_htc_rx_completion_handler,
214 .recv_cb = ath11k_htc_rx_completion_handler,
439 pipe->recv_cb(ab, skb); in ath11k_ce_recv_process_cb()
649 pipe->recv_cb = attr->recv_cb; in ath11k_ce_alloc_pipe()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/wireless/ath/ath11k/
H A Dce.c25 .recv_cb = ath11k_htc_rx_completion_handler,
34 .recv_cb = ath11k_htc_rx_completion_handler,
59 .recv_cb = ath11k_dp_htt_htc_t2h_msg_handler,
100 .recv_cb = ath11k_htc_rx_completion_handler,
127 .recv_cb = ath11k_htc_rx_completion_handler,
136 .recv_cb = ath11k_htc_rx_completion_handler,
205 .recv_cb = ath11k_htc_rx_completion_handler,
214 .recv_cb = ath11k_htc_rx_completion_handler,
439 pipe->recv_cb(ab, skb); in ath11k_ce_recv_process_cb()
649 pipe->recv_cb = attr->recv_cb; in ath11k_ce_alloc_pipe()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/wireless/ath/ath11k/
H A Dce.c25 .recv_cb = ath11k_htc_rx_completion_handler,
34 .recv_cb = ath11k_htc_rx_completion_handler,
59 .recv_cb = ath11k_dp_htt_htc_t2h_msg_handler,
100 .recv_cb = ath11k_htc_rx_completion_handler,
127 .recv_cb = ath11k_htc_rx_completion_handler,
136 .recv_cb = ath11k_htc_rx_completion_handler,
205 .recv_cb = ath11k_htc_rx_completion_handler,
214 .recv_cb = ath11k_htc_rx_completion_handler,
439 pipe->recv_cb(ab, skb); in ath11k_ce_recv_process_cb()
649 pipe->recv_cb = attr->recv_cb; in ath11k_ce_alloc_pipe()
[all …]
/dports/archivers/maxcso/maxcso-1.10.0/libuv/src/win/
H A Dudp.c294 handle->recv_cb(handle, UV_ENOBUFS, &handle->recv_buffer, NULL, 0); in uv_udp_queue_recv()
367 uv_udp_recv_cb recv_cb) { in uv__udp_recv_start() argument
386 handle->recv_cb = recv_cb; in uv__udp_recv_start()
487 handle->recv_cb(handle, uv_translate_sys_error(err), &buf, NULL, 0); in uv_process_udp_recv_req()
496 handle->recv_cb(handle, in uv_process_udp_recv_req()
511 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv_process_udp_recv_req()
532 handle->recv_cb(handle, bytes, &buf, (const struct sockaddr*) &from, 0); in uv_process_udp_recv_req()
537 handle->recv_cb(handle, in uv_process_udp_recv_req()
544 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv_process_udp_recv_req()
549 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv_process_udp_recv_req()
[all …]
/dports/security/s2n/s2n-tls-1.1.2/bindings/rust/s2n-tls/src/testing/
H A Ds2n_tls.rs78 .set_receive_callback(Some(Self::recv_cb)) in set()
94 unsafe extern "C" fn recv_cb( in unset() function
105 connection.set_receive_callback(Some(recv_cb)).unwrap(); in unset()
169 unsafe extern "C" fn recv_cb(context: *mut c_void, data: *mut u8, len: u32) -> s2n_status_code { in recv_cb() method
/dports/www/node10/node-v10.24.1/deps/uv/src/unix/
H A Dudp.c86 handle->recv_cb = NULL; in uv__udp_finish_close()
160 assert(handle->recv_cb != NULL); in uv__udp_recvmsg()
172 handle->recv_cb(handle, UV_ENOBUFS, &buf, NULL, 0); in uv__udp_recvmsg()
191 handle->recv_cb(handle, 0, &buf, NULL, 0); in uv__udp_recvmsg()
193 handle->recv_cb(handle, UV__ERR(errno), &buf, NULL, 0); in uv__udp_recvmsg()
207 && handle->recv_cb != NULL); in uv__udp_recvmsg()
774 handle->recv_cb = NULL; in uv_udp_init_ex()
1103 uv_udp_recv_cb recv_cb) { in uv__udp_recv_start() argument
1106 if (alloc_cb == NULL || recv_cb == NULL) in uv__udp_recv_start()
1117 handle->recv_cb = recv_cb; in uv__udp_recv_start()
[all …]
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/rfnoc/
H A Dchdr_rx_data_xport.cpp61 auto recv_cb = in chdr_rx_data_xport() local
74 recv_cb, in chdr_rx_data_xport()
119 auto recv_cb = [&pkt, local_epid, &strc](buff_t::uptr& buff, in configure_sep() local
161 recv_cb, in configure_sep()

12345678910>>...12