X-Git-Url: http://git.droids-corp.org/?a=blobdiff_plain;f=examples%2Fipsec-secgw%2Fevent_helper.c;h=8475d542b2c4d9d260a066ecc4ee7c612bf8e661;hb=b4cfffaa85ecfac2035eee26fa48167fdcefd678;hp=076f1f292d8ad589674656e2ee76c142ba799c22;hpb=65e3a202ac6dd81acaa9623d7772e62043bbe28e;p=dpdk.git diff --git a/examples/ipsec-secgw/event_helper.c b/examples/ipsec-secgw/event_helper.c index 076f1f292d..8475d542b2 100644 --- a/examples/ipsec-secgw/event_helper.c +++ b/examples/ipsec-secgw/event_helper.c @@ -100,12 +100,15 @@ static inline bool eh_dev_has_rx_internal_port(uint8_t eventdev_id) { bool flag = true; - int j; + int j, ret; RTE_ETH_FOREACH_DEV(j) { uint32_t caps = 0; - rte_event_eth_rx_adapter_caps_get(eventdev_id, j, &caps); + ret = rte_event_eth_rx_adapter_caps_get(eventdev_id, j, &caps); + if (ret < 0) + return false; + if (!(caps & RTE_EVENT_ETH_RX_ADAPTER_CAP_INTERNAL_PORT)) flag = false; } @@ -116,12 +119,15 @@ static inline bool eh_dev_has_tx_internal_port(uint8_t eventdev_id) { bool flag = true; - int j; + int j, ret; RTE_ETH_FOREACH_DEV(j) { uint32_t caps = 0; - rte_event_eth_tx_adapter_caps_get(eventdev_id, j, &caps); + ret = rte_event_eth_tx_adapter_caps_get(eventdev_id, j, &caps); + if (ret < 0) + return false; + if (!(caps & RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT)) flag = false; } @@ -323,6 +329,7 @@ eh_set_default_conf_rx_adapter(struct eventmode_conf *em_conf) int nb_eth_dev; int adapter_id; int conn_id; + int ret; int i; /* Create one adapter with eth queues mapped to event queue(s) */ @@ -385,7 +392,12 @@ eh_set_default_conf_rx_adapter(struct eventmode_conf *em_conf) conn->ethdev_rx_qid = -1; /* Get Rx adapter capabilities */ - rte_event_eth_rx_adapter_caps_get(eventdev_id, i, &caps); + ret = rte_event_eth_rx_adapter_caps_get(eventdev_id, i, &caps); + if (ret < 0) { + EH_LOG_ERR("Failed to get event device %d eth rx adapter" + " capabilities for port %d", eventdev_id, i); + return ret; + } if (!(caps & RTE_EVENT_ETH_RX_ADAPTER_CAP_INTERNAL_PORT)) rx_internal_port = false; @@ -420,6 +432,7 @@ eh_set_default_conf_tx_adapter(struct eventmode_conf *em_conf) int adapter_id; int nb_eth_dev; int conn_id; + int ret; int i; /* @@ -479,7 +492,12 @@ eh_set_default_conf_tx_adapter(struct eventmode_conf *em_conf) conn->ethdev_tx_qid = -1; /* Get Tx adapter capabilities */ - rte_event_eth_tx_adapter_caps_get(eventdev_id, i, &caps); + ret = rte_event_eth_tx_adapter_caps_get(eventdev_id, i, &caps); + if (ret < 0) { + EH_LOG_ERR("Failed to get event device %d eth tx adapter" + " capabilities for port %d", eventdev_id, i); + return ret; + } if (!(caps & RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT)) tx_internal_port = false; @@ -1443,16 +1461,16 @@ eh_conf_init(void) /* Set two cores as eth cores for Rx & Tx */ - /* Use first core other than master core as Rx core */ + /* Use first core other than main core as Rx core */ eth_core_id = rte_get_next_lcore(0, /* curr core */ - 1, /* skip master core */ + 1, /* skip main core */ 0 /* wrap */); rte_bitmap_set(em_conf->eth_core_mask, eth_core_id); /* Use next core as Tx core */ eth_core_id = rte_get_next_lcore(eth_core_id, /* curr core */ - 1, /* skip master core */ + 1, /* skip main core */ 0 /* wrap */); rte_bitmap_set(em_conf->eth_core_mask, eth_core_id); @@ -1565,7 +1583,12 @@ eh_devs_init(struct eh_conf *conf) if ((conf->eth_portmask & (1 << port_id)) == 0) continue; - rte_eth_dev_stop(port_id); + ret = rte_eth_dev_stop(port_id); + if (ret != 0) { + EH_LOG_ERR("Failed to stop port %u, err: %d", + port_id, ret); + return ret; + } } /* Setup eventdev */