1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2018-2021 HiSilicon Limited.
6 #include <ethdev_driver.h>
7 #include <rte_string_fns.h>
10 #include "hns3_ethdev.h"
11 #include "hns3_logs.h"
12 #include "hns3_rxtx.h"
15 /* local data for primary or secondary process. */
16 static struct hns3_process_local_data process_data;
19 * Initialize IPC message.
22 * Pointer to Ethernet structure.
24 * Pointer to message to fill in.
29 mp_init_msg(struct rte_eth_dev *dev, struct rte_mp_msg *msg,
30 enum hns3_mp_req_type type)
32 struct hns3_mp_param *param = (struct hns3_mp_param *)msg->param;
34 memset(msg, 0, sizeof(*msg));
35 strlcpy(msg->name, HNS3_MP_NAME, sizeof(msg->name));
36 msg->len_param = sizeof(*param);
38 param->port_id = dev->data->port_id;
42 * IPC message handler of primary process.
45 * Pointer to Ethernet structure.
47 * Pointer to the peer socket path.
50 * 0 on success, a negative errno value otherwise and rte_errno is set.
53 mp_primary_handle(const struct rte_mp_msg *mp_msg __rte_unused,
54 const void *peer __rte_unused)
60 * IPC message handler of a secondary process.
63 * Pointer to Ethernet structure.
65 * Pointer to the peer socket path.
68 * 0 on success, a negative errno value otherwise and rte_errno is set.
71 mp_secondary_handle(const struct rte_mp_msg *mp_msg, const void *peer)
73 struct rte_mp_msg mp_res;
74 struct hns3_mp_param *res = (struct hns3_mp_param *)mp_res.param;
75 const struct hns3_mp_param *param =
76 (const struct hns3_mp_param *)mp_msg->param;
77 struct rte_eth_dev *dev;
80 if (!rte_eth_dev_is_valid_port(param->port_id)) {
82 PMD_INIT_LOG(ERR, "port %d invalid port ID", param->port_id);
85 dev = &rte_eth_devices[param->port_id];
86 switch (param->type) {
87 case HNS3_MP_REQ_START_RXTX:
88 PMD_INIT_LOG(INFO, "port %u starting datapath",
90 hns3_set_rxtx_function(dev);
92 case HNS3_MP_REQ_STOP_RXTX:
93 PMD_INIT_LOG(INFO, "port %u stopping datapath",
95 hns3_set_rxtx_function(dev);
97 case HNS3_MP_REQ_START_TX:
98 PMD_INIT_LOG(INFO, "port %u starting Tx datapath",
100 hns3_start_tx_datapath(dev);
102 case HNS3_MP_REQ_STOP_TX:
103 PMD_INIT_LOG(INFO, "port %u stopping Tx datapath",
105 hns3_stop_tx_datapath(dev);
109 PMD_INIT_LOG(ERR, "port %u invalid mp request type",
115 mp_init_msg(dev, &mp_res, param->type);
117 ret = rte_mp_reply(&mp_res, peer);
123 mp_req_type_is_valid(enum hns3_mp_req_type type)
125 return type == HNS3_MP_REQ_START_RXTX ||
126 type == HNS3_MP_REQ_STOP_RXTX ||
127 type == HNS3_MP_REQ_START_TX ||
128 type == HNS3_MP_REQ_STOP_TX;
132 * Broadcast request of stopping/starting data-path to secondary processes.
135 * Pointer to Ethernet structure.
140 mp_req_on_rxtx(struct rte_eth_dev *dev, enum hns3_mp_req_type type)
142 struct hns3_hw *hw = HNS3_DEV_PRIVATE_TO_HW(dev->data->dev_private);
143 struct rte_mp_msg mp_req;
144 struct rte_mp_msg *mp_res;
145 struct rte_mp_reply mp_rep;
146 struct hns3_mp_param *res;
151 if (rte_eal_process_type() == RTE_PROC_SECONDARY ||
152 __atomic_load_n(&hw->secondary_cnt, __ATOMIC_RELAXED) == 0)
155 if (!mp_req_type_is_valid(type)) {
156 hns3_err(hw, "port %u unknown request (req_type %d)",
157 dev->data->port_id, type);
160 mp_init_msg(dev, &mp_req, type);
161 ts.tv_sec = HNS3_MP_REQ_TIMEOUT_SEC;
163 ret = rte_mp_request_sync(&mp_req, &mp_rep, &ts);
165 hns3_err(hw, "port %u failed to request stop/start Rx/Tx (%d)",
166 dev->data->port_id, type);
169 if (mp_rep.nb_sent != mp_rep.nb_received) {
171 "port %u not all secondaries responded (req_type %d)",
172 dev->data->port_id, type);
175 for (i = 0; i < mp_rep.nb_received; i++) {
176 mp_res = &mp_rep.msgs[i];
177 res = (struct hns3_mp_param *)mp_res->param;
179 hns3_err(hw, "port %u request failed on secondary #%d",
180 dev->data->port_id, i);
189 * Broadcast request of starting data-path to secondary processes. The request
193 * Pointer to Ethernet structure.
195 void hns3_mp_req_start_rxtx(struct rte_eth_dev *dev)
197 mp_req_on_rxtx(dev, HNS3_MP_REQ_START_RXTX);
201 * Broadcast request of stopping data-path to secondary processes. The request
205 * Pointer to Ethernet structure.
207 void hns3_mp_req_stop_rxtx(struct rte_eth_dev *dev)
209 mp_req_on_rxtx(dev, HNS3_MP_REQ_STOP_RXTX);
213 hns3_mp_req_stop_tx(struct rte_eth_dev *dev)
215 mp_req_on_rxtx(dev, HNS3_MP_REQ_STOP_TX);
219 hns3_mp_req_start_tx(struct rte_eth_dev *dev)
221 mp_req_on_rxtx(dev, HNS3_MP_REQ_START_TX);
225 * Initialize by primary process.
228 hns3_mp_init_primary(void)
232 if (process_data.init_done)
235 /* primary is allowed to not support IPC */
236 ret = rte_mp_action_register(HNS3_MP_NAME, mp_primary_handle);
237 if (ret && rte_errno != ENOTSUP)
240 process_data.init_done = true;
246 * Initialize by secondary process.
249 hns3_mp_init_secondary(void)
253 if (process_data.init_done)
256 ret = rte_mp_action_register(HNS3_MP_NAME, mp_secondary_handle);
257 if (ret && rte_errno != ENOTSUP)
260 process_data.init_done = true;
266 hns3_mp_init(struct rte_eth_dev *dev)
268 struct hns3_hw *hw = HNS3_DEV_PRIVATE_TO_HW(dev->data->dev_private);
271 if (rte_eal_process_type() != RTE_PROC_PRIMARY) {
272 ret = hns3_mp_init_secondary();
274 PMD_INIT_LOG(ERR, "Failed to init for secondary process, ret = %d",
278 __atomic_fetch_add(&hw->secondary_cnt, 1, __ATOMIC_RELAXED);
280 ret = hns3_mp_init_primary();
282 PMD_INIT_LOG(ERR, "Failed to init for primary process, ret = %d",
288 process_data.eth_dev_cnt++;
293 void hns3_mp_uninit(struct rte_eth_dev *dev)
295 struct hns3_hw *hw = HNS3_DEV_PRIVATE_TO_HW(dev->data->dev_private);
297 if (rte_eal_process_type() != RTE_PROC_PRIMARY)
298 __atomic_fetch_sub(&hw->secondary_cnt, 1, __ATOMIC_RELAXED);
300 process_data.eth_dev_cnt--;
301 if (process_data.eth_dev_cnt == 0) {
302 rte_mp_action_unregister(HNS3_MP_NAME);
303 process_data.init_done = false;