/dports/net/mpich/mpich-3.4.3/modules/ucx/src/ucg/builtin/ops/ |
H A D | builtin_comp.c | 380 *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 D | vmci_datagram.c | 30 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 D | vmci_datagram.c | 30 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 D | vmci_datagram.c | 30 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 D | udp.c | 76 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 D | messages_ctdb_ref.c | 30 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 D | messages_dgm_ref.c | 30 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 D | messages_ctdb.c | 55 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 D | dpdk_io_service_client.hpp | 38 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 D | udp.c | 85 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 D | udp.c | 246 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 D | udp.c | 123 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 D | udp.c | 123 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 D | udp.c | 123 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 D | udp.c | 121 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 D | udp.c | 121 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 D | udp.c | 118 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 D | udp.c | 123 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 D | ce.c | 25 .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 D | ce.c | 25 .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 D | ce.c | 25 .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 D | udp.c | 294 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 D | s2n_tls.rs | 78 .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 D | udp.c | 86 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 D | chdr_rx_data_xport.cpp | 61 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()
|