Lines Matching refs:test_params

112 static struct link_bonding_unittest_params *test_params = &default_params;  variable
181 TEST_ASSERT_SUCCESS(rte_eth_dev_configure(port_id, test_params->nb_rx_q, in configure_ethdev()
182 test_params->nb_tx_q, &default_pmd_conf), in configure_ethdev()
185 for (q_id = 0; q_id < test_params->nb_rx_q; q_id++) in configure_ethdev()
188 test_params->mbuf_pool) , in configure_ethdev()
191 for (q_id = 0; q_id < test_params->nb_tx_q; q_id++) in configure_ethdev()
217 if (test_params->pkt_eth_hdr == NULL) { in test_setup()
218 test_params->pkt_eth_hdr = malloc(sizeof(struct rte_ether_hdr) + in test_setup()
221 TEST_ASSERT_NOT_NULL(test_params->pkt_eth_hdr, in test_setup()
227 if (test_params->mbuf_pool == NULL) { in test_setup()
228 test_params->mbuf_pool = rte_pktmbuf_pool_create("MBUF_POOL", in test_setup()
231 TEST_ASSERT_NOT_NULL(test_params->mbuf_pool, in test_setup()
244 test_params->slave_port_ids[i] = virtual_ethdev_create(pmd_name, in test_setup()
246 TEST_ASSERT(test_params->slave_port_ids[i] >= 0, in test_setup()
250 test_params->slave_port_ids[i], 1, 0), in test_setup()
267 if (test_params->bonded_port_id == -1) { in test_create_bonded_device()
268 test_params->bonded_port_id = rte_eth_bond_create(BONDED_DEV_NAME, in test_create_bonded_device()
269 test_params->bonding_mode, rte_socket_id()); in test_create_bonded_device()
271 TEST_ASSERT(test_params->bonded_port_id >= 0, in test_create_bonded_device()
274 TEST_ASSERT_SUCCESS(configure_ethdev(test_params->bonded_port_id, 0, 0), in test_create_bonded_device()
278 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in test_create_bonded_device()
279 test_params->bonding_mode), "Failed to set ethdev %d to mode %d", in test_create_bonded_device()
280 test_params->bonded_port_id, test_params->bonding_mode); in test_create_bonded_device()
282 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_create_bonded_device()
290 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_create_bonded_device()
305 test_params->bonding_mode = BONDING_MODE_ROUND_ROBIN; in test_create_bonded_device_with_invalid_params()
308 port_id = rte_eth_bond_create(NULL, test_params->bonding_mode, in test_create_bonded_device_with_invalid_params()
312 test_params->bonding_mode = INVALID_BONDING_MODE; in test_create_bonded_device_with_invalid_params()
315 port_id = rte_eth_bond_create(BONDED_DEV_NAME, test_params->bonding_mode, in test_create_bonded_device_with_invalid_params()
319 test_params->bonding_mode = BONDING_MODE_ROUND_ROBIN; in test_create_bonded_device_with_invalid_params()
322 port_id = rte_eth_bond_create(BONDED_DEV_NAME, test_params->bonding_mode, in test_create_bonded_device_with_invalid_params()
336 TEST_ASSERT_SUCCESS(rte_eth_bond_slave_add(test_params->bonded_port_id, in test_add_slave_to_bonded_device()
337 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_add_slave_to_bonded_device()
339 test_params->slave_port_ids[test_params->bonded_slave_count], in test_add_slave_to_bonded_device()
340 test_params->bonded_port_id); in test_add_slave_to_bonded_device()
342 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_add_slave_to_bonded_device()
344 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count + 1, in test_add_slave_to_bonded_device()
346 current_slave_count, test_params->bonded_slave_count + 1); in test_add_slave_to_bonded_device()
349 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_add_slave_to_bonded_device()
354 test_params->bonded_slave_count++; in test_add_slave_to_bonded_device()
363 TEST_ASSERT_FAIL(rte_eth_bond_slave_add(test_params->bonded_port_id + 5, in test_add_slave_to_invalid_bonded_device()
364 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_add_slave_to_invalid_bonded_device()
368 TEST_ASSERT_FAIL(rte_eth_bond_slave_add(test_params->slave_port_ids[0], in test_add_slave_to_invalid_bonded_device()
369 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_add_slave_to_invalid_bonded_device()
383 TEST_ASSERT_SUCCESS(rte_eth_bond_slave_remove(test_params->bonded_port_id, in test_remove_slave_from_bonded_device()
384 test_params->slave_port_ids[test_params->bonded_slave_count-1]), in test_remove_slave_from_bonded_device()
386 test_params->slave_port_ids[test_params->bonded_slave_count-1], in test_remove_slave_from_bonded_device()
387 test_params->bonded_port_id); in test_remove_slave_from_bonded_device()
390 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_remove_slave_from_bonded_device()
393 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count - 1, in test_remove_slave_from_bonded_device()
395 current_slave_count, test_params->bonded_slave_count - 1); in test_remove_slave_from_bonded_device()
400 test_params->bonded_slave_count-1; in test_remove_slave_from_bonded_device()
403 test_params->slave_port_ids[test_params->bonded_slave_count-1], in test_remove_slave_from_bonded_device()
406 test_params->slave_port_ids[test_params->bonded_slave_count-1]); in test_remove_slave_from_bonded_device()
411 test_params->slave_port_ids[test_params->bonded_slave_count-1]); in test_remove_slave_from_bonded_device()
413 virtual_ethdev_simulate_link_status_interrupt(test_params->bonded_port_id, in test_remove_slave_from_bonded_device()
416 test_params->bonded_slave_count--; in test_remove_slave_from_bonded_device()
426 test_params->bonded_port_id + 5, in test_remove_slave_from_invalid_bonded_device()
427 test_params->slave_port_ids[test_params->bonded_slave_count - 1]), in test_remove_slave_from_invalid_bonded_device()
432 test_params->slave_port_ids[0], in test_remove_slave_from_invalid_bonded_device()
433 test_params->slave_port_ids[test_params->bonded_slave_count - 1]), in test_remove_slave_from_invalid_bonded_device()
450 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_add_already_bonded_slave_to_bonded_device()
458 port_id = rte_eth_bond_create(pmd_name, test_params->bonding_mode, in test_add_already_bonded_slave_to_bonded_device()
463 test_params->slave_port_ids[test_params->bonded_slave_count - 1]) in test_add_already_bonded_slave_to_bonded_device()
466 test_params->slave_port_ids[test_params->bonded_slave_count-1], in test_add_already_bonded_slave_to_bonded_device()
494 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_get_slaves_from_bonded_device()
500 test_params->bonded_port_id, NULL, RTE_MAX_ETHPORTS); in test_get_slaves_from_bonded_device()
506 test_params->slave_port_ids[0], NULL, RTE_MAX_ETHPORTS); in test_get_slaves_from_bonded_device()
511 test_params->slave_port_ids[0], NULL, RTE_MAX_ETHPORTS); in test_get_slaves_from_bonded_device()
543 for (i = 0; i < test_params->bonded_slave_count; i++) { in enable_bonded_slaves()
544 virtual_ethdev_tx_burst_fn_set_success(test_params->slave_port_ids[i], in enable_bonded_slaves()
548 test_params->slave_port_ids[i], 1); in enable_bonded_slaves()
565 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_start_bonded_device()
567 test_params->bonded_port_id); in test_start_bonded_device()
572 test_params->slave_port_ids[test_params->bonded_slave_count-1], 1); in test_start_bonded_device()
574 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_start_bonded_device()
576 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count, in test_start_bonded_device()
578 current_slave_count, test_params->bonded_slave_count); in test_start_bonded_device()
581 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_start_bonded_device()
582 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count, in test_start_bonded_device()
584 current_slave_count, test_params->bonded_slave_count); in test_start_bonded_device()
586 current_bonding_mode = rte_eth_bond_mode_get(test_params->bonded_port_id); in test_start_bonded_device()
587 TEST_ASSERT_EQUAL(current_bonding_mode, test_params->bonding_mode, in test_start_bonded_device()
589 current_bonding_mode, test_params->bonding_mode); in test_start_bonded_device()
591 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_start_bonded_device()
592 TEST_ASSERT_EQUAL(primary_port, test_params->slave_port_ids[0], in test_start_bonded_device()
594 primary_port, test_params->slave_port_ids[0]); in test_start_bonded_device()
596 retval = rte_eth_link_get(test_params->bonded_port_id, &link_status); in test_start_bonded_device()
599 test_params->bonded_port_id, rte_strerror(-retval)); in test_start_bonded_device()
602 test_params->bonded_port_id, link_status.link_status, 1); in test_start_bonded_device()
616 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_stop_bonded_device()
618 test_params->bonded_port_id); in test_stop_bonded_device()
620 retval = rte_eth_link_get(test_params->bonded_port_id, &link_status); in test_stop_bonded_device()
623 test_params->bonded_port_id, rte_strerror(-retval)); in test_stop_bonded_device()
626 test_params->bonded_port_id, link_status.link_status, 0); in test_stop_bonded_device()
628 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_stop_bonded_device()
630 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count, in test_stop_bonded_device()
632 current_slave_count, test_params->bonded_slave_count); in test_stop_bonded_device()
635 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_stop_bonded_device()
648 while (test_params->bonded_slave_count > 0) in remove_slaves_and_stop_bonded_device()
652 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in remove_slaves_and_stop_bonded_device()
654 test_params->bonded_port_id); in remove_slaves_and_stop_bonded_device()
656 rte_eth_stats_reset(test_params->bonded_port_id); in remove_slaves_and_stop_bonded_device()
657 rte_eth_bond_mac_address_reset(test_params->bonded_port_id); in remove_slaves_and_stop_bonded_device()
682 TEST_ASSERT_FAIL(rte_eth_bond_mode_set(test_params->slave_port_ids[0], in test_set_bonding_mode()
685 test_params->slave_port_ids[0]); in test_set_bonding_mode()
687 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in test_set_bonding_mode()
690 test_params->bonded_port_id, bonding_modes[i]); in test_set_bonding_mode()
692 bonding_mode = rte_eth_bond_mode_get(test_params->bonded_port_id); in test_set_bonding_mode()
695 bonding_mode, test_params->bonded_port_id, in test_set_bonding_mode()
705 bonding_mode = rte_eth_bond_mode_get(test_params->slave_port_ids[0]); in test_set_bonding_mode()
708 test_params->slave_port_ids[0]); in test_set_bonding_mode()
722 for (i = test_params->bonded_slave_count; i < 4; i++) in test_set_primary_slave()
726 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in test_set_primary_slave()
729 test_params->bonded_port_id, BONDING_MODE_ROUND_ROBIN); in test_set_primary_slave()
733 test_params->slave_port_ids[i]), in test_set_primary_slave()
737 TEST_ASSERT_FAIL(rte_eth_bond_primary_set(test_params->slave_port_ids[i], in test_set_primary_slave()
738 test_params->slave_port_ids[i]), in test_set_primary_slave()
747 TEST_ASSERT_SUCCESS(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_set_primary_slave()
748 test_params->slave_port_ids[i]), in test_set_primary_slave()
750 test_params->bonded_port_id, test_params->slave_port_ids[i]); in test_set_primary_slave()
752 retval = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_set_primary_slave()
755 test_params->bonded_port_id); in test_set_primary_slave()
757 TEST_ASSERT_EQUAL(retval, test_params->slave_port_ids[i], in test_set_primary_slave()
759 test_params->bonded_port_id, retval, in test_set_primary_slave()
760 test_params->slave_port_ids[i]); in test_set_primary_slave()
763 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_set_primary_slave()
765 test_params->bonded_port_id); in test_set_primary_slave()
767 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_set_primary_slave()
769 test_params->bonded_port_id); in test_set_primary_slave()
775 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_set_primary_slave()
777 test_params->slave_port_ids[i]); in test_set_primary_slave()
783 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_set_primary_slave()
785 test_params->bonded_port_id); in test_set_primary_slave()
793 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[j], in test_set_primary_slave()
796 test_params->slave_port_ids[j]); in test_set_primary_slave()
807 TEST_ASSERT_FAIL(rte_eth_bond_primary_get(test_params->bonded_port_id + 10), in test_set_primary_slave()
811 TEST_ASSERT_FAIL(rte_eth_bond_primary_get(test_params->slave_port_ids[0]), in test_set_primary_slave()
818 TEST_ASSERT(rte_eth_bond_primary_get(test_params->bonded_port_id) < 0, in test_set_primary_slave()
841 test_params->slave_port_ids[0], mac_addr), in test_set_explicit_bonded_mac()
846 test_params->bonded_port_id, NULL), in test_set_explicit_bonded_mac()
850 test_params->bonded_port_id, mac_addr), in test_set_explicit_bonded_mac()
852 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
855 for (i = test_params->bonded_slave_count; i < 4; i++) { in test_set_explicit_bonded_mac()
861 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_set_explicit_bonded_mac()
863 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
869 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_set_explicit_bonded_mac()
871 test_params->slave_port_ids[i]); in test_set_explicit_bonded_mac()
879 rte_eth_bond_mac_address_reset(test_params->bonded_port_id), in test_set_explicit_bonded_mac()
881 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
884 rte_eth_bond_mac_address_reset(test_params->slave_port_ids[0]), in test_set_explicit_bonded_mac()
886 test_params->slave_port_ids[1]); in test_set_explicit_bonded_mac()
892 TEST_ASSERT_SUCCESS(rte_eth_bond_mac_address_reset(test_params->bonded_port_id), in test_set_explicit_bonded_mac()
894 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
1127 TEST_ASSERT_SUCCESS(configure_ethdev(test_params->bonded_port_id, 0, in initialize_bonded_device_with_slaves()
1129 "with (%d) slaves.", test_params->bonded_port_id, bonding_mode, in initialize_bonded_device_with_slaves()
1133 while (number_of_slaves > test_params->bonded_slave_count) in initialize_bonded_device_with_slaves()
1136 test_params->bonded_slave_count - 1, in initialize_bonded_device_with_slaves()
1137 test_params->bonded_port_id); in initialize_bonded_device_with_slaves()
1140 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in initialize_bonded_device_with_slaves()
1143 test_params->bonded_port_id, bonding_mode); in initialize_bonded_device_with_slaves()
1145 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in initialize_bonded_device_with_slaves()
1147 test_params->bonded_port_id); in initialize_bonded_device_with_slaves()
1165 for (i = 0; i < test_params->bonded_slave_count + 1; i++) { in test_adding_slave_after_bonded_device_started()
1167 test_params->slave_port_ids[i], 1); in test_adding_slave_after_bonded_device_started()
1170 TEST_ASSERT_SUCCESS(rte_eth_bond_slave_add(test_params->bonded_port_id, in test_adding_slave_after_bonded_device_started()
1171 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_adding_slave_after_bonded_device_started()
1175 test_params->slave_port_ids[test_params->bonded_slave_count]); in test_adding_slave_after_bonded_device_started()
1177 test_params->bonded_slave_count++; in test_adding_slave_after_bonded_device_started()
1250 rte_eth_dev_callback_register(test_params->bonded_port_id, in test_status_interrupt()
1252 &test_params->bonded_port_id); in test_status_interrupt()
1254 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_status_interrupt()
1264 test_params->slave_port_ids[0], 0); in test_status_interrupt()
1266 test_params->slave_port_ids[1], 0); in test_status_interrupt()
1268 test_params->slave_port_ids[2], 0); in test_status_interrupt()
1274 test_params->slave_port_ids[3], 0); in test_status_interrupt()
1282 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_status_interrupt()
1293 test_params->slave_port_ids[0], 1); in test_status_interrupt()
1307 test_params->slave_port_ids[0], 1); in test_status_interrupt()
1317 rte_eth_dev_callback_unregister(test_params->bonded_port_id, in test_status_interrupt()
1319 &test_params->bonded_port_id); in test_status_interrupt()
1339 initialize_eth_header(test_params->pkt_eth_hdr, in generate_test_burst()
1344 initialize_eth_header(test_params->pkt_eth_hdr, in generate_test_burst()
1351 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in generate_test_burst()
1354 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in generate_test_burst()
1359 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in generate_test_burst()
1362 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in generate_test_burst()
1365 ip_hdr = test_params->pkt_ipv4_hdr; in generate_test_burst()
1368 pktlen = initialize_ipv6_header(test_params->pkt_ipv6_hdr, in generate_test_burst()
1372 pktlen = initialize_ipv6_header(test_params->pkt_ipv6_hdr, in generate_test_burst()
1376 ip_hdr = test_params->pkt_ipv6_hdr; in generate_test_burst()
1380 generated_burst_size = generate_packet_burst(test_params->mbuf_pool, in generate_test_burst()
1381 pkts_burst, test_params->pkt_eth_hdr, vlan, ip_hdr, ipv4, in generate_test_burst()
1382 test_params->pkt_udp_hdr, burst_size, PACKET_BURST_GEN_PKT_LEN_128, in generate_test_burst()
1403 burst_size = 20 * test_params->bonded_slave_count; in test_roundrobin_tx_burst()
1414 test_params->bonded_port_id, 0, pkt_burst, burst_size), burst_size, in test_roundrobin_tx_burst()
1418 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_tx_burst()
1421 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_roundrobin_tx_burst()
1425 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_tx_burst()
1426 rte_eth_stats_get(test_params->slave_port_ids[i], &port_stats); in test_roundrobin_tx_burst()
1428 (uint64_t)burst_size / test_params->bonded_slave_count, in test_roundrobin_tx_burst()
1430 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_roundrobin_tx_burst()
1431 burst_size / test_params->bonded_slave_count); in test_roundrobin_tx_burst()
1435 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_tx_burst()
1437 test_params->slave_port_ids[i], 0); in test_roundrobin_tx_burst()
1441 TEST_ASSERT_EQUAL(rte_eth_tx_burst(test_params->bonded_port_id, 0, in test_roundrobin_tx_burst()
1512 test_params->slave_port_ids[TEST_RR_SLAVE_TX_FAIL_FAILING_SLAVE_IDX], in test_roundrobin_tx_burst_slave_tx_fail()
1516 test_params->slave_port_ids[TEST_RR_SLAVE_TX_FAIL_FAILING_SLAVE_IDX], in test_roundrobin_tx_burst_slave_tx_fail()
1519 tx_count = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkt_burst, in test_roundrobin_tx_burst_slave_tx_fail()
1536 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_tx_burst_slave_tx_fail()
1542 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_roundrobin_tx_burst_slave_tx_fail()
1547 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_tx_burst_slave_tx_fail()
1550 rte_eth_stats_get(test_params->slave_port_ids[i], &port_stats); in test_roundrobin_tx_burst_slave_tx_fail()
1553 test_params->bonded_slave_count; in test_roundrobin_tx_burst_slave_tx_fail()
1562 test_params->slave_port_ids[i], in test_roundrobin_tx_burst_slave_tx_fail()
1596 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_rx_burst_on_single_slave()
1598 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_single_slave()
1604 test_params->bonded_port_id, 0, rx_pkt_burst, in test_roundrobin_rx_burst_on_single_slave()
1609 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_rx_burst_on_single_slave()
1612 test_params->bonded_port_id, in test_roundrobin_rx_burst_on_single_slave()
1619 for (j = 0; j < test_params->bonded_slave_count; j++) { in test_roundrobin_rx_burst_on_single_slave()
1620 rte_eth_stats_get(test_params->slave_port_ids[j], &port_stats); in test_roundrobin_rx_burst_on_single_slave()
1625 " (%d)", test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_single_slave()
1630 " (%d)", test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_single_slave()
1635 rte_eth_stats_reset(test_params->slave_port_ids[j]); in test_roundrobin_rx_burst_on_single_slave()
1638 rte_eth_stats_reset(test_params->bonded_port_id); in test_roundrobin_rx_burst_on_single_slave()
1679 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_multiple_slaves()
1685 nb_rx = rte_eth_rx_burst(test_params->bonded_port_id, 0, rx_pkt_burst, in test_roundrobin_rx_burst_on_multiple_slaves()
1692 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1696 test_params->bonded_port_id, (unsigned int)port_stats.ipackets, in test_roundrobin_rx_burst_on_multiple_slaves()
1700 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1703 test_params->slave_port_ids[0], in test_roundrobin_rx_burst_on_multiple_slaves()
1706 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1709 test_params->slave_port_ids[1], (unsigned int)port_stats.ipackets, in test_roundrobin_rx_burst_on_multiple_slaves()
1712 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1715 test_params->slave_port_ids[2], in test_roundrobin_rx_burst_on_multiple_slaves()
1718 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1721 test_params->slave_port_ids[3], in test_roundrobin_rx_burst_on_multiple_slaves()
1742 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &expected_mac_addr_0), in test_roundrobin_verify_mac_assignment()
1744 test_params->slave_port_ids[0]); in test_roundrobin_verify_mac_assignment()
1745 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[2], &expected_mac_addr_2), in test_roundrobin_verify_mac_assignment()
1747 test_params->slave_port_ids[2]); in test_roundrobin_verify_mac_assignment()
1755 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1756 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1758 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1762 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1766 TEST_ASSERT_SUCCESS(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_roundrobin_verify_mac_assignment()
1767 test_params->slave_port_ids[2]), in test_roundrobin_verify_mac_assignment()
1769 test_params->bonded_port_id, test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1771 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1772 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1774 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1779 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1784 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_roundrobin_verify_mac_assignment()
1786 test_params->bonded_port_id); in test_roundrobin_verify_mac_assignment()
1788 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_roundrobin_verify_mac_assignment()
1791 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1793 test_params->bonded_port_id); in test_roundrobin_verify_mac_assignment()
1797 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1799 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1800 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1802 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1806 " port", test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1811 test_params->bonded_port_id, in test_roundrobin_verify_mac_assignment()
1815 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1817 test_params->bonded_port_id); in test_roundrobin_verify_mac_assignment()
1821 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1823 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1824 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1826 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1829 " that of new primary port\n", test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1847 ret = rte_eth_promiscuous_enable(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1850 test_params->bonded_port_id, rte_strerror(-ret)); in test_roundrobin_verify_promiscuous_enable_disable()
1852 promiscuous_en = rte_eth_promiscuous_get(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1855 test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1857 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_promiscuous_enable_disable()
1859 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1862 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1865 ret = rte_eth_promiscuous_disable(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1868 test_params->bonded_port_id, rte_strerror(-ret)); in test_roundrobin_verify_promiscuous_enable_disable()
1870 promiscuous_en = rte_eth_promiscuous_get(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1873 test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1875 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_promiscuous_enable_disable()
1877 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1880 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1912 slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, slaves, in test_roundrobin_verify_slave_link_status_change_behaviour()
1918 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_roundrobin_verify_slave_link_status_change_behaviour()
1926 test_params->slave_port_ids[1], 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1928 test_params->slave_port_ids[3], 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1930 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_roundrobin_verify_slave_link_status_change_behaviour()
1950 rte_eth_stats_reset(test_params->bonded_port_id); in test_roundrobin_verify_slave_link_status_change_behaviour()
1954 rte_eth_tx_burst(test_params->bonded_port_id, 0, tx_pkt_burst, in test_roundrobin_verify_slave_link_status_change_behaviour()
1957 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1960 test_params->bonded_port_id, (int)port_stats.opackets, in test_roundrobin_verify_slave_link_status_change_behaviour()
1963 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1966 test_params->slave_port_ids[0], (int)port_stats.opackets, 10); in test_roundrobin_verify_slave_link_status_change_behaviour()
1968 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1971 test_params->slave_port_ids[1], (int)port_stats.opackets, 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1973 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1976 test_params->slave_port_ids[2], (int)port_stats.opackets, 10); in test_roundrobin_verify_slave_link_status_change_behaviour()
1978 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1981 test_params->slave_port_ids[3], (int)port_stats.opackets, 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1997 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_roundrobin_verify_slave_link_status_change_behaviour()
2002 test_params->bonded_port_id, 0, rx_pkt_burst, MAX_PKT_BURST), in test_roundrobin_verify_slave_link_status_change_behaviour()
2007 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
2010 test_params->bonded_port_id); in test_roundrobin_verify_slave_link_status_change_behaviour()
2057 TEST_ASSERT_SUCCESS(rte_eth_bond_slave_add(test_params->bonded_port_id, in test_roundrobin_verfiy_polling_slave_link_status_change()
2061 test_params->bonded_port_id); in test_roundrobin_verfiy_polling_slave_link_status_change()
2065 TEST_ASSERT_SUCCESS(configure_ethdev(test_params->bonded_port_id, 1, 1), in test_roundrobin_verfiy_polling_slave_link_status_change()
2067 test_params->bonded_port_id); in test_roundrobin_verfiy_polling_slave_link_status_change()
2071 rte_eth_dev_callback_register(test_params->bonded_port_id, in test_roundrobin_verfiy_polling_slave_link_status_change()
2073 &test_params->bonded_port_id); in test_roundrobin_verfiy_polling_slave_link_status_change()
2099 rte_eth_dev_callback_unregister(test_params->bonded_port_id, in test_roundrobin_verfiy_polling_slave_link_status_change()
2101 &test_params->bonded_port_id); in test_roundrobin_verfiy_polling_slave_link_status_change()
2108 rte_eth_bond_slave_remove(test_params->bonded_port_id, in test_roundrobin_verfiy_polling_slave_link_status_change()
2111 polling_test_slaves[i], test_params->bonded_port_id); in test_roundrobin_verfiy_polling_slave_link_status_change()
2131 initialize_eth_header(test_params->pkt_eth_hdr, in test_activebackup_tx_burst()
2135 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in test_activebackup_tx_burst()
2137 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in test_activebackup_tx_burst()
2140 burst_size = 20 * test_params->bonded_slave_count; in test_activebackup_tx_burst()
2146 TEST_ASSERT_EQUAL(generate_packet_burst(test_params->mbuf_pool, pkts_burst, in test_activebackup_tx_burst()
2147 test_params->pkt_eth_hdr, 0, test_params->pkt_ipv4_hdr, 1, in test_activebackup_tx_burst()
2148 test_params->pkt_udp_hdr, burst_size, PACKET_BURST_GEN_PKT_LEN, 1), in test_activebackup_tx_burst()
2152 TEST_ASSERT_EQUAL(rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst, in test_activebackup_tx_burst()
2156 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_activebackup_tx_burst()
2159 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_activebackup_tx_burst()
2162 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_activebackup_tx_burst()
2165 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_activebackup_tx_burst()
2166 rte_eth_stats_get(test_params->slave_port_ids[i], &port_stats); in test_activebackup_tx_burst()
2167 if (test_params->slave_port_ids[i] == primary_port) { in test_activebackup_tx_burst()
2170 test_params->bonded_port_id, in test_activebackup_tx_burst()
2172 burst_size / test_params->bonded_slave_count); in test_activebackup_tx_burst()
2176 test_params->bonded_port_id, in test_activebackup_tx_burst()
2182 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_activebackup_tx_burst()
2184 test_params->slave_port_ids[i], 0); in test_activebackup_tx_burst()
2188 TEST_ASSERT_EQUAL(rte_eth_tx_burst(test_params->bonded_port_id, 0, in test_activebackup_tx_burst()
2214 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_activebackup_rx_burst()
2217 test_params->bonded_port_id); in test_activebackup_rx_burst()
2219 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_activebackup_rx_burst()
2226 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_activebackup_rx_burst()
2230 TEST_ASSERT_EQUAL(rte_eth_rx_burst(test_params->bonded_port_id, 0, in test_activebackup_rx_burst()
2234 if (test_params->slave_port_ids[i] == primary_port) { in test_activebackup_rx_burst()
2236 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_activebackup_rx_burst()
2239 test_params->bonded_port_id, in test_activebackup_rx_burst()
2243 for (j = 0; j < test_params->bonded_slave_count; j++) { in test_activebackup_rx_burst()
2244 rte_eth_stats_get(test_params->slave_port_ids[j], &port_stats); in test_activebackup_rx_burst()
2248 "expected (%d)", test_params->slave_port_ids[i], in test_activebackup_rx_burst()
2253 "expected (%d)\n", test_params->slave_port_ids[i], in test_activebackup_rx_burst()
2258 for (j = 0; j < test_params->bonded_slave_count; j++) { in test_activebackup_rx_burst()
2259 rte_eth_stats_get(test_params->slave_port_ids[j], &port_stats); in test_activebackup_rx_burst()
2262 "(%d)", test_params->slave_port_ids[i], in test_activebackup_rx_burst()
2276 rte_eth_stats_reset(test_params->bonded_port_id); in test_activebackup_rx_burst()
2294 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_activebackup_verify_promiscuous_enable_disable()
2297 test_params->bonded_port_id); in test_activebackup_verify_promiscuous_enable_disable()
2299 ret = rte_eth_promiscuous_enable(test_params->bonded_port_id); in test_activebackup_verify_promiscuous_enable_disable()
2302 test_params->bonded_port_id, rte_strerror(-ret)); in test_activebackup_verify_promiscuous_enable_disable()
2304 TEST_ASSERT_EQUAL(rte_eth_promiscuous_get(test_params->bonded_port_id), 1, in test_activebackup_verify_promiscuous_enable_disable()
2306 test_params->bonded_port_id); in test_activebackup_verify_promiscuous_enable_disable()
2308 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_activebackup_verify_promiscuous_enable_disable()
2310 test_params->slave_port_ids[i]); in test_activebackup_verify_promiscuous_enable_disable()
2311 if (primary_port == test_params->slave_port_ids[i]) { in test_activebackup_verify_promiscuous_enable_disable()
2314 test_params->slave_port_ids[i]); in test_activebackup_verify_promiscuous_enable_disable()
2318 test_params->slave_port_ids[i]); in test_activebackup_verify_promiscuous_enable_disable()
2323 ret = rte_eth_promiscuous_disable(test_params->bonded_port_id); in test_activebackup_verify_promiscuous_enable_disable()
2326 test_params->bonded_port_id, rte_strerror(-ret)); in test_activebackup_verify_promiscuous_enable_disable()
2328 TEST_ASSERT_EQUAL(rte_eth_promiscuous_get(test_params->bonded_port_id), 0, in test_activebackup_verify_promiscuous_enable_disable()
2330 test_params->bonded_port_id); in test_activebackup_verify_promiscuous_enable_disable()
2332 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_activebackup_verify_promiscuous_enable_disable()
2334 test_params->slave_port_ids[i]); in test_activebackup_verify_promiscuous_enable_disable()
2337 test_params->slave_port_ids[i]); in test_activebackup_verify_promiscuous_enable_disable()
2350 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &expected_mac_addr_0), in test_activebackup_verify_mac_assignment()
2352 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2353 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &expected_mac_addr_1), in test_activebackup_verify_mac_assignment()
2355 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2364 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_activebackup_verify_mac_assignment()
2366 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2370 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2372 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2374 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2378 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2380 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2382 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2386 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2389 TEST_ASSERT_EQUAL(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_activebackup_verify_mac_assignment()
2390 test_params->slave_port_ids[1]), 0, in test_activebackup_verify_mac_assignment()
2392 test_params->bonded_port_id, test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2394 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_activebackup_verify_mac_assignment()
2396 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2400 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2402 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2404 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2408 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2410 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2412 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2416 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2421 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_activebackup_verify_mac_assignment()
2423 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2425 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_activebackup_verify_mac_assignment()
2428 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_activebackup_verify_mac_assignment()
2430 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2434 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2436 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2438 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2442 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2444 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2446 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2450 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2454 test_params->bonded_port_id, in test_activebackup_verify_mac_assignment()
2458 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_activebackup_verify_mac_assignment()
2460 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2464 test_params->bonded_port_id); in test_activebackup_verify_mac_assignment()
2466 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2468 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2472 test_params->slave_port_ids[0]); in test_activebackup_verify_mac_assignment()
2474 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_activebackup_verify_mac_assignment()
2476 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2480 test_params->slave_port_ids[1]); in test_activebackup_verify_mac_assignment()
2513 slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, slaves, in test_activebackup_verify_slave_link_status_change_failover()
2519 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_activebackup_verify_slave_link_status_change_failover()
2525 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_activebackup_verify_slave_link_status_change_failover()
2526 TEST_ASSERT_EQUAL(primary_port, test_params->slave_port_ids[0], in test_activebackup_verify_slave_link_status_change_failover()
2531 test_params->slave_port_ids[1], 0); in test_activebackup_verify_slave_link_status_change_failover()
2533 test_params->slave_port_ids[3], 0); in test_activebackup_verify_slave_link_status_change_failover()
2536 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS), 2, in test_activebackup_verify_slave_link_status_change_failover()
2541 test_params->slave_port_ids[1], 1); in test_activebackup_verify_slave_link_status_change_failover()
2543 test_params->slave_port_ids[3], 1); in test_activebackup_verify_slave_link_status_change_failover()
2549 test_params->slave_port_ids[0], 0); in test_activebackup_verify_slave_link_status_change_failover()
2552 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS), in test_activebackup_verify_slave_link_status_change_failover()
2557 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_activebackup_verify_slave_link_status_change_failover()
2558 TEST_ASSERT_EQUAL(primary_port, test_params->slave_port_ids[2], in test_activebackup_verify_slave_link_status_change_failover()
2564 test_params->bonded_port_id, 0, &pkt_burst[0][0], in test_activebackup_verify_slave_link_status_change_failover()
2567 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2570 test_params->slave_port_ids[2]); in test_activebackup_verify_slave_link_status_change_failover()
2572 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2575 test_params->slave_port_ids[0]); in test_activebackup_verify_slave_link_status_change_failover()
2577 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2580 test_params->slave_port_ids[1]); in test_activebackup_verify_slave_link_status_change_failover()
2582 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2585 test_params->slave_port_ids[3]); in test_activebackup_verify_slave_link_status_change_failover()
2595 test_params->slave_port_ids[i], &pkt_burst[i][0], burst_size); in test_activebackup_verify_slave_link_status_change_failover()
2599 test_params->bonded_port_id, 0, rx_pkt_burst, MAX_PKT_BURST), in test_activebackup_verify_slave_link_status_change_failover()
2603 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2606 test_params->bonded_port_id); in test_activebackup_verify_slave_link_status_change_failover()
2608 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2611 test_params->slave_port_ids[2]); in test_activebackup_verify_slave_link_status_change_failover()
2613 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2616 test_params->slave_port_ids[0]); in test_activebackup_verify_slave_link_status_change_failover()
2618 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2621 test_params->slave_port_ids[1]); in test_activebackup_verify_slave_link_status_change_failover()
2623 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_activebackup_verify_slave_link_status_change_failover()
2626 test_params->slave_port_ids[3]); in test_activebackup_verify_slave_link_status_change_failover()
2648 test_params->slave_port_ids[0], BALANCE_XMIT_POLICY_LAYER2), in test_balance_xmit_policy_configuration()
2653 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER2), in test_balance_xmit_policy_configuration()
2656 TEST_ASSERT_EQUAL(rte_eth_bond_xmit_policy_get(test_params->bonded_port_id), in test_balance_xmit_policy_configuration()
2661 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER23), in test_balance_xmit_policy_configuration()
2664 TEST_ASSERT_EQUAL(rte_eth_bond_xmit_policy_get(test_params->bonded_port_id), in test_balance_xmit_policy_configuration()
2670 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER34), in test_balance_xmit_policy_configuration()
2673 TEST_ASSERT_EQUAL(rte_eth_bond_xmit_policy_get(test_params->bonded_port_id), in test_balance_xmit_policy_configuration()
2702 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER2), in test_balance_l2_tx_burst()
2705 initialize_eth_header(test_params->pkt_eth_hdr, in test_balance_l2_tx_burst()
2709 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in test_balance_l2_tx_burst()
2711 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in test_balance_l2_tx_burst()
2715 TEST_ASSERT_EQUAL(generate_packet_burst(test_params->mbuf_pool, &pkts_burst[0][0], in test_balance_l2_tx_burst()
2716 test_params->pkt_eth_hdr, 0, test_params->pkt_ipv4_hdr, 1, in test_balance_l2_tx_burst()
2717 test_params->pkt_udp_hdr, burst_size[0], in test_balance_l2_tx_burst()
2721 initialize_eth_header(test_params->pkt_eth_hdr, in test_balance_l2_tx_burst()
2727 TEST_ASSERT_EQUAL(generate_packet_burst(test_params->mbuf_pool, &pkts_burst[1][0], in test_balance_l2_tx_burst()
2728 test_params->pkt_eth_hdr, 0, test_params->pkt_ipv4_hdr, 1, in test_balance_l2_tx_burst()
2729 test_params->pkt_udp_hdr, burst_size[1], in test_balance_l2_tx_burst()
2735 TEST_ASSERT_EQUAL(rte_eth_tx_burst(test_params->bonded_port_id, 0, in test_balance_l2_tx_burst()
2741 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_balance_l2_tx_burst()
2745 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_balance_l2_tx_burst()
2750 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_balance_l2_tx_burst()
2753 test_params->slave_port_ids[0], (unsigned int)port_stats.opackets, in test_balance_l2_tx_burst()
2756 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_balance_l2_tx_burst()
2759 test_params->slave_port_ids[1], (unsigned int)port_stats.opackets, in test_balance_l2_tx_burst()
2763 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_balance_l2_tx_burst()
2766 test_params->slave_port_ids[i], 0); in test_balance_l2_tx_burst()
2771 test_params->bonded_port_id, 0, &pkts_burst[0][0], burst_size[0]), in test_balance_l2_tx_burst()
2794 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER23), in balance_l23_tx_burst()
2813 nb_tx_1 = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst_1, in balance_l23_tx_burst()
2818 nb_tx_2 = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst_2, in balance_l23_tx_burst()
2823 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in balance_l23_tx_burst()
2826 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in balance_l23_tx_burst()
2830 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in balance_l23_tx_burst()
2833 test_params->slave_port_ids[0], (unsigned int)port_stats.opackets, in balance_l23_tx_burst()
2836 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in balance_l23_tx_burst()
2839 test_params->slave_port_ids[1], (unsigned int)port_stats.opackets, in balance_l23_tx_burst()
2843 for (i = 0; i < test_params->bonded_slave_count; i++) { in balance_l23_tx_burst()
2846 test_params->slave_port_ids[i], 0); in balance_l23_tx_burst()
2851 test_params->bonded_port_id, 0, pkts_burst_1, in balance_l23_tx_burst()
2906 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER34), in balance_l34_tx_burst()
2925 nb_tx_1 = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst_1, in balance_l34_tx_burst()
2930 nb_tx_2 = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst_2, in balance_l34_tx_burst()
2936 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in balance_l34_tx_burst()
2939 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in balance_l34_tx_burst()
2943 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in balance_l34_tx_burst()
2946 test_params->slave_port_ids[0], (unsigned int)port_stats.opackets, in balance_l34_tx_burst()
2949 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in balance_l34_tx_burst()
2952 test_params->slave_port_ids[1], (unsigned int)port_stats.opackets, in balance_l34_tx_burst()
2956 for (i = 0; i < test_params->bonded_slave_count; i++) { in balance_l34_tx_burst()
2959 test_params->slave_port_ids[i], 0); in balance_l34_tx_burst()
2964 test_params->bonded_port_id, 0, pkts_burst_1, in balance_l34_tx_burst()
3031 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER2), in test_balance_tx_burst_slave_tx_fail()
3057 test_params->slave_port_ids[TEST_BAL_SLAVE_TX_FAIL_FAILING_SLAVE_IDX], in test_balance_tx_burst_slave_tx_fail()
3061 test_params->slave_port_ids[TEST_BAL_SLAVE_TX_FAIL_FAILING_SLAVE_IDX], in test_balance_tx_burst_slave_tx_fail()
3066 tx_count_1 = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst_1, in test_balance_tx_burst_slave_tx_fail()
3083 tx_count_2 = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst_2, in test_balance_tx_burst_slave_tx_fail()
3092 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_balance_tx_burst_slave_tx_fail()
3099 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_balance_tx_burst_slave_tx_fail()
3106 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_balance_tx_burst_slave_tx_fail()
3112 test_params->slave_port_ids[0], in test_balance_tx_burst_slave_tx_fail()
3120 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_balance_tx_burst_slave_tx_fail()
3125 test_params->slave_port_ids[1], in test_balance_tx_burst_slave_tx_fail()
3171 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_balance_rx_burst()
3177 TEST_ASSERT_EQUAL(rte_eth_rx_burst(test_params->bonded_port_id, 0, in test_balance_rx_burst()
3183 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_balance_rx_burst()
3187 test_params->bonded_port_id, (unsigned int)port_stats.ipackets, in test_balance_rx_burst()
3192 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_balance_rx_burst()
3195 test_params->slave_port_ids[0], in test_balance_rx_burst()
3198 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_balance_rx_burst()
3201 test_params->slave_port_ids[1], (unsigned int)port_stats.ipackets, in test_balance_rx_burst()
3204 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_balance_rx_burst()
3207 test_params->slave_port_ids[2], (unsigned int)port_stats.ipackets, in test_balance_rx_burst()
3210 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_balance_rx_burst()
3213 test_params->slave_port_ids[3], (unsigned int)port_stats.ipackets, in test_balance_rx_burst()
3241 ret = rte_eth_promiscuous_enable(test_params->bonded_port_id); in test_balance_verify_promiscuous_enable_disable()
3244 test_params->bonded_port_id, rte_strerror(-ret)); in test_balance_verify_promiscuous_enable_disable()
3246 TEST_ASSERT_EQUAL(rte_eth_promiscuous_get(test_params->bonded_port_id), 1, in test_balance_verify_promiscuous_enable_disable()
3248 test_params->bonded_port_id); in test_balance_verify_promiscuous_enable_disable()
3250 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_balance_verify_promiscuous_enable_disable()
3252 test_params->slave_port_ids[i]), 1, in test_balance_verify_promiscuous_enable_disable()
3254 test_params->slave_port_ids[i]); in test_balance_verify_promiscuous_enable_disable()
3257 ret = rte_eth_promiscuous_disable(test_params->bonded_port_id); in test_balance_verify_promiscuous_enable_disable()
3260 test_params->bonded_port_id, rte_strerror(-ret)); in test_balance_verify_promiscuous_enable_disable()
3262 TEST_ASSERT_EQUAL(rte_eth_promiscuous_get(test_params->bonded_port_id), 0, in test_balance_verify_promiscuous_enable_disable()
3264 test_params->bonded_port_id); in test_balance_verify_promiscuous_enable_disable()
3266 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_balance_verify_promiscuous_enable_disable()
3268 test_params->slave_port_ids[i]), 0, in test_balance_verify_promiscuous_enable_disable()
3270 test_params->slave_port_ids[i]); in test_balance_verify_promiscuous_enable_disable()
3283 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &expected_mac_addr_0), in test_balance_verify_mac_assignment()
3285 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3286 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &expected_mac_addr_1), in test_balance_verify_mac_assignment()
3288 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3297 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_balance_verify_mac_assignment()
3299 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3303 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3305 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_balance_verify_mac_assignment()
3307 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3311 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3313 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_balance_verify_mac_assignment()
3315 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3319 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3322 TEST_ASSERT_SUCCESS(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_balance_verify_mac_assignment()
3323 test_params->slave_port_ids[1]), in test_balance_verify_mac_assignment()
3325 test_params->bonded_port_id, test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3327 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_balance_verify_mac_assignment()
3329 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3333 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3335 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_balance_verify_mac_assignment()
3337 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3341 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3343 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_balance_verify_mac_assignment()
3345 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3349 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3354 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_balance_verify_mac_assignment()
3356 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3358 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_balance_verify_mac_assignment()
3361 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_balance_verify_mac_assignment()
3363 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3367 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3369 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_balance_verify_mac_assignment()
3371 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3375 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3377 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_balance_verify_mac_assignment()
3379 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3383 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3387 test_params->bonded_port_id, in test_balance_verify_mac_assignment()
3391 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_balance_verify_mac_assignment()
3393 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3397 test_params->bonded_port_id); in test_balance_verify_mac_assignment()
3399 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_balance_verify_mac_assignment()
3401 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3405 test_params->slave_port_ids[0]); in test_balance_verify_mac_assignment()
3407 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_balance_verify_mac_assignment()
3409 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3413 test_params->slave_port_ids[1]); in test_balance_verify_mac_assignment()
3440 test_params->bonded_port_id, BALANCE_XMIT_POLICY_LAYER2), in test_balance_verify_slave_link_status_change_behaviour()
3445 slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, slaves, in test_balance_verify_slave_link_status_change_behaviour()
3451 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_balance_verify_slave_link_status_change_behaviour()
3459 test_params->slave_port_ids[1], 0); in test_balance_verify_slave_link_status_change_behaviour()
3461 test_params->slave_port_ids[3], 0); in test_balance_verify_slave_link_status_change_behaviour()
3464 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS), 2, in test_balance_verify_slave_link_status_change_behaviour()
3481 test_params->bonded_port_id, 0, &pkt_burst[0][0], burst_size), in test_balance_verify_slave_link_status_change_behaviour()
3485 test_params->bonded_port_id, 0, &pkt_burst[1][0], burst_size), in test_balance_verify_slave_link_status_change_behaviour()
3489 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_balance_verify_slave_link_status_change_behaviour()
3492 test_params->bonded_port_id, (int)port_stats.opackets, in test_balance_verify_slave_link_status_change_behaviour()
3495 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_balance_verify_slave_link_status_change_behaviour()
3498 test_params->slave_port_ids[0], (int)port_stats.opackets, in test_balance_verify_slave_link_status_change_behaviour()
3501 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_balance_verify_slave_link_status_change_behaviour()
3504 test_params->slave_port_ids[2], (int)port_stats.opackets, in test_balance_verify_slave_link_status_change_behaviour()
3510 test_params->slave_port_ids[2], 0); in test_balance_verify_slave_link_status_change_behaviour()
3513 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS), 1, in test_balance_verify_slave_link_status_change_behaviour()
3522 test_params->bonded_port_id, 0, &pkt_burst[1][0], burst_size), in test_balance_verify_slave_link_status_change_behaviour()
3525 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_balance_verify_slave_link_status_change_behaviour()
3529 test_params->bonded_port_id, (int)port_stats.opackets, in test_balance_verify_slave_link_status_change_behaviour()
3532 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_balance_verify_slave_link_status_change_behaviour()
3535 test_params->slave_port_ids[0], (int)port_stats.opackets, in test_balance_verify_slave_link_status_change_behaviour()
3539 test_params->slave_port_ids[0], 0); in test_balance_verify_slave_link_status_change_behaviour()
3541 test_params->slave_port_ids[1], 1); in test_balance_verify_slave_link_status_change_behaviour()
3543 test_params->slave_port_ids[2], 1); in test_balance_verify_slave_link_status_change_behaviour()
3545 test_params->slave_port_ids[3], 1); in test_balance_verify_slave_link_status_change_behaviour()
3552 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_balance_verify_slave_link_status_change_behaviour()
3558 rte_eth_rx_burst(test_params->bonded_port_id, 0, rx_pkt_burst, in test_balance_verify_slave_link_status_change_behaviour()
3562 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_balance_verify_slave_link_status_change_behaviour()
3565 test_params->bonded_port_id, (int)port_stats.ipackets, in test_balance_verify_slave_link_status_change_behaviour()
3584 initialize_eth_header(test_params->pkt_eth_hdr, in test_broadcast_tx_burst()
3589 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in test_broadcast_tx_burst()
3591 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in test_broadcast_tx_burst()
3594 burst_size = 20 * test_params->bonded_slave_count; in test_broadcast_tx_burst()
3600 TEST_ASSERT_EQUAL(generate_packet_burst(test_params->mbuf_pool, in test_broadcast_tx_burst()
3601 pkts_burst, test_params->pkt_eth_hdr, 0, test_params->pkt_ipv4_hdr, in test_broadcast_tx_burst()
3602 1, test_params->pkt_udp_hdr, burst_size, PACKET_BURST_GEN_PKT_LEN, in test_broadcast_tx_burst()
3606 TEST_ASSERT_EQUAL(rte_eth_tx_burst(test_params->bonded_port_id, 0, in test_broadcast_tx_burst()
3610 test_params->bonded_port_id, burst_size); in test_broadcast_tx_burst()
3613 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_broadcast_tx_burst()
3615 (uint64_t)burst_size * test_params->bonded_slave_count, in test_broadcast_tx_burst()
3617 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_broadcast_tx_burst()
3621 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_tx_burst()
3622 rte_eth_stats_get(test_params->slave_port_ids[i], &port_stats); in test_broadcast_tx_burst()
3625 test_params->bonded_port_id, in test_broadcast_tx_burst()
3630 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_tx_burst()
3633 test_params->slave_port_ids[i], 0); in test_broadcast_tx_burst()
3638 test_params->bonded_port_id, 0, pkts_burst, burst_size), 0, in test_broadcast_tx_burst()
3680 test_params->slave_port_ids[0], in test_broadcast_tx_burst_slave_tx_fail()
3683 test_params->slave_port_ids[1], in test_broadcast_tx_burst_slave_tx_fail()
3686 test_params->slave_port_ids[2], in test_broadcast_tx_burst_slave_tx_fail()
3690 test_params->slave_port_ids[0], in test_broadcast_tx_burst_slave_tx_fail()
3694 test_params->slave_port_ids[1], in test_broadcast_tx_burst_slave_tx_fail()
3698 test_params->slave_port_ids[2], in test_broadcast_tx_burst_slave_tx_fail()
3702 tx_count = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkts_burst, in test_broadcast_tx_burst_slave_tx_fail()
3720 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_broadcast_tx_burst_slave_tx_fail()
3726 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_broadcast_tx_burst_slave_tx_fail()
3731 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_broadcast_tx_burst_slave_tx_fail()
3737 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_broadcast_tx_burst_slave_tx_fail()
3741 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_broadcast_tx_burst_slave_tx_fail()
3747 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_broadcast_tx_burst_slave_tx_fail()
3793 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_broadcast_rx_burst()
3801 test_params->bonded_port_id, 0, rx_pkt_burst, MAX_PKT_BURST), in test_broadcast_rx_burst()
3806 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_broadcast_rx_burst()
3810 test_params->bonded_port_id, (unsigned int)port_stats.ipackets, in test_broadcast_rx_burst()
3815 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_broadcast_rx_burst()
3818 test_params->slave_port_ids[0], (unsigned int)port_stats.ipackets, in test_broadcast_rx_burst()
3821 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_broadcast_rx_burst()
3824 test_params->slave_port_ids[0], (unsigned int)port_stats.ipackets, in test_broadcast_rx_burst()
3827 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_broadcast_rx_burst()
3830 test_params->slave_port_ids[2], (unsigned int)port_stats.ipackets, in test_broadcast_rx_burst()
3833 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_broadcast_rx_burst()
3836 test_params->slave_port_ids[3], (unsigned int)port_stats.ipackets, in test_broadcast_rx_burst()
3864 ret = rte_eth_promiscuous_enable(test_params->bonded_port_id); in test_broadcast_verify_promiscuous_enable_disable()
3867 test_params->bonded_port_id, rte_strerror(-ret)); in test_broadcast_verify_promiscuous_enable_disable()
3870 TEST_ASSERT_EQUAL(rte_eth_promiscuous_get(test_params->bonded_port_id), 1, in test_broadcast_verify_promiscuous_enable_disable()
3872 test_params->bonded_port_id); in test_broadcast_verify_promiscuous_enable_disable()
3874 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_verify_promiscuous_enable_disable()
3876 test_params->slave_port_ids[i]), 1, in test_broadcast_verify_promiscuous_enable_disable()
3878 test_params->slave_port_ids[i]); in test_broadcast_verify_promiscuous_enable_disable()
3881 ret = rte_eth_promiscuous_disable(test_params->bonded_port_id); in test_broadcast_verify_promiscuous_enable_disable()
3884 test_params->bonded_port_id, rte_strerror(-ret)); in test_broadcast_verify_promiscuous_enable_disable()
3886 TEST_ASSERT_EQUAL(rte_eth_promiscuous_get(test_params->bonded_port_id), 0, in test_broadcast_verify_promiscuous_enable_disable()
3888 test_params->bonded_port_id); in test_broadcast_verify_promiscuous_enable_disable()
3890 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_verify_promiscuous_enable_disable()
3892 test_params->slave_port_ids[i]), 0, in test_broadcast_verify_promiscuous_enable_disable()
3894 test_params->slave_port_ids[i]); in test_broadcast_verify_promiscuous_enable_disable()
3909 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &expected_mac_addr_0), in test_broadcast_verify_mac_assignment()
3911 test_params->slave_port_ids[0]); in test_broadcast_verify_mac_assignment()
3912 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[2], &expected_mac_addr_1), in test_broadcast_verify_mac_assignment()
3914 test_params->slave_port_ids[2]); in test_broadcast_verify_mac_assignment()
3923 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_verify_mac_assignment()
3924 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_broadcast_verify_mac_assignment()
3926 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3930 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3934 TEST_ASSERT_SUCCESS(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_broadcast_verify_mac_assignment()
3935 test_params->slave_port_ids[2]), in test_broadcast_verify_mac_assignment()
3937 test_params->bonded_port_id, test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3939 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_verify_mac_assignment()
3940 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_broadcast_verify_mac_assignment()
3942 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3947 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3953 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_broadcast_verify_mac_assignment()
3955 test_params->bonded_port_id); in test_broadcast_verify_mac_assignment()
3957 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_broadcast_verify_mac_assignment()
3960 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_broadcast_verify_mac_assignment()
3962 test_params->bonded_port_id); in test_broadcast_verify_mac_assignment()
3966 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3968 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_verify_mac_assignment()
3969 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_broadcast_verify_mac_assignment()
3971 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3975 "port", test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3980 test_params->bonded_port_id, in test_broadcast_verify_mac_assignment()
3984 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_broadcast_verify_mac_assignment()
3986 test_params->bonded_port_id); in test_broadcast_verify_mac_assignment()
3990 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
3993 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_broadcast_verify_mac_assignment()
3994 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_broadcast_verify_mac_assignment()
3996 test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
4000 "port", test_params->slave_port_ids[i]); in test_broadcast_verify_mac_assignment()
4027 slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, slaves, in test_broadcast_verify_slave_link_status_change_behaviour()
4033 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_broadcast_verify_slave_link_status_change_behaviour()
4041 test_params->slave_port_ids[1], 0); in test_broadcast_verify_slave_link_status_change_behaviour()
4043 test_params->slave_port_ids[3], 0); in test_broadcast_verify_slave_link_status_change_behaviour()
4045 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_broadcast_verify_slave_link_status_change_behaviour()
4051 for (i = 0; i < test_params->bonded_slave_count; i++) in test_broadcast_verify_slave_link_status_change_behaviour()
4052 rte_eth_stats_reset(test_params->slave_port_ids[i]); in test_broadcast_verify_slave_link_status_change_behaviour()
4061 TEST_ASSERT_EQUAL(rte_eth_tx_burst(test_params->bonded_port_id, 0, in test_broadcast_verify_slave_link_status_change_behaviour()
4065 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_broadcast_verify_slave_link_status_change_behaviour()
4068 test_params->bonded_port_id, (int)port_stats.opackets, in test_broadcast_verify_slave_link_status_change_behaviour()
4071 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_broadcast_verify_slave_link_status_change_behaviour()
4074 test_params->slave_port_ids[0]); in test_broadcast_verify_slave_link_status_change_behaviour()
4076 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_broadcast_verify_slave_link_status_change_behaviour()
4079 test_params->slave_port_ids[1]); in test_broadcast_verify_slave_link_status_change_behaviour()
4081 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_broadcast_verify_slave_link_status_change_behaviour()
4084 test_params->slave_port_ids[2]); in test_broadcast_verify_slave_link_status_change_behaviour()
4087 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_broadcast_verify_slave_link_status_change_behaviour()
4090 test_params->slave_port_ids[3]); in test_broadcast_verify_slave_link_status_change_behaviour()
4098 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_broadcast_verify_slave_link_status_change_behaviour()
4104 test_params->bonded_port_id, 0, rx_pkt_burst, MAX_PKT_BURST), in test_broadcast_verify_slave_link_status_change_behaviour()
4109 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_broadcast_verify_slave_link_status_change_behaviour()
4112 test_params->bonded_port_id); in test_broadcast_verify_slave_link_status_change_behaviour()
4121 test_params->nb_rx_q = 4; in test_reconfigure_bonded_device()
4122 test_params->nb_tx_q = 4; in test_reconfigure_bonded_device()
4124 TEST_ASSERT_SUCCESS(configure_ethdev(test_params->bonded_port_id, 0, 0), in test_reconfigure_bonded_device()
4127 test_params->nb_rx_q = 2; in test_reconfigure_bonded_device()
4128 test_params->nb_tx_q = 2; in test_reconfigure_bonded_device()
4130 TEST_ASSERT_SUCCESS(configure_ethdev(test_params->bonded_port_id, 0, 0), in test_reconfigure_bonded_device()
4140 rte_eth_dev_close(test_params->bonded_port_id); in test_close_bonded_device()
4147 free(test_params->pkt_eth_hdr); in testsuite_teardown()
4148 test_params->pkt_eth_hdr = NULL; in testsuite_teardown()
4161 for (slave_port = 0; slave_port < test_params->bonded_slave_count; in free_virtualpmd_tx_queue()
4164 test_params->slave_port_ids[slave_port], in free_virtualpmd_tx_queue()
4185 burst_size = 20 * test_params->bonded_slave_count; in test_tlb_tx_burst()
4195 initialize_eth_header(test_params->pkt_eth_hdr, in test_tlb_tx_burst()
4200 initialize_eth_header(test_params->pkt_eth_hdr, in test_tlb_tx_burst()
4201 (struct rte_ether_addr *)test_params->default_slave_mac, in test_tlb_tx_burst()
4205 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in test_tlb_tx_burst()
4207 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in test_tlb_tx_burst()
4209 generate_packet_burst(test_params->mbuf_pool, pkt_burst, in test_tlb_tx_burst()
4210 test_params->pkt_eth_hdr, 0, test_params->pkt_ipv4_hdr, in test_tlb_tx_burst()
4211 1, test_params->pkt_udp_hdr, burst_size, 60, 1); in test_tlb_tx_burst()
4213 nb_tx = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkt_burst, in test_tlb_tx_burst()
4227 rte_eth_stats_get(test_params->bonded_port_id, &port_stats[0]); in test_tlb_tx_burst()
4234 test_params->bonded_port_id, (unsigned int)port_stats[0].opackets, in test_tlb_tx_burst()
4239 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_tlb_tx_burst()
4240 rte_eth_stats_get(test_params->slave_port_ids[i], &port_stats[i]); in test_tlb_tx_burst()
4248 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_tlb_tx_burst()
4255 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_tlb_tx_burst()
4257 test_params->slave_port_ids[i], 0); in test_tlb_tx_burst()
4261 nb_tx = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkt_burst, in test_tlb_tx_burst()
4290 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_tlb_rx_burst()
4293 test_params->bonded_port_id); in test_tlb_rx_burst()
4295 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_tlb_rx_burst()
4302 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_tlb_rx_burst()
4306 nb_rx = rte_eth_rx_burst(test_params->bonded_port_id, 0, in test_tlb_rx_burst()
4311 if (test_params->slave_port_ids[i] == primary_port) { in test_tlb_rx_burst()
4313 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_tlb_rx_burst()
4316 test_params->bonded_port_id, in test_tlb_rx_burst()
4320 for (j = 0; j < test_params->bonded_slave_count; j++) { in test_tlb_rx_burst()
4321 rte_eth_stats_get(test_params->slave_port_ids[j], &port_stats); in test_tlb_rx_burst()
4325 test_params->slave_port_ids[i], in test_tlb_rx_burst()
4330 test_params->slave_port_ids[i], in test_tlb_rx_burst()
4335 for (j = 0; j < test_params->bonded_slave_count; j++) { in test_tlb_rx_burst()
4336 rte_eth_stats_get(test_params->slave_port_ids[j], &port_stats); in test_tlb_rx_burst()
4339 test_params->slave_port_ids[i], in test_tlb_rx_burst()
4349 rte_eth_stats_reset(test_params->bonded_port_id); in test_tlb_rx_burst()
4367 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4370 test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4372 ret = rte_eth_promiscuous_enable(test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4375 test_params->bonded_port_id, rte_strerror(-ret)); in test_tlb_verify_promiscuous_enable_disable()
4377 promiscuous_en = rte_eth_promiscuous_get(test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4380 test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4381 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_tlb_verify_promiscuous_enable_disable()
4383 test_params->slave_port_ids[i]); in test_tlb_verify_promiscuous_enable_disable()
4384 if (primary_port == test_params->slave_port_ids[i]) { in test_tlb_verify_promiscuous_enable_disable()
4387 test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4391 test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4396 ret = rte_eth_promiscuous_disable(test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4399 test_params->bonded_port_id, rte_strerror(-ret)); in test_tlb_verify_promiscuous_enable_disable()
4401 promiscuous_en = rte_eth_promiscuous_get(test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4404 test_params->bonded_port_id); in test_tlb_verify_promiscuous_enable_disable()
4406 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_tlb_verify_promiscuous_enable_disable()
4408 test_params->slave_port_ids[i]); in test_tlb_verify_promiscuous_enable_disable()
4411 test_params->slave_port_ids[i]); in test_tlb_verify_promiscuous_enable_disable()
4424 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &expected_mac_addr_0), in test_tlb_verify_mac_assignment()
4426 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4427 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &expected_mac_addr_1), in test_tlb_verify_mac_assignment()
4429 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4438 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_tlb_verify_mac_assignment()
4440 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4444 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4446 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_tlb_verify_mac_assignment()
4448 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4452 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4454 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_tlb_verify_mac_assignment()
4456 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4460 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4463 TEST_ASSERT_EQUAL(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_tlb_verify_mac_assignment()
4464 test_params->slave_port_ids[1]), 0, in test_tlb_verify_mac_assignment()
4466 test_params->bonded_port_id, test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4468 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_tlb_verify_mac_assignment()
4470 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4474 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4476 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_tlb_verify_mac_assignment()
4478 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4482 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4484 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_tlb_verify_mac_assignment()
4486 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4490 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4495 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_tlb_verify_mac_assignment()
4497 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4499 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_tlb_verify_mac_assignment()
4502 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_tlb_verify_mac_assignment()
4504 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4508 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4510 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_tlb_verify_mac_assignment()
4512 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4516 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4518 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_tlb_verify_mac_assignment()
4520 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4524 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4529 test_params->bonded_port_id, in test_tlb_verify_mac_assignment()
4533 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_tlb_verify_mac_assignment()
4535 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4539 test_params->bonded_port_id); in test_tlb_verify_mac_assignment()
4541 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &read_mac_addr), in test_tlb_verify_mac_assignment()
4543 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4547 test_params->slave_port_ids[0]); in test_tlb_verify_mac_assignment()
4549 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[1], &read_mac_addr), in test_tlb_verify_mac_assignment()
4551 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4555 test_params->slave_port_ids[1]); in test_tlb_verify_mac_assignment()
4585 slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, slaves, in test_tlb_verify_slave_link_status_change_failover()
4591 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_tlb_verify_slave_link_status_change_failover()
4597 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_tlb_verify_slave_link_status_change_failover()
4598 TEST_ASSERT_EQUAL(primary_port, test_params->slave_port_ids[0], in test_tlb_verify_slave_link_status_change_failover()
4603 test_params->slave_port_ids[1], 0); in test_tlb_verify_slave_link_status_change_failover()
4605 test_params->slave_port_ids[3], 0); in test_tlb_verify_slave_link_status_change_failover()
4608 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS), 2, in test_tlb_verify_slave_link_status_change_failover()
4613 test_params->slave_port_ids[1], 1); in test_tlb_verify_slave_link_status_change_failover()
4615 test_params->slave_port_ids[3], 1); in test_tlb_verify_slave_link_status_change_failover()
4621 test_params->slave_port_ids[0], 0); in test_tlb_verify_slave_link_status_change_failover()
4624 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS), 3, in test_tlb_verify_slave_link_status_change_failover()
4628 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_tlb_verify_slave_link_status_change_failover()
4629 TEST_ASSERT_EQUAL(primary_port, test_params->slave_port_ids[2], in test_tlb_verify_slave_link_status_change_failover()
4638 test_params->bonded_port_id, 0, &pkt_burst[0][0], burst_size), burst_size, in test_tlb_verify_slave_link_status_change_failover()
4643 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_tlb_verify_slave_link_status_change_failover()
4646 test_params->slave_port_ids[0]); in test_tlb_verify_slave_link_status_change_failover()
4648 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_tlb_verify_slave_link_status_change_failover()
4651 test_params->slave_port_ids[1]); in test_tlb_verify_slave_link_status_change_failover()
4653 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_tlb_verify_slave_link_status_change_failover()
4656 test_params->slave_port_ids[2]); in test_tlb_verify_slave_link_status_change_failover()
4658 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_tlb_verify_slave_link_status_change_failover()
4661 test_params->slave_port_ids[3]); in test_tlb_verify_slave_link_status_change_failover()
4672 test_params->slave_port_ids[i], &pkt_burst[i][0], burst_size); in test_tlb_verify_slave_link_status_change_failover()
4675 if (rte_eth_rx_burst(test_params->bonded_port_id, 0, rx_pkt_burst, in test_tlb_verify_slave_link_status_change_failover()
4683 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_tlb_verify_slave_link_status_change_failover()
4686 test_params->bonded_port_id); in test_tlb_verify_slave_link_status_change_failover()
4726 rte_eth_tx_burst(test_params->bonded_port_id, 0, NULL, 0); in test_alb_change_mac_in_reply_sent()
4727 for (slave_idx = 0; slave_idx < test_params->bonded_slave_count; in test_alb_change_mac_in_reply_sent()
4730 test_params->slave_port_ids[slave_idx], pkts_sent, in test_alb_change_mac_in_reply_sent()
4735 rte_eth_devices[test_params->bonded_port_id].data->mac_addrs, in test_alb_change_mac_in_reply_sent()
4742 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_change_mac_in_reply_sent()
4751 rte_eth_tx_burst(test_params->bonded_port_id, 0, &pkt, 1); in test_alb_change_mac_in_reply_sent()
4753 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_change_mac_in_reply_sent()
4762 rte_eth_tx_burst(test_params->bonded_port_id, 0, &pkt, 1); in test_alb_change_mac_in_reply_sent()
4764 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_change_mac_in_reply_sent()
4773 rte_eth_tx_burst(test_params->bonded_port_id, 0, &pkt, 1); in test_alb_change_mac_in_reply_sent()
4775 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_change_mac_in_reply_sent()
4784 rte_eth_tx_burst(test_params->bonded_port_id, 0, &pkt, 1); in test_alb_change_mac_in_reply_sent()
4787 rte_eth_devices[test_params->slave_port_ids[0]].data->mac_addrs; in test_alb_change_mac_in_reply_sent()
4789 rte_eth_devices[test_params->slave_port_ids[1]].data->mac_addrs; in test_alb_change_mac_in_reply_sent()
4795 for (slave_idx = 0; slave_idx < test_params->bonded_slave_count; slave_idx++) { in test_alb_change_mac_in_reply_sent()
4797 test_params->slave_port_ids[slave_idx], pkts_sent, in test_alb_change_mac_in_reply_sent()
4848 rte_eth_tx_burst(test_params->bonded_port_id, 0, NULL, 0); in test_alb_reply_from_client()
4849 for (slave_idx = 0; slave_idx < test_params->bonded_slave_count; slave_idx++) { in test_alb_reply_from_client()
4851 test_params->slave_port_ids[slave_idx], pkts_sent, in test_alb_reply_from_client()
4856 rte_eth_devices[test_params->bonded_port_id].data->mac_addrs, in test_alb_reply_from_client()
4863 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_reply_from_client()
4872 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[0], &pkt, in test_alb_reply_from_client()
4875 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_reply_from_client()
4884 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[0], &pkt, in test_alb_reply_from_client()
4887 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_reply_from_client()
4896 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[0], &pkt, in test_alb_reply_from_client()
4899 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_reply_from_client()
4908 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[0], &pkt, in test_alb_reply_from_client()
4915 rte_eth_rx_burst(test_params->bonded_port_id, 0, pkts_sent, MAX_PKT_BURST); in test_alb_reply_from_client()
4916 rte_eth_tx_burst(test_params->bonded_port_id, 0, NULL, 0); in test_alb_reply_from_client()
4918 slave_mac1 = rte_eth_devices[test_params->slave_port_ids[0]].data->mac_addrs; in test_alb_reply_from_client()
4919 slave_mac2 = rte_eth_devices[test_params->slave_port_ids[1]].data->mac_addrs; in test_alb_reply_from_client()
4924 for (slave_idx = 0; slave_idx < test_params->bonded_slave_count; slave_idx++) { in test_alb_reply_from_client()
4926 test_params->slave_port_ids[slave_idx], pkts_sent, MAX_PKT_BURST); in test_alb_reply_from_client()
4983 rte_eth_tx_burst(test_params->bonded_port_id, 0, NULL, 0); in test_alb_receive_vlan_reply()
4984 for (slave_idx = 0; slave_idx < test_params->bonded_slave_count; slave_idx++) { in test_alb_receive_vlan_reply()
4986 test_params->slave_port_ids[slave_idx], pkts_sent, in test_alb_receive_vlan_reply()
4991 rte_eth_devices[test_params->bonded_port_id].data->mac_addrs, in test_alb_receive_vlan_reply()
4997 pkt = rte_pktmbuf_alloc(test_params->mbuf_pool); in test_alb_receive_vlan_reply()
5011 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[0], &pkt, in test_alb_receive_vlan_reply()
5014 rte_eth_rx_burst(test_params->bonded_port_id, 0, pkts_sent, MAX_PKT_BURST); in test_alb_receive_vlan_reply()
5015 rte_eth_tx_burst(test_params->bonded_port_id, 0, NULL, 0); in test_alb_receive_vlan_reply()
5020 for (slave_idx = 0; slave_idx < test_params->bonded_slave_count; slave_idx++) { in test_alb_receive_vlan_reply()
5022 test_params->slave_port_ids[slave_idx], pkts_sent, in test_alb_receive_vlan_reply()
5082 test_params->bonded_port_id, 0, pkt_burst, burst_size); in test_alb_ipv4_tx()