| 111 | }; |
| 112 | |
| 113 | static int |
| 114 | _eventdev_setup(int mode) |
| 115 | { |
| 116 | int i, ret; |
| 117 | struct rte_event_dev_config dev_conf; |
| 118 | struct rte_event_dev_info info; |
| 119 | const char *pool_name = "evdev_dpaa2_test_pool"; |
| 120 | |
| 121 | /* Create and destroy pool for each test case to make it standalone */ |
| 122 | eventdev_test_mempool = rte_pktmbuf_pool_create(pool_name, |
| 123 | MAX_EVENTS, |
| 124 | 0 /*MBUF_CACHE_SIZE*/, |
| 125 | 0, |
| 126 | 512, /* Use very small mbufs */ |
| 127 | rte_socket_id()); |
| 128 | if (!eventdev_test_mempool) { |
| 129 | dpaa2_evdev_err("ERROR creating mempool"); |
| 130 | return -1; |
| 131 | } |
| 132 | |
| 133 | ret = rte_event_dev_info_get(evdev, &info); |
| 134 | RTE_TEST_ASSERT_SUCCESS(ret, "Failed to get event dev info"); |
| 135 | RTE_TEST_ASSERT(info.max_num_events >= (int32_t)MAX_EVENTS, |
| 136 | "ERROR max_num_events=%d < max_events=%d", |
| 137 | info.max_num_events, MAX_EVENTS); |
| 138 | |
| 139 | devconf_set_default_sane_values(&dev_conf, &info); |
| 140 | if (mode == TEST_EVENTDEV_SETUP_DEQUEUE_TIMEOUT) |
| 141 | dev_conf.event_dev_cfg |= RTE_EVENT_DEV_CFG_PER_DEQUEUE_TIMEOUT; |
| 142 | |
| 143 | ret = rte_event_dev_configure(evdev, &dev_conf); |
| 144 | RTE_TEST_ASSERT_SUCCESS(ret, "Failed to configure eventdev"); |
| 145 | |
| 146 | uint32_t queue_count; |
| 147 | RTE_TEST_ASSERT_SUCCESS(rte_event_dev_attr_get(evdev, |
| 148 | RTE_EVENT_DEV_ATTR_QUEUE_COUNT, |
| 149 | &queue_count), "Queue count get failed"); |
| 150 | |
| 151 | if (mode == TEST_EVENTDEV_SETUP_PRIORITY) { |
| 152 | if (queue_count > 8) { |
| 153 | dpaa2_evdev_err( |
| 154 | "test expects the unique priority per queue"); |
| 155 | return -ENOTSUP; |
| 156 | } |
| 157 | |
| 158 | /* Configure event queues(0 to n) with |
| 159 | * RTE_EVENT_DEV_PRIORITY_HIGHEST to |
| 160 | * RTE_EVENT_DEV_PRIORITY_LOWEST |
| 161 | */ |
| 162 | uint8_t step = (RTE_EVENT_DEV_PRIORITY_LOWEST + 1) / |
| 163 | queue_count; |
| 164 | for (i = 0; i < (int)queue_count; i++) { |
| 165 | struct rte_event_queue_conf queue_conf; |
| 166 | |
| 167 | ret = rte_event_queue_default_conf_get(evdev, i, |
| 168 | &queue_conf); |
| 169 | RTE_TEST_ASSERT_SUCCESS(ret, "Failed to get def_conf%d", |
| 170 | i); |
no test coverage detected