Searched refs:nb_received (Results 1 – 15 of 15) sorted by relevance
48 MLX5_ASSERT(mp_rep.nb_received == 1); in mlx5_mp_req_mr_create()95 MLX5_ASSERT(mp_rep.nb_received == 1); in mlx5_mp_req_mempool_reg()137 MLX5_ASSERT(mp_rep.nb_received == 1); in mlx5_mp_req_queue_state_modify()172 MLX5_ASSERT(mp_rep.nb_received == 1); in mlx5_mp_req_verbs_cmd_fd()
209 if (mp_rep.nb_sent != mp_rep.nb_received) { in mp_req_on_rxtx()214 for (i = 0; i < mp_rep.nb_received; i++) { in mp_req_on_rxtx()284 MLX4_ASSERT(mp_rep.nb_received == 1); in mlx4_mp_req_mr_create()321 MLX4_ASSERT(mp_rep.nb_received == 1); in mlx4_mp_req_verbs_cmd_fd()
447 (reply->nb_received + 1)); in process_async_request()458 memcpy(&user_msgs[reply->nb_received], in process_async_request()460 reply->nb_received++; in process_async_request()968 tmp = realloc(reply->msgs, sizeof(msg) * (reply->nb_received + 1)); in mp_request_sync()975 memcpy(&tmp[reply->nb_received], &msg, sizeof(msg)); in mp_request_sync()977 reply->nb_received++; in mp_request_sync()995 reply->nb_received = 0; in rte_mp_request_sync()1072 reply->nb_received = 0; in rte_mp_request_sync()1132 reply->nb_received = 0; in rte_mp_request_async()
378 if (ret || mp_reply.nb_received != 1) { in eal_dev_hotplug_request_to_primary()415 if (mp_reply.nb_sent != mp_reply.nb_received) { in eal_dev_hotplug_request_to_secondary()422 for (i = 0; i < mp_reply.nb_received; i++) { in eal_dev_hotplug_request_to_secondary()
421 if (reply->nb_received != reply->nb_sent) in handle_sync_response()424 for (i = 0; i < reply->nb_received; i++) { in handle_sync_response()664 if (reply.nb_received != reply.nb_sent) { in request_sync()669 for (i = 0; i < reply.nb_received; i++) { in request_sync()
252 if (mp_rep.nb_sent != mp_rep.nb_received) { in mp_req_on_rxtx()258 for (i = 0; i < mp_rep.nb_received; i++) { in mp_req_on_rxtx()337 MLX5_ASSERT(mp_rep.nb_received == 1); in mlx5_mp_os_req_queue_control()
169 if (mp_rep.nb_sent != mp_rep.nb_received) { in mp_req_on_rxtx()175 for (i = 0; i < mp_rep.nb_received; i++) { in mp_req_on_rxtx()
173 int nb_received; member
405 mp_reply.nb_received == 1) { in vfio_open_group_fd()685 mp_reply.nb_received == 1) { in vfio_sync_default_container()1178 mp_reply.nb_received == 1) { in vfio_get_default_container_fd()1314 mp_reply.nb_received == 1) { in rte_vfio_get_container_fd()
491 mp_reply.nb_received == 1) { in vdev_scan()
272 * ``nb_received`` - number indicating how many responses were received (i.e. of343 If some of the messages timed out, ``nb_sent`` and ``nb_received`` fields in the
1864 if (ret < 0 || replies.nb_received != 1) { in afxdp_mp_request_fds()
151 if (ret < 0 || replies.nb_received != 1) { in memif_mp_request_regions()
2396 if (ret < 0 || replies.nb_received != 1) { in tap_mp_attach_queues()
444 RTE_ASSERT(mp_rep.nb_received == 1); \