Lines Matching refs:tqueue
93 struct test_queue *tqueue; /**< Test structure for RTE_RED Queues */ member
292 *tcfg->tqueue->q = 0; in test_rte_red_init()
452 .tqueue = &ft_tqueue,
481 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test1()
486 tcfg->tqueue->rdata, in func_test1()
487 tcfg->tqueue->q, in func_test1()
489 tcfg->tqueue->q_ramp_up) != 0) { in func_test1()
495 tcfg->tqueue->rdata, in func_test1()
496 tcfg->tqueue->q, in func_test1()
498 tcfg->tqueue->avg_ramp_up) != 0) { in func_test1()
504 tcfg->tqueue->rdata, in func_test1()
505 tcfg->tqueue->q, in func_test1()
510 avg = rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test1()
519 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in func_test1()
531 (double)tcfg->tqueue->drop_tolerance); in func_test1()
569 .tqueue = &ft_tqueue,
586 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test2()
589 tcfg->tqueue->rdata, in func_test2()
590 tcfg->tqueue->q, in func_test2()
592 tcfg->tqueue->q_ramp_up) != 0) { in func_test2()
598 tcfg->tqueue->rdata, in func_test2()
599 tcfg->tqueue->q, in func_test2()
601 tcfg->tqueue->avg_ramp_up) != 0) { in func_test2()
617 tcfg->tqueue->rdata, in func_test2()
618 tcfg->tqueue->q, in func_test2()
623 avg = rte_red_get_avg_int(&tcfg->tconfig->rconfig[i], tcfg->tqueue->rdata); in func_test2()
630 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in func_test2()
642 (double)tcfg->tqueue->drop_tolerance); in func_test2()
676 .tqueue = &ft_tqueue,
693 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test3()
696 tcfg->tqueue->rdata, in func_test3()
697 tcfg->tqueue->q, in func_test3()
699 tcfg->tqueue->q_ramp_up) != 0) { in func_test3()
705 tcfg->tqueue->rdata, in func_test3()
706 tcfg->tqueue->q, in func_test3()
708 tcfg->tqueue->avg_ramp_up) != 0) { in func_test3()
721 avg_before = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test3()
726 *tcfg->tqueue->q = 0; in func_test3()
727 rte_red_mark_queue_empty(tcfg->tqueue->rdata, get_port_ts()); in func_test3()
735 tcfg->tqueue->rdata, in func_test3()
736 *tcfg->tqueue->q, in func_test3()
738 (*tcfg->tqueue->q)++; in func_test3()
748 tcfg->tqueue->rdata); in func_test3()
749 if (!check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in func_test3()
754 (double)tcfg->tqueue->avg_tolerance, in func_test3()
755 diff <= (double)tcfg->tqueue->avg_tolerance ? "pass" : "fail"); in func_test3()
803 .tqueue = &ft4_tqueue,
825 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test4()
828 tcfg->tqueue->rdata, in func_test4()
829 tcfg->tqueue->q, in func_test4()
831 tcfg->tqueue->q_ramp_up) != 0) { in func_test4()
837 tcfg->tqueue->rdata, in func_test4()
838 tcfg->tqueue->q, in func_test4()
840 tcfg->tqueue->avg_ramp_up) != 0) { in func_test4()
847 avg_before = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test4()
852 *tcfg->tqueue->q = 0; in func_test4()
853 rte_red_mark_queue_empty(tcfg->tqueue->rdata, get_port_ts()); in func_test4()
866 tcfg->tqueue->rdata, in func_test4()
867 *tcfg->tqueue->q, in func_test4()
872 (*tcfg->tqueue->q)++; in func_test4()
891 avg_after = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test4()
892 if (!check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in func_test4()
897 diff, (double)tcfg->tqueue->avg_tolerance, in func_test4()
898 diff <= (double)tcfg->tqueue->avg_tolerance ? "pass" : "fail"); in func_test4()
963 .tqueue = &ft5_tqueue,
982 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test5()
983 rte_red_rt_data_init(&tcfg->tqueue->rdata[j]); in func_test5()
984 tcfg->tqueue->q[j] = 0; in func_test5()
986 if (increase_actual_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
987 &tcfg->tqueue->rdata[j], in func_test5()
988 &tcfg->tqueue->q[j], in func_test5()
990 tcfg->tqueue->q_ramp_up) != 0) { in func_test5()
995 if (increase_average_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
996 &tcfg->tqueue->rdata[j], in func_test5()
997 &tcfg->tqueue->q[j], in func_test5()
999 tcfg->tqueue->avg_ramp_up) != 0) { in func_test5()
1005 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test5()
1014 enqueue_dequeue_func(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
1015 &tcfg->tqueue->rdata[j], in func_test5()
1016 &tcfg->tqueue->q[j], in func_test5()
1021 avg = rte_red_get_avg_int(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
1022 &tcfg->tqueue->rdata[j]); in func_test5()
1028 tcfg->tconfig->maxp_inv[tcfg->tqueue->qconfig[j]], in func_test5()
1030 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in func_test5()
1034 j, tcfg->tqueue->qconfig[j], avg, in func_test5()
1037 diff, (double)tcfg->tqueue->drop_tolerance); in func_test5()
1090 .tqueue = &ft6_tqueue,
1107 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test6()
1108 rte_red_rt_data_init(&tcfg->tqueue->rdata[j]); in func_test6()
1109 tcfg->tqueue->q[j] = 0; in func_test6()
1111 if (increase_actual_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1112 &tcfg->tqueue->rdata[j], in func_test6()
1113 &tcfg->tqueue->q[j], in func_test6()
1115 tcfg->tqueue->q_ramp_up) != 0) { in func_test6()
1119 if (increase_average_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1120 &tcfg->tqueue->rdata[j], in func_test6()
1121 &tcfg->tqueue->q[j], in func_test6()
1123 tcfg->tqueue->avg_ramp_up) != 0) { in func_test6()
1128 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test6()
1134 avg_before = rte_red_get_avg_float(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1135 &tcfg->tqueue->rdata[j]); in func_test6()
1140 tcfg->tqueue->q[j] = 0; in func_test6()
1141 rte_red_mark_queue_empty(&tcfg->tqueue->rdata[j], get_port_ts()); in func_test6()
1147 if (rte_red_enqueue(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1148 &tcfg->tqueue->rdata[j], in func_test6()
1149 tcfg->tqueue->q[j], in func_test6()
1151 tcfg->tqueue->q[j]++; in func_test6()
1158 (1 << tcfg->tconfig->wq_log2[tcfg->tqueue->qconfig[j]]), in func_test6()
1160 avg_after = rte_red_get_avg_float(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1161 &tcfg->tqueue->rdata[j]); in func_test6()
1162 if (!check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in func_test6()
1166 j, tcfg->tqueue->qconfig[j], avg_before, avg_after, in func_test6()
1167 exp_avg, diff, (double)tcfg->tqueue->avg_tolerance, in func_test6()
1168 diff <= tcfg->tqueue->avg_tolerance ? "pass" : "fail"); in func_test6()
1260 .tqueue = &pt_tqueue,
1271 .tqueue = &pt_tqueue,
1282 .tqueue = &pt_tqueue,
1309 *tcfg->tqueue->q = *tcfg->tlevel; in perf1_test()
1314 rte_red_rt_data_init(tcfg->tqueue->rdata); in perf1_test()
1319 rte_red_set_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, *tcfg->tlevel); in perf1_test()
1320 if (rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata) in perf1_test()
1327 tcfg->tqueue->rdata, in perf1_test()
1328 tcfg->tqueue->q, in perf1_test()
1376 .tqueue = &pt_tqueue,
1395 .tqueue = &pt_tqueue,
1414 .tqueue = &pt_tqueue,
1450 *tcfg->tqueue->q = *tcfg->tlevel; in perf2_test()
1451 count = (*tcfg->tqueue->rdata).count; in perf2_test()
1456 rte_red_rt_data_init(tcfg->tqueue->rdata); in perf2_test()
1457 (*tcfg->tqueue->rdata).count = count; in perf2_test()
1462 rte_red_set_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, *tcfg->tlevel); in perf2_test()
1463 avg_before = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in perf2_test()
1472 *tcfg->tqueue->q = 0; in perf2_test()
1473 rte_red_mark_queue_empty(tcfg->tqueue->rdata, get_port_ts()); in perf2_test()
1485 ret = rte_red_enqueue(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, in perf2_test()
1486 *tcfg->tqueue->q, ts ); in perf2_test()
1507 avg_after = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in perf2_test()
1511 if (check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in perf2_test()
1515 (double)tcfg->tqueue->avg_tolerance, ok ? "pass" : "fail"); in perf2_test()
1608 .tqueue = &ovfl_tqueue,
1634 rte_red_rt_data_init(tcfg->tqueue->rdata); in ovfl_test1()
1639 for (i = 0; i < tcfg->tqueue->q_ramp_up; i++) { in ovfl_test1()
1640 ret = rte_red_enqueue(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, in ovfl_test1()
1641 *tcfg->tqueue->q, get_port_ts()); in ovfl_test1()
1644 if (++(*tcfg->tqueue->q) >= *tcfg->tlevel) in ovfl_test1()
1652 for (i = 0; i < tcfg->tqueue->avg_ramp_up; i++) { in ovfl_test1()
1653 ret = rte_red_enqueue(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, in ovfl_test1()
1654 *tcfg->tqueue->q, get_port_ts()); in ovfl_test1()
1655 ovfl_check_avg((*tcfg->tqueue->rdata).avg); in ovfl_test1()
1656 avg = rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in ovfl_test1()
1668 avg = rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in ovfl_test1()
1682 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in ovfl_test1()