Lines Matching refs:test_params

112 static struct link_bonding_unittest_params *test_params = &default_params;  variable
180 TEST_ASSERT_SUCCESS(rte_eth_dev_configure(port_id, test_params->nb_rx_q, in configure_ethdev()
181 test_params->nb_tx_q, &default_pmd_conf), in configure_ethdev()
188 for (q_id = 0; q_id < test_params->nb_rx_q; q_id++) in configure_ethdev()
191 test_params->mbuf_pool) , in configure_ethdev()
194 for (q_id = 0; q_id < test_params->nb_tx_q; q_id++) in configure_ethdev()
220 if (test_params->pkt_eth_hdr == NULL) { in test_setup()
221 test_params->pkt_eth_hdr = malloc(sizeof(struct rte_ether_hdr) + in test_setup()
224 TEST_ASSERT_NOT_NULL(test_params->pkt_eth_hdr, in test_setup()
230 if (test_params->mbuf_pool == NULL) { in test_setup()
231 test_params->mbuf_pool = rte_pktmbuf_pool_create("MBUF_POOL", in test_setup()
234 TEST_ASSERT_NOT_NULL(test_params->mbuf_pool, in test_setup()
247 test_params->slave_port_ids[i] = virtual_ethdev_create(pmd_name, in test_setup()
249 TEST_ASSERT(test_params->slave_port_ids[i] >= 0, in test_setup()
253 test_params->slave_port_ids[i], 1, 0), in test_setup()
270 if (test_params->bonded_port_id == -1) { in test_create_bonded_device()
271 test_params->bonded_port_id = rte_eth_bond_create(BONDED_DEV_NAME, in test_create_bonded_device()
272 test_params->bonding_mode, rte_socket_id()); in test_create_bonded_device()
274 TEST_ASSERT(test_params->bonded_port_id >= 0, in test_create_bonded_device()
277 TEST_ASSERT_SUCCESS(configure_ethdev(test_params->bonded_port_id, 0, 0), in test_create_bonded_device()
281 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in test_create_bonded_device()
282 test_params->bonding_mode), "Failed to set ethdev %d to mode %d", in test_create_bonded_device()
283 test_params->bonded_port_id, test_params->bonding_mode); in test_create_bonded_device()
285 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_create_bonded_device()
293 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_create_bonded_device()
308 test_params->bonding_mode = BONDING_MODE_ROUND_ROBIN; in test_create_bonded_device_with_invalid_params()
311 port_id = rte_eth_bond_create(NULL, test_params->bonding_mode, in test_create_bonded_device_with_invalid_params()
315 test_params->bonding_mode = INVALID_BONDING_MODE; in test_create_bonded_device_with_invalid_params()
318 port_id = rte_eth_bond_create(BONDED_DEV_NAME, test_params->bonding_mode, in test_create_bonded_device_with_invalid_params()
322 test_params->bonding_mode = BONDING_MODE_ROUND_ROBIN; in test_create_bonded_device_with_invalid_params()
325 port_id = rte_eth_bond_create(BONDED_DEV_NAME, test_params->bonding_mode, in test_create_bonded_device_with_invalid_params()
339 TEST_ASSERT_SUCCESS(rte_eth_bond_slave_add(test_params->bonded_port_id, in test_add_slave_to_bonded_device()
340 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_add_slave_to_bonded_device()
342 test_params->slave_port_ids[test_params->bonded_slave_count], in test_add_slave_to_bonded_device()
343 test_params->bonded_port_id); in test_add_slave_to_bonded_device()
345 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_add_slave_to_bonded_device()
347 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count + 1, in test_add_slave_to_bonded_device()
349 current_slave_count, test_params->bonded_slave_count + 1); in test_add_slave_to_bonded_device()
352 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_add_slave_to_bonded_device()
357 test_params->bonded_slave_count++; in test_add_slave_to_bonded_device()
366 TEST_ASSERT_FAIL(rte_eth_bond_slave_add(test_params->bonded_port_id + 5, in test_add_slave_to_invalid_bonded_device()
367 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_add_slave_to_invalid_bonded_device()
371 TEST_ASSERT_FAIL(rte_eth_bond_slave_add(test_params->slave_port_ids[0], in test_add_slave_to_invalid_bonded_device()
372 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_add_slave_to_invalid_bonded_device()
386 TEST_ASSERT_SUCCESS(rte_eth_bond_slave_remove(test_params->bonded_port_id, in test_remove_slave_from_bonded_device()
387 test_params->slave_port_ids[test_params->bonded_slave_count-1]), in test_remove_slave_from_bonded_device()
389 test_params->slave_port_ids[test_params->bonded_slave_count-1], in test_remove_slave_from_bonded_device()
390 test_params->bonded_port_id); in test_remove_slave_from_bonded_device()
393 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_remove_slave_from_bonded_device()
396 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count - 1, in test_remove_slave_from_bonded_device()
398 current_slave_count, test_params->bonded_slave_count - 1); in test_remove_slave_from_bonded_device()
403 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()
409 test_params->slave_port_ids[test_params->bonded_slave_count-1]); in test_remove_slave_from_bonded_device()
414 test_params->slave_port_ids[test_params->bonded_slave_count-1]); in test_remove_slave_from_bonded_device()
416 virtual_ethdev_simulate_link_status_interrupt(test_params->bonded_port_id, in test_remove_slave_from_bonded_device()
419 test_params->bonded_slave_count--; in test_remove_slave_from_bonded_device()
429 test_params->bonded_port_id + 5, in test_remove_slave_from_invalid_bonded_device()
430 test_params->slave_port_ids[test_params->bonded_slave_count - 1]), in test_remove_slave_from_invalid_bonded_device()
435 test_params->slave_port_ids[0], in test_remove_slave_from_invalid_bonded_device()
436 test_params->slave_port_ids[test_params->bonded_slave_count - 1]), in test_remove_slave_from_invalid_bonded_device()
453 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_add_already_bonded_slave_to_bonded_device()
461 port_id = rte_eth_bond_create(pmd_name, test_params->bonding_mode, 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()
469 test_params->slave_port_ids[test_params->bonded_slave_count-1], in test_add_already_bonded_slave_to_bonded_device()
497 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_get_slaves_from_bonded_device()
503 test_params->bonded_port_id, NULL, RTE_MAX_ETHPORTS); in test_get_slaves_from_bonded_device()
509 test_params->slave_port_ids[0], NULL, RTE_MAX_ETHPORTS); in test_get_slaves_from_bonded_device()
514 test_params->slave_port_ids[0], NULL, RTE_MAX_ETHPORTS); in test_get_slaves_from_bonded_device()
546 for (i = 0; i < test_params->bonded_slave_count; i++) { in enable_bonded_slaves()
547 virtual_ethdev_tx_burst_fn_set_success(test_params->slave_port_ids[i], in enable_bonded_slaves()
551 test_params->slave_port_ids[i], 1); in enable_bonded_slaves()
568 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_start_bonded_device()
570 test_params->bonded_port_id); in test_start_bonded_device()
575 test_params->slave_port_ids[test_params->bonded_slave_count-1], 1); in test_start_bonded_device()
577 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_start_bonded_device()
579 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count, in test_start_bonded_device()
581 current_slave_count, test_params->bonded_slave_count); in test_start_bonded_device()
584 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_start_bonded_device()
585 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count, in test_start_bonded_device()
587 current_slave_count, test_params->bonded_slave_count); in test_start_bonded_device()
589 current_bonding_mode = rte_eth_bond_mode_get(test_params->bonded_port_id); in test_start_bonded_device()
590 TEST_ASSERT_EQUAL(current_bonding_mode, test_params->bonding_mode, in test_start_bonded_device()
592 current_bonding_mode, test_params->bonding_mode); in test_start_bonded_device()
594 primary_port = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_start_bonded_device()
595 TEST_ASSERT_EQUAL(primary_port, test_params->slave_port_ids[0], in test_start_bonded_device()
597 primary_port, test_params->slave_port_ids[0]); in test_start_bonded_device()
599 retval = rte_eth_link_get(test_params->bonded_port_id, &link_status); in test_start_bonded_device()
602 test_params->bonded_port_id, rte_strerror(-retval)); in test_start_bonded_device()
605 test_params->bonded_port_id, link_status.link_status, 1); in test_start_bonded_device()
619 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_stop_bonded_device()
621 test_params->bonded_port_id); in test_stop_bonded_device()
623 retval = rte_eth_link_get(test_params->bonded_port_id, &link_status); in test_stop_bonded_device()
626 test_params->bonded_port_id, rte_strerror(-retval)); in test_stop_bonded_device()
629 test_params->bonded_port_id, link_status.link_status, 0); in test_stop_bonded_device()
631 current_slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, in test_stop_bonded_device()
633 TEST_ASSERT_EQUAL(current_slave_count, test_params->bonded_slave_count, in test_stop_bonded_device()
635 current_slave_count, test_params->bonded_slave_count); in test_stop_bonded_device()
638 test_params->bonded_port_id, slaves, RTE_MAX_ETHPORTS); in test_stop_bonded_device()
651 while (test_params->bonded_slave_count > 0) in remove_slaves_and_stop_bonded_device()
655 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in remove_slaves_and_stop_bonded_device()
657 test_params->bonded_port_id); in remove_slaves_and_stop_bonded_device()
659 rte_eth_stats_reset(test_params->bonded_port_id); in remove_slaves_and_stop_bonded_device()
660 rte_eth_bond_mac_address_reset(test_params->bonded_port_id); in remove_slaves_and_stop_bonded_device()
685 TEST_ASSERT_FAIL(rte_eth_bond_mode_set(test_params->slave_port_ids[0], in test_set_bonding_mode()
688 test_params->slave_port_ids[0]); in test_set_bonding_mode()
690 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in test_set_bonding_mode()
693 test_params->bonded_port_id, bonding_modes[i]); in test_set_bonding_mode()
695 bonding_mode = rte_eth_bond_mode_get(test_params->bonded_port_id); in test_set_bonding_mode()
698 bonding_mode, test_params->bonded_port_id, in test_set_bonding_mode()
708 bonding_mode = rte_eth_bond_mode_get(test_params->slave_port_ids[0]); in test_set_bonding_mode()
711 test_params->slave_port_ids[0]); in test_set_bonding_mode()
725 for (i = test_params->bonded_slave_count; i < 4; i++) in test_set_primary_slave()
729 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in test_set_primary_slave()
732 test_params->bonded_port_id, BONDING_MODE_ROUND_ROBIN); in test_set_primary_slave()
736 test_params->slave_port_ids[i]), in test_set_primary_slave()
740 TEST_ASSERT_FAIL(rte_eth_bond_primary_set(test_params->slave_port_ids[i], in test_set_primary_slave()
741 test_params->slave_port_ids[i]), in test_set_primary_slave()
750 TEST_ASSERT_SUCCESS(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_set_primary_slave()
751 test_params->slave_port_ids[i]), in test_set_primary_slave()
753 test_params->bonded_port_id, test_params->slave_port_ids[i]); in test_set_primary_slave()
755 retval = rte_eth_bond_primary_get(test_params->bonded_port_id); in test_set_primary_slave()
758 test_params->bonded_port_id); in test_set_primary_slave()
760 TEST_ASSERT_EQUAL(retval, test_params->slave_port_ids[i], in test_set_primary_slave()
762 test_params->bonded_port_id, retval, in test_set_primary_slave()
763 test_params->slave_port_ids[i]); in test_set_primary_slave()
766 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_set_primary_slave()
768 test_params->bonded_port_id); in test_set_primary_slave()
770 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_set_primary_slave()
772 test_params->bonded_port_id); in test_set_primary_slave()
778 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_set_primary_slave()
780 test_params->slave_port_ids[i]); in test_set_primary_slave()
786 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_set_primary_slave()
788 test_params->bonded_port_id); in test_set_primary_slave()
796 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[j], in test_set_primary_slave()
799 test_params->slave_port_ids[j]); in test_set_primary_slave()
810 TEST_ASSERT_FAIL(rte_eth_bond_primary_get(test_params->bonded_port_id + 10), in test_set_primary_slave()
814 TEST_ASSERT_FAIL(rte_eth_bond_primary_get(test_params->slave_port_ids[0]), in test_set_primary_slave()
821 TEST_ASSERT(rte_eth_bond_primary_get(test_params->bonded_port_id) < 0, in test_set_primary_slave()
844 test_params->slave_port_ids[0], mac_addr), in test_set_explicit_bonded_mac()
849 test_params->bonded_port_id, NULL), in test_set_explicit_bonded_mac()
853 test_params->bonded_port_id, mac_addr), in test_set_explicit_bonded_mac()
855 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
858 for (i = test_params->bonded_slave_count; i < 4; i++) { in test_set_explicit_bonded_mac()
864 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_set_explicit_bonded_mac()
866 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
872 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_set_explicit_bonded_mac()
874 test_params->slave_port_ids[i]); in test_set_explicit_bonded_mac()
882 rte_eth_bond_mac_address_reset(test_params->bonded_port_id), in test_set_explicit_bonded_mac()
884 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
887 rte_eth_bond_mac_address_reset(test_params->slave_port_ids[0]), in test_set_explicit_bonded_mac()
889 test_params->slave_port_ids[1]); in test_set_explicit_bonded_mac()
895 TEST_ASSERT_SUCCESS(rte_eth_bond_mac_address_reset(test_params->bonded_port_id), in test_set_explicit_bonded_mac()
897 test_params->bonded_port_id); in test_set_explicit_bonded_mac()
1130 TEST_ASSERT_SUCCESS(configure_ethdev(test_params->bonded_port_id, 0, in initialize_bonded_device_with_slaves()
1132 "with (%d) slaves.", test_params->bonded_port_id, bonding_mode, in initialize_bonded_device_with_slaves()
1136 while (number_of_slaves > test_params->bonded_slave_count) in initialize_bonded_device_with_slaves()
1139 test_params->bonded_slave_count - 1, in initialize_bonded_device_with_slaves()
1140 test_params->bonded_port_id); in initialize_bonded_device_with_slaves()
1143 TEST_ASSERT_SUCCESS(rte_eth_bond_mode_set(test_params->bonded_port_id, in initialize_bonded_device_with_slaves()
1146 test_params->bonded_port_id, bonding_mode); in initialize_bonded_device_with_slaves()
1148 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in initialize_bonded_device_with_slaves()
1150 test_params->bonded_port_id); in initialize_bonded_device_with_slaves()
1168 for (i = 0; i < test_params->bonded_slave_count + 1; i++) { in test_adding_slave_after_bonded_device_started()
1170 test_params->slave_port_ids[i], 1); in test_adding_slave_after_bonded_device_started()
1173 TEST_ASSERT_SUCCESS(rte_eth_bond_slave_add(test_params->bonded_port_id, in test_adding_slave_after_bonded_device_started()
1174 test_params->slave_port_ids[test_params->bonded_slave_count]), in test_adding_slave_after_bonded_device_started()
1178 test_params->slave_port_ids[test_params->bonded_slave_count]); in test_adding_slave_after_bonded_device_started()
1180 test_params->bonded_slave_count++; in test_adding_slave_after_bonded_device_started()
1253 rte_eth_dev_callback_register(test_params->bonded_port_id, in test_status_interrupt()
1255 &test_params->bonded_port_id); in test_status_interrupt()
1257 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_status_interrupt()
1267 test_params->slave_port_ids[0], 0); in test_status_interrupt()
1269 test_params->slave_port_ids[1], 0); in test_status_interrupt()
1271 test_params->slave_port_ids[2], 0); in test_status_interrupt()
1277 test_params->slave_port_ids[3], 0); in test_status_interrupt()
1285 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_status_interrupt()
1296 test_params->slave_port_ids[0], 1); in test_status_interrupt()
1310 test_params->slave_port_ids[0], 1); in test_status_interrupt()
1320 rte_eth_dev_callback_unregister(test_params->bonded_port_id, in test_status_interrupt()
1322 &test_params->bonded_port_id); in test_status_interrupt()
1342 initialize_eth_header(test_params->pkt_eth_hdr, in generate_test_burst()
1347 initialize_eth_header(test_params->pkt_eth_hdr, in generate_test_burst()
1354 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in generate_test_burst()
1357 pktlen = initialize_udp_header(test_params->pkt_udp_hdr, src_port, in generate_test_burst()
1362 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in generate_test_burst()
1365 pktlen = initialize_ipv4_header(test_params->pkt_ipv4_hdr, src_addr, in generate_test_burst()
1368 ip_hdr = test_params->pkt_ipv4_hdr; in generate_test_burst()
1371 pktlen = initialize_ipv6_header(test_params->pkt_ipv6_hdr, in generate_test_burst()
1375 pktlen = initialize_ipv6_header(test_params->pkt_ipv6_hdr, in generate_test_burst()
1379 ip_hdr = test_params->pkt_ipv6_hdr; in generate_test_burst()
1383 generated_burst_size = generate_packet_burst(test_params->mbuf_pool, in generate_test_burst()
1384 pkts_burst, test_params->pkt_eth_hdr, vlan, ip_hdr, ipv4, in generate_test_burst()
1385 test_params->pkt_udp_hdr, burst_size, PACKET_BURST_GEN_PKT_LEN_128, in generate_test_burst()
1406 burst_size = 20 * test_params->bonded_slave_count; in test_roundrobin_tx_burst()
1417 test_params->bonded_port_id, 0, pkt_burst, burst_size), burst_size, in test_roundrobin_tx_burst()
1421 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_tx_burst()
1424 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_roundrobin_tx_burst()
1428 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_tx_burst()
1429 rte_eth_stats_get(test_params->slave_port_ids[i], &port_stats); in test_roundrobin_tx_burst()
1431 (uint64_t)burst_size / test_params->bonded_slave_count, in test_roundrobin_tx_burst()
1433 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_roundrobin_tx_burst()
1434 burst_size / test_params->bonded_slave_count); in test_roundrobin_tx_burst()
1438 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_tx_burst()
1440 test_params->slave_port_ids[i], 0); in test_roundrobin_tx_burst()
1444 TEST_ASSERT_EQUAL(rte_eth_tx_burst(test_params->bonded_port_id, 0, in test_roundrobin_tx_burst()
1515 test_params->slave_port_ids[TEST_RR_SLAVE_TX_FAIL_FAILING_SLAVE_IDX], in test_roundrobin_tx_burst_slave_tx_fail()
1519 test_params->slave_port_ids[TEST_RR_SLAVE_TX_FAIL_FAILING_SLAVE_IDX], in test_roundrobin_tx_burst_slave_tx_fail()
1522 tx_count = rte_eth_tx_burst(test_params->bonded_port_id, 0, pkt_burst, in test_roundrobin_tx_burst_slave_tx_fail()
1539 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_tx_burst_slave_tx_fail()
1545 test_params->bonded_port_id, (unsigned int)port_stats.opackets, in test_roundrobin_tx_burst_slave_tx_fail()
1550 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_tx_burst_slave_tx_fail()
1553 rte_eth_stats_get(test_params->slave_port_ids[i], &port_stats); in test_roundrobin_tx_burst_slave_tx_fail()
1556 test_params->bonded_slave_count; in test_roundrobin_tx_burst_slave_tx_fail()
1565 test_params->slave_port_ids[i], in test_roundrobin_tx_burst_slave_tx_fail()
1599 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_rx_burst_on_single_slave()
1601 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_single_slave()
1607 test_params->bonded_port_id, 0, rx_pkt_burst, in test_roundrobin_rx_burst_on_single_slave()
1612 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_rx_burst_on_single_slave()
1615 test_params->bonded_port_id, in test_roundrobin_rx_burst_on_single_slave()
1622 for (j = 0; j < test_params->bonded_slave_count; j++) { in test_roundrobin_rx_burst_on_single_slave()
1623 rte_eth_stats_get(test_params->slave_port_ids[j], &port_stats); in test_roundrobin_rx_burst_on_single_slave()
1628 " (%d)", test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_single_slave()
1633 " (%d)", test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_single_slave()
1638 rte_eth_stats_reset(test_params->slave_port_ids[j]); in test_roundrobin_rx_burst_on_single_slave()
1641 rte_eth_stats_reset(test_params->bonded_port_id); in test_roundrobin_rx_burst_on_single_slave()
1681 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_roundrobin_rx_burst_on_multiple_slaves()
1687 nb_rx = rte_eth_rx_burst(test_params->bonded_port_id, 0, rx_pkt_burst, in test_roundrobin_rx_burst_on_multiple_slaves()
1694 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1698 test_params->bonded_port_id, (unsigned int)port_stats.ipackets, in test_roundrobin_rx_burst_on_multiple_slaves()
1702 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1705 test_params->slave_port_ids[0], in test_roundrobin_rx_burst_on_multiple_slaves()
1708 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1711 test_params->slave_port_ids[1], (unsigned int)port_stats.ipackets, in test_roundrobin_rx_burst_on_multiple_slaves()
1714 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1717 test_params->slave_port_ids[2], in test_roundrobin_rx_burst_on_multiple_slaves()
1720 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_roundrobin_rx_burst_on_multiple_slaves()
1723 test_params->slave_port_ids[3], in test_roundrobin_rx_burst_on_multiple_slaves()
1743 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[0], &expected_mac_addr_0), in test_roundrobin_verify_mac_assignment()
1745 test_params->slave_port_ids[0]); in test_roundrobin_verify_mac_assignment()
1746 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[2], &expected_mac_addr_2), in test_roundrobin_verify_mac_assignment()
1748 test_params->slave_port_ids[2]); in test_roundrobin_verify_mac_assignment()
1756 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1757 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1759 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1763 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1767 TEST_ASSERT_SUCCESS(rte_eth_bond_primary_set(test_params->bonded_port_id, in test_roundrobin_verify_mac_assignment()
1768 test_params->slave_port_ids[2]), in test_roundrobin_verify_mac_assignment()
1770 test_params->bonded_port_id, test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1772 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1773 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1775 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1780 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1785 TEST_ASSERT_SUCCESS(rte_eth_dev_stop(test_params->bonded_port_id), in test_roundrobin_verify_mac_assignment()
1787 test_params->bonded_port_id); in test_roundrobin_verify_mac_assignment()
1789 TEST_ASSERT_SUCCESS(rte_eth_dev_start(test_params->bonded_port_id), in test_roundrobin_verify_mac_assignment()
1792 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1794 test_params->bonded_port_id); in test_roundrobin_verify_mac_assignment()
1798 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1800 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1801 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1803 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1807 " port", test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1812 test_params->bonded_port_id, in test_roundrobin_verify_mac_assignment()
1816 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->bonded_port_id, &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1818 test_params->bonded_port_id); in test_roundrobin_verify_mac_assignment()
1822 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1824 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_mac_assignment()
1825 TEST_ASSERT_SUCCESS(rte_eth_macaddr_get(test_params->slave_port_ids[i], &read_mac_addr), in test_roundrobin_verify_mac_assignment()
1827 test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1830 " that of new primary port\n", test_params->slave_port_ids[i]); in test_roundrobin_verify_mac_assignment()
1848 ret = rte_eth_promiscuous_enable(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1851 test_params->bonded_port_id, rte_strerror(-ret)); in test_roundrobin_verify_promiscuous_enable_disable()
1853 promiscuous_en = rte_eth_promiscuous_get(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1856 test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1858 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_promiscuous_enable_disable()
1860 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1863 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1866 ret = rte_eth_promiscuous_disable(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1869 test_params->bonded_port_id, rte_strerror(-ret)); in test_roundrobin_verify_promiscuous_enable_disable()
1871 promiscuous_en = rte_eth_promiscuous_get(test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1874 test_params->bonded_port_id); in test_roundrobin_verify_promiscuous_enable_disable()
1876 for (i = 0; i < test_params->bonded_slave_count; i++) { in test_roundrobin_verify_promiscuous_enable_disable()
1878 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1881 test_params->slave_port_ids[i]); in test_roundrobin_verify_promiscuous_enable_disable()
1913 slave_count = rte_eth_bond_slaves_get(test_params->bonded_port_id, slaves, in test_roundrobin_verify_slave_link_status_change_behaviour()
1919 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_roundrobin_verify_slave_link_status_change_behaviour()
1927 test_params->slave_port_ids[1], 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1929 test_params->slave_port_ids[3], 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1931 slave_count = rte_eth_bond_active_slaves_get(test_params->bonded_port_id, in test_roundrobin_verify_slave_link_status_change_behaviour()
1951 rte_eth_stats_reset(test_params->bonded_port_id); in test_roundrobin_verify_slave_link_status_change_behaviour()
1955 rte_eth_tx_burst(test_params->bonded_port_id, 0, tx_pkt_burst, in test_roundrobin_verify_slave_link_status_change_behaviour()
1958 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1961 test_params->bonded_port_id, (int)port_stats.opackets, in test_roundrobin_verify_slave_link_status_change_behaviour()
1964 rte_eth_stats_get(test_params->slave_port_ids[0], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1967 test_params->slave_port_ids[0], (int)port_stats.opackets, 10); in test_roundrobin_verify_slave_link_status_change_behaviour()
1969 rte_eth_stats_get(test_params->slave_port_ids[1], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1972 test_params->slave_port_ids[1], (int)port_stats.opackets, 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1974 rte_eth_stats_get(test_params->slave_port_ids[2], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1977 test_params->slave_port_ids[2], (int)port_stats.opackets, 10); in test_roundrobin_verify_slave_link_status_change_behaviour()
1979 rte_eth_stats_get(test_params->slave_port_ids[3], &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
1982 test_params->slave_port_ids[3], (int)port_stats.opackets, 0); in test_roundrobin_verify_slave_link_status_change_behaviour()
1998 virtual_ethdev_add_mbufs_to_rx_queue(test_params->slave_port_ids[i], in test_roundrobin_verify_slave_link_status_change_behaviour()
2003 test_params->bonded_port_id, 0, rx_pkt_burst, MAX_PKT_BURST), in test_roundrobin_verify_slave_link_status_change_behaviour()
2008 rte_eth_stats_get(test_params->bonded_port_id, &port_stats); in test_roundrobin_verify_slave_link_status_change_behaviour()
2011 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()