Lines Matching refs:tqueue
69 struct test_queue *tqueue; /**< Test structure for RTE_RED Queues */ member
268 *tcfg->tqueue->q = 0; in test_rte_red_init()
428 .tqueue = &ft_tqueue,
457 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test1()
462 tcfg->tqueue->rdata, in func_test1()
463 tcfg->tqueue->q, in func_test1()
465 tcfg->tqueue->q_ramp_up) != 0) { in func_test1()
471 tcfg->tqueue->rdata, in func_test1()
472 tcfg->tqueue->q, in func_test1()
474 tcfg->tqueue->avg_ramp_up) != 0) { in func_test1()
480 tcfg->tqueue->rdata, in func_test1()
481 tcfg->tqueue->q, in func_test1()
486 avg = rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test1()
495 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in func_test1()
507 (double)tcfg->tqueue->drop_tolerance); in func_test1()
545 .tqueue = &ft_tqueue,
562 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test2()
565 tcfg->tqueue->rdata, in func_test2()
566 tcfg->tqueue->q, in func_test2()
568 tcfg->tqueue->q_ramp_up) != 0) { in func_test2()
574 tcfg->tqueue->rdata, in func_test2()
575 tcfg->tqueue->q, in func_test2()
577 tcfg->tqueue->avg_ramp_up) != 0) { in func_test2()
593 tcfg->tqueue->rdata, in func_test2()
594 tcfg->tqueue->q, in func_test2()
599 avg = rte_red_get_avg_int(&tcfg->tconfig->rconfig[i], tcfg->tqueue->rdata); in func_test2()
606 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in func_test2()
618 (double)tcfg->tqueue->drop_tolerance); in func_test2()
652 .tqueue = &ft_tqueue,
669 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test3()
672 tcfg->tqueue->rdata, in func_test3()
673 tcfg->tqueue->q, in func_test3()
675 tcfg->tqueue->q_ramp_up) != 0) { in func_test3()
681 tcfg->tqueue->rdata, in func_test3()
682 tcfg->tqueue->q, in func_test3()
684 tcfg->tqueue->avg_ramp_up) != 0) { in func_test3()
697 avg_before = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test3()
702 *tcfg->tqueue->q = 0; in func_test3()
703 rte_red_mark_queue_empty(tcfg->tqueue->rdata, get_port_ts()); in func_test3()
711 tcfg->tqueue->rdata, in func_test3()
712 *tcfg->tqueue->q, in func_test3()
714 (*tcfg->tqueue->q)++; in func_test3()
724 tcfg->tqueue->rdata); in func_test3()
725 if (!check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in func_test3()
730 (double)tcfg->tqueue->avg_tolerance, in func_test3()
731 diff <= (double)tcfg->tqueue->avg_tolerance ? "pass" : "fail"); in func_test3()
779 .tqueue = &ft4_tqueue,
801 rte_red_rt_data_init(tcfg->tqueue->rdata); in func_test4()
804 tcfg->tqueue->rdata, in func_test4()
805 tcfg->tqueue->q, in func_test4()
807 tcfg->tqueue->q_ramp_up) != 0) { in func_test4()
813 tcfg->tqueue->rdata, in func_test4()
814 tcfg->tqueue->q, in func_test4()
816 tcfg->tqueue->avg_ramp_up) != 0) { in func_test4()
823 avg_before = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test4()
828 *tcfg->tqueue->q = 0; in func_test4()
829 rte_red_mark_queue_empty(tcfg->tqueue->rdata, get_port_ts()); in func_test4()
842 tcfg->tqueue->rdata, in func_test4()
843 *tcfg->tqueue->q, in func_test4()
848 (*tcfg->tqueue->q)++; in func_test4()
867 avg_after = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in func_test4()
868 if (!check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in func_test4()
873 diff, (double)tcfg->tqueue->avg_tolerance, in func_test4()
874 diff <= (double)tcfg->tqueue->avg_tolerance ? "pass" : "fail"); in func_test4()
939 .tqueue = &ft5_tqueue,
958 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test5()
959 rte_red_rt_data_init(&tcfg->tqueue->rdata[j]); in func_test5()
960 tcfg->tqueue->q[j] = 0; in func_test5()
962 if (increase_actual_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
963 &tcfg->tqueue->rdata[j], in func_test5()
964 &tcfg->tqueue->q[j], in func_test5()
966 tcfg->tqueue->q_ramp_up) != 0) { in func_test5()
971 if (increase_average_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
972 &tcfg->tqueue->rdata[j], in func_test5()
973 &tcfg->tqueue->q[j], in func_test5()
975 tcfg->tqueue->avg_ramp_up) != 0) { in func_test5()
981 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test5()
990 enqueue_dequeue_func(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
991 &tcfg->tqueue->rdata[j], in func_test5()
992 &tcfg->tqueue->q[j], in func_test5()
997 avg = rte_red_get_avg_int(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test5()
998 &tcfg->tqueue->rdata[j]); in func_test5()
1004 tcfg->tconfig->maxp_inv[tcfg->tqueue->qconfig[j]], in func_test5()
1006 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in func_test5()
1010 j, tcfg->tqueue->qconfig[j], avg, in func_test5()
1013 diff, (double)tcfg->tqueue->drop_tolerance); in func_test5()
1066 .tqueue = &ft6_tqueue,
1083 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test6()
1084 rte_red_rt_data_init(&tcfg->tqueue->rdata[j]); in func_test6()
1085 tcfg->tqueue->q[j] = 0; in func_test6()
1087 if (increase_actual_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1088 &tcfg->tqueue->rdata[j], in func_test6()
1089 &tcfg->tqueue->q[j], in func_test6()
1091 tcfg->tqueue->q_ramp_up) != 0) { in func_test6()
1095 if (increase_average_qsize(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1096 &tcfg->tqueue->rdata[j], in func_test6()
1097 &tcfg->tqueue->q[j], in func_test6()
1099 tcfg->tqueue->avg_ramp_up) != 0) { in func_test6()
1104 for (j = 0; j < tcfg->tqueue->num_queues; j++) { in func_test6()
1110 avg_before = rte_red_get_avg_float(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1111 &tcfg->tqueue->rdata[j]); in func_test6()
1116 tcfg->tqueue->q[j] = 0; in func_test6()
1117 rte_red_mark_queue_empty(&tcfg->tqueue->rdata[j], get_port_ts()); in func_test6()
1123 if (rte_red_enqueue(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1124 &tcfg->tqueue->rdata[j], in func_test6()
1125 tcfg->tqueue->q[j], in func_test6()
1127 tcfg->tqueue->q[j]++; in func_test6()
1134 (1 << tcfg->tconfig->wq_log2[tcfg->tqueue->qconfig[j]]), in func_test6()
1136 avg_after = rte_red_get_avg_float(&tcfg->tconfig->rconfig[tcfg->tqueue->qconfig[j]], in func_test6()
1137 &tcfg->tqueue->rdata[j]); in func_test6()
1138 if (!check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in func_test6()
1142 j, tcfg->tqueue->qconfig[j], avg_before, avg_after, in func_test6()
1143 exp_avg, diff, (double)tcfg->tqueue->avg_tolerance, in func_test6()
1144 diff <= tcfg->tqueue->avg_tolerance ? "pass" : "fail"); in func_test6()
1236 .tqueue = &pt_tqueue,
1247 .tqueue = &pt_tqueue,
1258 .tqueue = &pt_tqueue,
1285 *tcfg->tqueue->q = *tcfg->tlevel; in perf1_test()
1290 rte_red_rt_data_init(tcfg->tqueue->rdata); in perf1_test()
1295 rte_red_set_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, *tcfg->tlevel); in perf1_test()
1296 if (rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata) in perf1_test()
1303 tcfg->tqueue->rdata, in perf1_test()
1304 tcfg->tqueue->q, in perf1_test()
1352 .tqueue = &pt_tqueue,
1371 .tqueue = &pt_tqueue,
1390 .tqueue = &pt_tqueue,
1426 *tcfg->tqueue->q = *tcfg->tlevel; in perf2_test()
1427 count = (*tcfg->tqueue->rdata).count; in perf2_test()
1432 rte_red_rt_data_init(tcfg->tqueue->rdata); in perf2_test()
1433 (*tcfg->tqueue->rdata).count = count; in perf2_test()
1438 rte_red_set_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, *tcfg->tlevel); in perf2_test()
1439 avg_before = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in perf2_test()
1448 *tcfg->tqueue->q = 0; in perf2_test()
1449 rte_red_mark_queue_empty(tcfg->tqueue->rdata, get_port_ts()); in perf2_test()
1461 ret = rte_red_enqueue(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, in perf2_test()
1462 *tcfg->tqueue->q, ts ); in perf2_test()
1483 avg_after = rte_red_get_avg_float(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in perf2_test()
1487 if (check_avg(&diff, avg_after, exp_avg, (double)tcfg->tqueue->avg_tolerance)) in perf2_test()
1491 (double)tcfg->tqueue->avg_tolerance, ok ? "pass" : "fail"); in perf2_test()
1584 .tqueue = &ovfl_tqueue,
1610 rte_red_rt_data_init(tcfg->tqueue->rdata); in ovfl_test1()
1615 for (i = 0; i < tcfg->tqueue->q_ramp_up; i++) { in ovfl_test1()
1616 ret = rte_red_enqueue(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, in ovfl_test1()
1617 *tcfg->tqueue->q, get_port_ts()); in ovfl_test1()
1620 if (++(*tcfg->tqueue->q) >= *tcfg->tlevel) in ovfl_test1()
1628 for (i = 0; i < tcfg->tqueue->avg_ramp_up; i++) { in ovfl_test1()
1629 ret = rte_red_enqueue(tcfg->tconfig->rconfig, tcfg->tqueue->rdata, in ovfl_test1()
1630 *tcfg->tqueue->q, get_port_ts()); in ovfl_test1()
1631 ovfl_check_avg((*tcfg->tqueue->rdata).avg); in ovfl_test1()
1632 avg = rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in ovfl_test1()
1644 avg = rte_red_get_avg_int(tcfg->tconfig->rconfig, tcfg->tqueue->rdata); in ovfl_test1()
1658 if (!check_drop_rate(&diff, drop_rate, drop_prob, (double)tcfg->tqueue->drop_tolerance)) in ovfl_test1()