[PATCH v3 29/51] net/sxe2: refactor primary process MP message handling

[liujie5]

From: Jie Liu <liuj...@linkdatatechnology.com>

Extract the multi-process work logic into the sxe2_mp_do_primary_work
helper and operate on a copy of the request in the primary handler so
the original message is not modified. Simplify the reply construction
and return -ENOENT instead of -EINVAL when no response is received
from the primary process.

Fixes: 5db446ba97b0 ("net/sxe2: support statistics and multi-process")
Cc: sta...@dpdk.org
Cc: step...@networkplumber.org

Signed-off-by: Jie Liu <liuj...@linkdatatechnology.com>
---
 drivers/net/sxe2/sxe2_mp.c | 59 ++++++++++++++++++++++----------------
 1 file changed, 34 insertions(+), 25 deletions(-)

diff --git a/drivers/net/sxe2/sxe2_mp.c b/drivers/net/sxe2/sxe2_mp.c
index a4a5c76495..93a11150a9 100644
--- a/drivers/net/sxe2/sxe2_mp.c
+++ b/drivers/net/sxe2/sxe2_mp.c
@@ -29,16 +29,11 @@ static int32_t sxe2_mp_secondary_handle(const struct 
rte_mp_msg *mp_msg,
                                         const void *peer);
 
 static int32_t
-sxe2_mp_primary_handle(const struct rte_mp_msg *mp_msg, const void *peer)
+sxe2_mp_do_primary_work(struct sxe2_mp_param *param)
 {
-       struct rte_mp_msg reply;
-       const struct sxe2_mp_param *param =
-                       (const struct sxe2_mp_param *)mp_msg->param;
-       struct sxe2_mp_param *reply_param = (struct sxe2_mp_param *)reply.param;
        struct rte_eth_dev *dev;
-       int32_t ret = 0;
        struct sxe2_mp_shared_data *mz_data;
-       int32_t send_reply = 0;
+       int32_t ret = 0;
        int32_t cnt = 0;
 
        if (!rte_eth_dev_is_valid_port(param->port_id)) {
@@ -49,24 +44,21 @@ sxe2_mp_primary_handle(const struct rte_mp_msg *mp_msg, 
const void *peer)
        }
 
        dev = &rte_eth_devices[param->port_id];
-       sxe2_mp_mz = rte_memzone_lookup(SXE2_MP_MZ_NAME);
+
        if (sxe2_mp_mz == NULL) {
-               PMD_LOG_ERR(DRV, "Failed to lookup memzone %s", 
SXE2_MP_MZ_NAME);
-               ret = -ENOENT;
-               goto out;
+               sxe2_mp_mz = rte_memzone_lookup(SXE2_MP_MZ_NAME);
+               if (sxe2_mp_mz == NULL) {
+                       PMD_LOG_ERR(DRV, "Failed to lookup memzone %s",
+                                       SXE2_MP_MZ_NAME);
+                       ret = -ENOENT;
+                       goto out;
+               }
        }
 
        mz_data = (struct sxe2_mp_shared_data *)sxe2_mp_mz->addr;
-       send_reply = 1;
-
-       memset(&reply, 0, sizeof(reply));
-       (void)strlcpy(reply.name, SXE2_MP_NAME, sizeof(reply.name));
-       reply.len_param = sizeof(*reply_param);
-
        switch (param->type) {
        case SXE2_MP_REQ_GET_STATS:
-               ret = sxe2_stats_info_get(dev,
-                                         &mz_data->payload.stats_blk.stats,
+               ret = sxe2_stats_info_get(dev, 
&mz_data->payload.stats_blk.stats,
                                          &mz_data->payload.stats_blk.qstats);
                break;
        case SXE2_MP_REQ_GET_XSTATS:
@@ -88,15 +80,32 @@ sxe2_mp_primary_handle(const struct rte_mp_msg *mp_msg, 
const void *peer)
        default:
                PMD_LOG_ERR(DRV, "primary process: unrecognized msg type: %d",
                                param->type);
-               send_reply = false;
                ret = -EINVAL;
-               goto out;
+               break;
        }
+
 out:
-       if (!send_reply)
-               return ret;
+       param->result = ret;
+       return ret;
+}
 
-       reply_param->result = ret;
+static int32_t
+sxe2_mp_primary_handle(const struct rte_mp_msg *mp_msg, const void *peer)
+{
+       struct rte_mp_msg reply;
+       struct sxe2_mp_param *reply_param = (struct sxe2_mp_param *)reply.param;
+       const struct sxe2_mp_param *param =
+                       (const struct sxe2_mp_param *)mp_msg->param;
+       struct sxe2_mp_param param_copy;
+
+       memset(&reply, 0, sizeof(reply));
+       (void)strlcpy(reply.name, SXE2_MP_NAME, sizeof(reply.name));
+       reply.len_param = sizeof(*reply_param);
+
+       param_copy = *param;
+       (void)sxe2_mp_do_primary_work(&param_copy);
+
+       reply_param->result = param_copy.result;
        reply_param->type = param->type;
        reply_param->port_id = param->port_id;
 
@@ -275,7 +284,7 @@ int32_t sxe2_mp_request_simple(struct rte_eth_dev *dev,
        if (reply.nb_received == 0) {
                PMD_LOG_ERR(DRV, "No response received from primary for 
type=%d, port %u",
                        type, dev->data->port_id);
-               ret = -EINVAL;
+               ret = -ENOENT;
                goto out;
        }
 
-- 
2.52.0