| /dpdk/lib/eal/linux/ |
| H A D | eal_vfio_mp_sync.c | 29 struct rte_mp_msg reply; in vfio_mp_primary() local 39 memset(&reply, 0, sizeof(reply)); in vfio_mp_primary() 54 reply.num_fds = 1; in vfio_mp_primary() 55 reply.fds[0] = fd; in vfio_mp_primary() 65 reply.num_fds = 1; in vfio_mp_primary() 66 reply.fds[0] = fd; in vfio_mp_primary() 76 reply.num_fds = 1; in vfio_mp_primary() 77 reply.fds[0] = fd; in vfio_mp_primary() 101 strcpy(reply.name, EAL_VFIO_MP); in vfio_mp_primary() 102 reply.len_param = sizeof(*r); in vfio_mp_primary() [all …]
|
| /dpdk/lib/eal/common/ |
| H A D | eal_common_proc.c | 443 msg = sr->reply; in process_async_request() 467 reply->nb_sent--; in process_async_request() 475 free(sr->reply); in process_async_request() 944 reply->nb_sent++; in mp_request_sync() 964 reply->nb_sent--; in mp_request_sync() 968 tmp = realloc(reply->msgs, sizeof(msg) * (reply->nb_received + 1)); in mp_request_sync() 976 reply->msgs = tmp; in mp_request_sync() 994 reply->nb_sent = 0; in rte_mp_request_sync() 996 reply->msgs = NULL; in rte_mp_request_sync() 1071 free(reply->msgs); in rte_mp_request_sync() [all …]
|
| H A D | malloc_mp.c | 34 const struct rte_mp_reply *reply); 37 const struct rte_mp_reply *reply); 149 struct rte_mp_msg reply; in handle_sync() local 161 memset(&reply, 0, sizeof(reply)); in handle_sync() 163 reply.num_fds = 0; in handle_sync() 164 strlcpy(reply.name, msg->name, sizeof(reply.name)); in handle_sync() 421 if (reply->nb_received != reply->nb_sent) in handle_sync_response() 630 struct rte_mp_reply reply; in request_sync() local 636 memset(&reply, 0, sizeof(reply)); in request_sync() 664 if (reply.nb_received != reply.nb_sent) { in request_sync() [all …]
|
| /dpdk/drivers/net/bnx2x/ |
| H A D | bnx2x_vfpf.c | 381 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_init() 512 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_setup_queue() 556 struct vf_common_reply_tlv *reply; in bnx2x_vf_set_mac() local 581 reply = &sc->vf2pf_mbox->resp.common_reply; in bnx2x_vf_set_mac() 596 if (BNX2X_VF_STATUS_SUCCESS != reply->status) { in bnx2x_vf_set_mac() 598 reply->status); in bnx2x_vf_set_mac() 638 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_config_rss() 696 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_set_rx_mode() 713 struct vf_common_reply_tlv *reply = in bnx2x_vfpf_set_mcast() local 749 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vfpf_set_mcast() [all …]
|
| /dpdk/lib/eal/windows/ |
| H A D | eal_mp.c | 52 rte_mp_request_sync(struct rte_mp_msg *req, struct rte_mp_reply *reply, in rte_mp_request_sync() argument 56 RTE_SET_USED(reply); in rte_mp_request_sync()
|
| /dpdk/lib/eal/include/ |
| H A D | rte_eal.h | 207 const struct rte_mp_reply *reply); 294 rte_mp_request_sync(struct rte_mp_msg *req, struct rte_mp_reply *reply,
|
| /dpdk/usertools/ |
| H A D | dpdk-telemetry.py | 28 reply = sock.recv(buf_len).decode() 30 ret = json.loads(reply) 32 print("Error in reply: ", reply)
|
| /dpdk/drivers/net/memif/ |
| H A D | rte_eth_memif.c | 89 struct rte_mp_msg reply; in memif_mp_send_region() local 101 memset(&reply, 0, sizeof(reply)); in memif_mp_send_region() 102 strlcpy(reply.name, msg->name, sizeof(reply.name)); in memif_mp_send_region() 107 reply.num_fds = 1; in memif_mp_send_region() 127 struct rte_mp_msg msg, *reply; in memif_mp_request_regions() local 157 reply = &replies.msgs[0]; in memif_mp_request_regions() 164 free(reply); in memif_mp_request_regions() 168 if (reply->num_fds < 1) { in memif_mp_request_regions() 170 free(reply); in memif_mp_request_regions() 173 r->fd = reply->fds[0]; in memif_mp_request_regions() [all …]
|
| /dpdk/drivers/net/af_xdp/ |
| H A D | rte_eth_af_xdp.c | 1849 struct rte_mp_msg request, *reply; in afxdp_mp_request_fds() local 1869 reply = replies.msgs; in afxdp_mp_request_fds() 1877 for (i = 0; i < reply->num_fds; i++) in afxdp_mp_request_fds() 1880 free(reply); in afxdp_mp_request_fds() 1890 struct rte_mp_msg reply; in afxdp_mp_send_fds() local 1894 (struct ipc_hdr *)reply.param; in afxdp_mp_send_fds() 1910 reply.num_fds = 0; in afxdp_mp_send_fds() 1918 reply.fds[reply.num_fds++] = process_private->rxq_xsk_fds[i]; in afxdp_mp_send_fds() 1921 strlcpy(reply.name, request->name, sizeof(reply.name)); in afxdp_mp_send_fds() 1924 reply.len_param = sizeof(*reply_param); in afxdp_mp_send_fds() [all …]
|
| /dpdk/drivers/net/tap/ |
| H A D | rte_eth_tap.c | 2381 struct rte_mp_msg request, *reply; in tap_mp_attach_queues() local 2401 reply = &replies.msgs[0]; in tap_mp_attach_queues() 2418 free(reply); in tap_mp_attach_queues() 2428 struct rte_mp_msg reply; in tap_mp_sync_queues() local 2432 (struct ipc_queues *)reply.param; in tap_mp_sync_queues() 2446 reply.num_fds = 0; in tap_mp_sync_queues() 2455 reply.fds[reply.num_fds++] = process_private->rxq_fds[queue]; in tap_mp_sync_queues() 2462 reply.fds[reply.num_fds++] = process_private->txq_fds[queue]; in tap_mp_sync_queues() 2468 strlcpy(reply.name, request->name, sizeof(reply.name)); in tap_mp_sync_queues() 2471 reply.len_param = sizeof(*reply_param); in tap_mp_sync_queues() [all …]
|
| /dpdk/drivers/net/fm10k/base/ |
| H A D | fm10k_tlv.c | 759 u32 reply[3]; in fm10k_tlv_msg_test() local 882 fm10k_tlv_msg_init(reply, FM10K_TLV_MSG_ID_TEST); in fm10k_tlv_msg_test() 883 fm10k_tlv_attr_put_s32(reply, FM10K_TEST_MSG_RESULT, err); in fm10k_tlv_msg_test() 886 return mbx->ops.enqueue_tx(hw, mbx, reply); in fm10k_tlv_msg_test()
|
| /dpdk/doc/guides/vdpadevs/features/ |
| H A D | default.ini | 37 proto reply ack =
|
| /dpdk/doc/guides/prog_guide/ |
| H A D | telemetry_lib.rst | 101 by the handler function in the library/app, placed in a JSON reply by telemetry:: 122 by the handler function in telemetry, placed in a JSON reply by telemetry::
|
| H A D | toeplitz_hash_lib.rst | 276 * destination port on reply.
|
| H A D | multi_proc_support.rst | 259 Sending requests involves waiting for the other side to reply, so they can block
|
| H A D | rte_flow.rst | 1240 - ``op``: opcode (1 for request, 2 for reply). 3234 | ``reply_dir`` | TCP parameters of the reply direction | 3262 | ``reply_end`` | max{sack + max{win, 1}} seen in reply packets |
|
| /dpdk/doc/guides/vdpadevs/ |
| H A D | features_overview.rst | 90 proto reply ack
|
| /dpdk/doc/guides/rel_notes/ |
| H A D | release_2_1.rst | 418 * **app/testpmd: Fix reply to a multicast ICMP request.** 421 reply. 424 * **app/testpmd: fix MAC address in ARP reply.**
|
| H A D | release_18_02.rst | 190 it gets a reply message which is sent from the peer by ``rte_mp_reply``.
|
| /dpdk/doc/guides/nics/ |
| H A D | hns3.rst | 126 scheduling of the system will be very busy, and the reply of the
|
| /dpdk/doc/guides/contributing/ |
| H A D | vulnerability.rst | 66 Upon reception of the report, a security team member should reply
|
| H A D | patches.rst | 540 git send-email --to [email protected] --in-reply-to <[email protected]> 000*.patch 544 Shallow threading (``--thread --no-chain-reply-to``) is preferred for a patch series.
|