Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 87) sorted by relevance

1234

/dpdk/lib/eal/include/
H A Drte_test.h19 #define RTE_TEST_ASSERT(cond, msg, ...) do { \ argument
22 msg "\n", __func__, __LINE__, ##__VA_ARGS__); \
28 #define RTE_TEST_ASSERT_EQUAL(a, b, msg, ...) \ argument
29 RTE_TEST_ASSERT(a == b, msg, ##__VA_ARGS__)
31 #define RTE_TEST_ASSERT_NOT_EQUAL(a, b, msg, ...) \ argument
32 RTE_TEST_ASSERT(a != b, msg, ##__VA_ARGS__)
34 #define RTE_TEST_ASSERT_SUCCESS(val, msg, ...) \ argument
35 RTE_TEST_ASSERT(val == 0, msg, ##__VA_ARGS__)
37 #define RTE_TEST_ASSERT_FAIL(val, msg, ...) \ argument
38 RTE_TEST_ASSERT(val != 0, msg, ##__VA_ARGS__)
[all …]
/dpdk/drivers/raw/cnxk_gpio/
H A Drte_pmd_cnxk_gpio.h159 struct cnxk_gpio_msg msg = { in rte_pmd_gpio_set_pin_value() local
164 return __rte_pmd_gpio_enq_deq(dev_id, gpio, &msg, NULL, 0); in rte_pmd_gpio_set_pin_value()
184 struct cnxk_gpio_msg msg = { in rte_pmd_gpio_set_pin_edge() local
189 return __rte_pmd_gpio_enq_deq(dev_id, gpio, &msg, NULL, 0); in rte_pmd_gpio_set_pin_edge()
208 struct cnxk_gpio_msg msg = { in rte_pmd_gpio_set_pin_dir() local
213 return __rte_pmd_gpio_enq_deq(dev_id, gpio, &msg, NULL, 0); in rte_pmd_gpio_set_pin_dir()
238 struct cnxk_gpio_msg msg = { in rte_pmd_gpio_set_pin_active_low() local
243 return __rte_pmd_gpio_enq_deq(dev_id, gpio, &msg, NULL, 0); in rte_pmd_gpio_set_pin_active_low()
262 struct cnxk_gpio_msg msg = { in rte_pmd_gpio_get_pin_value() local
266 return __rte_pmd_gpio_enq_deq(dev_id, gpio, &msg, val, sizeof(*val)); in rte_pmd_gpio_get_pin_value()
[all …]
/dpdk/drivers/common/mlx5/
H A Dmlx5_common_mp.h96 mp_init_msg(struct mlx5_mp_id *mp_id, struct rte_mp_msg *msg, in mp_init_msg() argument
99 struct mlx5_mp_param *param = (struct mlx5_mp_param *)msg->param; in mp_init_msg()
101 memset(msg, 0, sizeof(*msg)); in mp_init_msg()
102 strlcpy(msg->name, mp_id->name, sizeof(msg->name)); in mp_init_msg()
103 msg->len_param = sizeof(*param); in mp_init_msg()
117 mp_init_port_agnostic_msg(struct rte_mp_msg *msg, enum mlx5_mp_req_type type) in mp_init_port_agnostic_msg() argument
119 struct mlx5_mp_param *param = (struct mlx5_mp_param *)msg->param; in mp_init_port_agnostic_msg()
121 memset(msg, 0, sizeof(*msg)); in mp_init_port_agnostic_msg()
122 strlcpy(msg->name, MLX5_MP_NAME, sizeof(msg->name)); in mp_init_port_agnostic_msg()
123 msg->len_param = sizeof(*param); in mp_init_port_agnostic_msg()
/dpdk/lib/eal/common/
H A Dmalloc_mp.c93 * S: if received msg of failure, quit
98 * S: if received msg of success, quit
102 * S: if received msg, quit
115 * S: if received msg of failure, quit
119 * S: if received msg, quit
149 handle_sync(const struct rte_mp_msg *msg, const void *peer) in handle_sync() argument
153 (const struct malloc_mp_req *)msg->param; in handle_sync()
166 strlcpy(reply.name, msg->name, sizeof(reply.name)); in handle_sync()
297 handle_request(const struct rte_mp_msg *msg, const void *peer __rte_unused) in handle_request() argument
300 (const struct malloc_mp_req *)msg in handle_request()
447 struct rte_mp_msg msg; handle_sync_response() local
468 struct rte_mp_msg msg; handle_sync_response() local
554 struct rte_mp_msg msg; handle_rollback_response() local
601 handle_response(const struct rte_mp_msg * msg,const void * peer __rte_unused) handle_response() argument
631 struct rte_mp_msg msg; request_sync() local
700 struct rte_mp_msg msg; request_to_primary() local
[all...]
H A Deal_common_proc.c64 struct rte_mp_msg msg; member
107 mp_send(struct rte_mp_msg *msg, const char *peer, int type);
268 char control[CMSG_SPACE(sizeof(m->msg.fds))]; in read_msg()
270 int buflen = sizeof(*m) - sizeof(m->msg.fds); in read_msg()
308 memcpy(m->msg.fds, CMSG_DATA(cmsg), sizeof(m->msg.fds)); in read_msg()
313 if (m->msg.num_fds < 0 || m->msg.num_fds > RTE_MP_MAX_FD_NUM) { in read_msg()
317 if (m->msg.len_param < 0 || m->msg.len_param > RTE_MP_MAX_PARAM_LEN) { in read_msg()
325 cleanup_msg_fds(const struct rte_mp_msg *msg) in cleanup_msg_fds() argument
329 for (i = 0; i < msg->num_fds; i++) in cleanup_msg_fds()
330 close(msg->fds[i]); in cleanup_msg_fds()
[all …]
H A Dhotplug_mp.c20 struct rte_mp_msg msg; member
89 const struct rte_mp_msg *msg = &bundle->msg; in __handle_secondary_request() local
91 (const struct eal_dev_mp_req *)msg->param; in __handle_secondary_request()
185 handle_secondary_request(const struct rte_mp_msg *msg, const void *peer) in handle_secondary_request() argument
189 (const struct eal_dev_mp_req *)msg->param; in handle_secondary_request()
198 bundle->msg = *msg; in handle_secondary_request()
228 struct rte_mp_msg *msg = &bundle->msg; in __handle_primary_request() local
230 (const struct eal_dev_mp_req *)msg->param; in __handle_primary_request()
306 handle_primary_request(const struct rte_mp_msg *msg, const void *peer) in handle_primary_request() argument
310 (const struct eal_dev_mp_req *)msg->param; in handle_primary_request()
[all …]
/dpdk/drivers/net/thunderx/base/
H A Dnicvf_mbox.h54 uint8_t msg; member
65 uint8_t msg; member
73 uint8_t msg; member
81 uint8_t msg; member
90 uint8_t msg; member
97 uint8_t msg; member
104 uint8_t msg; member
112 uint8_t msg; member
119 uint8_t msg; member
130 uint8_t msg; member
[all …]
/dpdk/drivers/crypto/bcmfs/hw/
H A Dbcmfs4_rm.c320 bcmfs4_sanity_check(struct bcmfs_qp_message *msg) in bcmfs4_sanity_check() argument
324 if (msg == NULL) in bcmfs4_sanity_check()
327 for (i = 0; i < msg->srcs_count; i++) { in bcmfs4_sanity_check()
328 if (msg->srcs_len[i] & 0xf) { in bcmfs4_sanity_check()
329 if (msg->srcs_len[i] > SRC_LENGTH_MASK) in bcmfs4_sanity_check()
332 if (msg->srcs_len[i] > (MSRC_LENGTH_MASK * 16)) in bcmfs4_sanity_check()
336 for (i = 0; i < msg->dsts_count; i++) { in bcmfs4_sanity_check()
337 if (msg->dsts_len[i] & 0xf) { in bcmfs4_sanity_check()
338 if (msg->dsts_len[i] > DST_LENGTH_MASK) in bcmfs4_sanity_check()
341 if (msg->dsts_len[i] > (MDST_LENGTH_MASK * 16)) in bcmfs4_sanity_check()
[all …]
H A Dbcmfs5_rm.c296 bcmfs5_sanity_check(struct bcmfs_qp_message *msg) in bcmfs5_sanity_check() argument
300 if (msg == NULL) in bcmfs5_sanity_check()
303 for (i = 0; i < msg->srcs_count; i++) { in bcmfs5_sanity_check()
304 if (msg->srcs_len[i] & 0xf) { in bcmfs5_sanity_check()
305 if (msg->srcs_len[i] > SRC_LENGTH_MASK) in bcmfs5_sanity_check()
308 if (msg->srcs_len[i] > (MSRC_LENGTH_MASK * 16)) in bcmfs5_sanity_check()
312 for (i = 0; i < msg->dsts_count; i++) { in bcmfs5_sanity_check()
313 if (msg->dsts_len[i] & 0xf) { in bcmfs5_sanity_check()
314 if (msg->dsts_len[i] > DST_LENGTH_MASK) in bcmfs5_sanity_check()
317 if (msg->dsts_len[i] > (MDST_LENGTH_MASK * 16)) in bcmfs5_sanity_check()
[all …]
/dpdk/app/test-bbdev/
H A Dmain.h27 #define TEST_ASSERT(cond, msg, ...) do { \ argument
30 msg "\n", __func__, __LINE__, ##__VA_ARGS__); \
36 #define TEST_ASSERT_BUFFERS_ARE_EQUAL(a, b, len, msg, ...) do { \ argument
39 msg "\n", __func__, __LINE__, ##__VA_ARGS__); \
46 #define TEST_ASSERT_SUCCESS(val, msg, ...) do { \ argument
50 msg "\n", __func__, __LINE__, _val, \
56 #define TEST_ASSERT_FAIL(val, msg, ...) \ argument
57 TEST_ASSERT_SUCCESS(!(val), msg, ##__VA_ARGS__)
59 #define TEST_ASSERT_NOT_NULL(val, msg, ...) do { \ argument
62 msg "\n", __func__, __LINE__, ##__VA_ARGS__); \
/dpdk/drivers/crypto/octeontx/
H A Dotx_cryptodev_mbox.c19 mbx.msg = CPT_READ_CSR(CPT_CSR_REG_BASE(cptvf), in otx_cpt_handle_mbox_intr()
25 cptvf->dev_name, (unsigned int long)mbx.msg); in otx_cpt_handle_mbox_intr()
26 switch (mbx.msg) { in otx_cpt_handle_mbox_intr()
66 cptvf->dev_name, (unsigned int long)mbx.msg); in otx_cpt_handle_mbox_intr()
80 CPTX_VFX_PF_MBOXX(0, 0, 0), mbx->msg); in otx_cpt_send_msg_to_pf()
108 (unsigned int long)(mbx->msg & 0xFF), in otx_cpt_send_msg_to_pf_timeout()
121 mbx.msg = OTX_CPT_MSG_READY; in otx_cpt_check_pf_ready()
135 mbx.msg = OTX_CPT_MSG_PF_TYPE; in otx_cpt_get_dev_type()
149 mbx.msg = OTX_CPT_MSG_QLEN; in otx_cpt_send_vq_size_msg()
165 mbx.msg = OTX_CPT_MSG_QBIND_GRP; in otx_cpt_send_vf_grp_msg()
[all …]
/dpdk/drivers/raw/ifpga/base/
H A Dopae_i2c.c10 struct i2c_msg *msg, int num) in i2c_transfer() argument
15 ret = dev->xfer(dev, msg, num); in i2c_transfer()
40 struct i2c_msg msg[2] = { in i2c_read() local
60 ret = i2c_transfer(dev, msg, 2); in i2c_read()
70 struct i2c_msg msg; in i2c_write() local
88 msg.addr = slave_addr; in i2c_write()
89 msg.flags = 0; in i2c_write()
90 msg.buf = buf; in i2c_write()
93 msg.buf[i++] = offset >> 8; in i2c_write()
95 msg.buf[i++] = offset; in i2c_write()
[all …]
/dpdk/drivers/net/octeontx/base/
H A Docteontx_bgx.c20 hdr.msg = MBOX_BGX_PORT_OPEN; in octeontx_bgx_port_open()
50 hdr.msg = MBOX_BGX_PORT_CLOSE; in octeontx_bgx_port_close()
67 hdr.msg = MBOX_BGX_PORT_START; in octeontx_bgx_port_start()
84 hdr.msg = MBOX_BGX_PORT_STOP; in octeontx_bgx_port_stop()
103 hdr.msg = MBOX_BGX_PORT_GET_CONFIG; in octeontx_bgx_port_get_config()
136 hdr.msg = MBOX_BGX_PORT_GET_STATUS; in octeontx_bgx_port_status()
156 hdr.msg = MBOX_BGX_PORT_SET_MCAST; in octeontx_bgx_port_multicast_set()
175 hdr.msg = MBOX_BGX_PORT_GET_STATS; in octeontx_bgx_port_xstats()
193 hdr.msg = MBOX_BGX_PORT_GET_STATS; in octeontx_bgx_port_stats()
218 hdr.msg = MBOX_BGX_PORT_CLR_STATS; in octeontx_bgx_port_stats_clr()
[all …]
/dpdk/drivers/net/txgbe/base/
H A Dtxgbe_mbx.h90 s32 txgbe_read_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id);
91 s32 txgbe_write_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id);
92 s32 txgbe_read_posted_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id);
93 s32 txgbe_write_posted_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id);
100 s32 txgbe_read_mbx_pf(struct txgbe_hw *hw, u32 *msg, u16 size, u16 vf_number);
101 s32 txgbe_write_mbx_pf(struct txgbe_hw *hw, u32 *msg, u16 size, u16 vf_number);
106 s32 txgbe_read_mbx_vf(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id);
107 s32 txgbe_write_mbx_vf(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id);
H A Dtxgbe_vf.c249 STATIC s32 txgbevf_write_msg_read_ack(struct txgbe_hw *hw, u32 *msg, in txgbevf_write_msg_read_ack() argument
253 s32 retval = mbx->write_posted(hw, msg, size, 0); in txgbevf_write_msg_read_ack()
579 u32 msg[3]; in txgbevf_negotiate_api_version() local
582 msg[0] = TXGBE_VF_API_NEGOTIATE; in txgbevf_negotiate_api_version()
583 msg[1] = api; in txgbevf_negotiate_api_version()
584 msg[2] = 0; in txgbevf_negotiate_api_version()
586 err = txgbevf_write_msg_read_ack(hw, msg, msg, 3); in txgbevf_negotiate_api_version()
588 msg[0] &= ~TXGBE_VT_MSGTYPE_CTS; in txgbevf_negotiate_api_version()
591 if (msg[0] == (TXGBE_VF_API_NEGOTIATE | TXGBE_VT_MSGTYPE_ACK)) { in txgbevf_negotiate_api_version()
606 u32 msg[5]; in txgbevf_get_queues() local
[all …]
H A Dtxgbe_mbx.c19 s32 txgbe_read_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id) in txgbe_read_mbx() argument
29 ret_val = mbx->read(hw, msg, size, mbx_id); in txgbe_read_mbx()
43 s32 txgbe_write_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id) in txgbe_write_mbx() argument
52 ret_val = mbx->write(hw, msg, size, mbx_id); in txgbe_write_mbx()
180 s32 txgbe_read_posted_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, u16 mbx_id) in txgbe_read_posted_mbx() argument
192 ret_val = mbx->read(hw, msg, size, mbx_id); in txgbe_read_posted_mbx()
207 s32 txgbe_write_posted_mbx(struct txgbe_hw *hw, u32 *msg, u16 size, in txgbe_write_posted_mbx() argument
218 ret_val = mbx->write(hw, msg, size, mbx_id); in txgbe_write_posted_mbx()
358 s32 txgbe_write_mbx_vf(struct txgbe_hw *hw, u32 *msg, u16 size, in txgbe_write_mbx_vf() argument
377 wr32a(hw, TXGBE_VFMBX, i, msg[i]); in txgbe_write_mbx_vf()
[all …]
/dpdk/examples/multi_process/simple_mp/
H A Dmp_commands.c15 void *msg = NULL; in cmd_send_parsed() local
18 if (rte_mempool_get(message_pool, &msg) < 0) in cmd_send_parsed()
20 strlcpy((char *)msg, res->message, STR_TOKEN_SIZE); in cmd_send_parsed()
21 if (rte_ring_enqueue(send_ring, msg) < 0) { in cmd_send_parsed()
23 rte_mempool_put(message_pool, msg); in cmd_send_parsed()
/dpdk/drivers/net/mlx5/linux/
H A Dmlx5_socket.c45 struct msghdr msg = { in mlx5_pmd_socket_handle() local
67 ret = recvmsg(conn_sock, &msg, MSG_WAITALL); in mlx5_pmd_socket_handle()
75 cmsg = CMSG_FIRSTHDR(&msg); in mlx5_pmd_socket_handle()
88 if (msg.msg_iovlen != 1 || msg.msg_iov->iov_len < sizeof(uint16_t)) { in mlx5_pmd_socket_handle()
93 dump_req = (struct mlx5_flow_dump_req *)msg.msg_iov->iov_base; in mlx5_pmd_socket_handle()
128 msg.msg_controllen = 0; in mlx5_pmd_socket_handle()
129 msg.msg_control = NULL; in mlx5_pmd_socket_handle()
130 msg.msg_iovlen = 1; in mlx5_pmd_socket_handle()
131 msg.msg_iov = &io; in mlx5_pmd_socket_handle()
137 ret = sendmsg(conn_sock, &msg, 0); in mlx5_pmd_socket_handle()
/dpdk/lib/vhost/
H A Dvhost_user.c158 expected_fds, vhost_message_handlers[ctx->msg.request.frontend].description, in validate_msg_fds()
360 ctx->msg.payload.u64 = features; in vhost_user_get_features()
361 ctx->msg.size = sizeof(ctx->msg.payload.u64); in vhost_user_get_features()
380 ctx->msg.payload.u64 = (uint64_t)queue_num; in vhost_user_get_queue_num()
381 ctx->msg.size = sizeof(ctx->msg.payload.u64); in vhost_user_get_queue_num()
396 uint64_t features = ctx->msg.payload.u64; in vhost_user_set_features()
486 struct vhost_virtqueue *vq = dev->virtqueue[ctx->msg.payload.state.index]; in vhost_user_set_vring_num()
488 if (ctx->msg in vhost_user_set_vring_num()
[all...]
/dpdk/drivers/common/cnxk/
H A Droc_ree.c168 struct ree_rd_wr_reg_msg *msg; in roc_ree_af_reg_read() local
175 msg = (struct ree_rd_wr_reg_msg *)mbox_alloc_msg_rsp( in roc_ree_af_reg_read()
176 mbox, 0, sizeof(*msg), sizeof(*msg)); in roc_ree_af_reg_read()
177 if (msg == NULL) { in roc_ree_af_reg_read()
182 msg->hdr.id = MBOX_MSG_REE_RD_WR_REGISTER; in roc_ree_af_reg_read()
183 msg->hdr.sig = MBOX_REQ_SIG; in roc_ree_af_reg_read()
184 msg->hdr.pcifunc = vf->dev->pf_func; in roc_ree_af_reg_read()
185 msg->is_write = 0; in roc_ree_af_reg_read()
186 msg->reg_offset = reg; in roc_ree_af_reg_read()
187 msg->ret_val = val; in roc_ree_af_reg_read()
[all …]
H A Droc_hash.h12 void __roc_api roc_hash_md5_gen(uint8_t *msg, uint32_t *hash);
13 void __roc_api roc_hash_sha1_gen(uint8_t *msg, uint32_t *hash);
14 void __roc_api roc_hash_sha256_gen(uint8_t *msg, uint32_t *hash, int hash_size);
15 void __roc_api roc_hash_sha512_gen(uint8_t *msg, uint64_t *hash, int hash_size);
/dpdk/drivers/net/memif/
H A Dmemif_socket.c31 memif_msg_send(int fd, memif_msg_t *msg, int afd) in memif_msg_send() argument
38 iov[0].iov_base = msg; in memif_msg_send()
71 size = memif_msg_send(rte_intr_fd_get(cc->intr_handle), &e->msg, in memif_msg_send_from_queue()
77 MIF_LOG(DEBUG, "Sent msg type %u.", e->msg.type); in memif_msg_send_from_queue()
121 d = &e->msg.disconnect; in memif_msg_enq_disconnect()
123 e->msg.type = MEMIF_MSG_TYPE_DISCONNECT; in memif_msg_enq_disconnect()
145 h = &e->msg.hello; in memif_msg_enq_hello()
147 e->msg.type = MEMIF_MSG_TYPE_HELLO; in memif_msg_enq_hello()
161 memif_msg_receive_hello(struct rte_eth_dev *dev, memif_msg_t *msg) in memif_msg_receive_hello() argument
164 memif_msg_hello_t *h = &msg->hello; in memif_msg_receive_hello()
[all …]
/dpdk/examples/vhost_blk/
H A Dvhost_blk_compat.c73 struct vhost_user_msg *msg = _msg; in extern_vhost_pre_msg_handler() local
88 switch ((int)msg->request) { in extern_vhost_pre_msg_handler()
101 msg->payload.cfg.region, in extern_vhost_pre_msg_handler()
102 msg->payload.cfg.size); in extern_vhost_pre_msg_handler()
104 msg->size = 0; in extern_vhost_pre_msg_handler()
121 struct vhost_user_msg *msg = _msg; in extern_vhost_post_msg_handler() local
136 switch (msg->request) { in extern_vhost_post_msg_handler()
/dpdk/drivers/net/hns3/
H A Dhns3_mbx.c139 cmd->msg = *req; in hns3vf_mbx_send()
184 (struct hns3_mbx_link_status *)req->msg.msg_data; in hns3vf_handle_link_change_event()
209 reset_level = rte_le_to_cpu_16(req->msg.reset_level); in hns3_handle_asserting_reset()
232 hns3_resp_to_errno(req->msg.resp_status); in hns3_handle_mbx_response()
233 memcpy(resp->additional_info, &req->msg.resp_data, in hns3_handle_mbx_response()
246 msg_data = (uint32_t)req->msg.vf_mbx_msg_code << in hns3_handle_mbx_response()
247 HNS3_MBX_RESP_CODE_OFFSET | req->msg.vf_mbx_msg_subcode; in hns3_handle_mbx_response()
255 resp->resp_status = hns3_resp_to_errno(req->msg.resp_status); in hns3_handle_mbx_response()
256 memcpy(resp->additional_info, &req->msg.resp_data, in hns3_handle_mbx_response()
287 if (!req->msg.link_status) in hns3pf_handle_link_change_event()
[all …]
/dpdk/lib/eal/windows/
H A Deal_mp.c44 rte_mp_sendmsg(struct rte_mp_msg *msg) in rte_mp_sendmsg() argument
46 RTE_SET_USED(msg); in rte_mp_sendmsg()
74 rte_mp_reply(struct rte_mp_msg *msg, const char *peer) in rte_mp_reply() argument
76 RTE_SET_USED(msg); in rte_mp_reply()

1234