189 static struct g_rr_params me = {  variable
190 	.sc_head = LIST_HEAD_INITIALIZER(&me.sc_head),
198 struct g_rr_params *gs_rr_me = &me;
204     &me.units, 0, "Scheduler instances");
206     &me.queues, 0, "Total rr queues");
208     &me.wait_ms.x_cur, 0, "Wait time milliseconds");
210     &me.quantum_ms.x_cur, 0, "Quantum size milliseconds");
212     &me.bypass, 0, "Bypass scheduler");
214     &me.w_anticipate, 0, "Do anticipation on writes");
216     &me.quantum_kb.x_cur, 0, "Quantum size Kbytes");
218     &me.queue_depth.x_cur, 0, "Maximum simultaneous requests");
220     &me.wait_hit, 0, "Hits in anticipation");
222     &me.wait_miss, 0, "Misses in anticipation");
256 	LIST_FOREACH(sc, &me.sc_head, sc_next) {  in gs_rr_sysctl_status()
327 	qp->q_budget = 1024 * get_bounded(&me.quantum_kb, 0);  in g_rr_init_class()
328 	qp->q_slice_duration = get_bounded(&me.quantum_ms, 2);  in g_rr_init_class()
329 	qp->q_wait_ticks = get_bounded(&me.wait_ms, 2);  in g_rr_init_class()
333 	me.queues++;  in g_rr_init_class()
356 	me.queues--;  in g_rr_fini_class()
376 	int wait = get_bounded(&me.wait_ms, 2);  in g_rr_should_anticipate()
378 	if (!me.w_anticipate && (bp->bio_cmd == BIO_WRITE))  in g_rr_should_anticipate()
405 	if (me.bypass == 0 && !force) {  in g_rr_next()
406 		if (sc->sc_in_flight >= get_bounded(&me.queue_depth, 0))  in g_rr_next()
489 	int delta = ticks - qp->q_lastsub, wait = get_bounded(&me.wait_ms, 2);  in g_rr_update_thinktime()
533 	if (me.bypass)  in g_rr_start()
586 		me.wait_hit--;  in g_rr_wait_timeout()
587 		me.wait_miss++;	/* record the miss */  in g_rr_wait_timeout()
606 	LIST_INSERT_HEAD(&me.sc_head, sc, sc_next);  in g_rr_init()
607 	me.units++;  in g_rr_init()
626 	me.units--;  in g_rr_fini()
657 		qp->q_slice_duration = get_bounded(&me.quantum_ms, 2);  in g_rr_done()
665 		qp->q_wait_ticks = get_bounded(&me.wait_ms, 2);  in g_rr_done()
666 		me.wait_hit++;  in g_rr_done()
682 			me.units, me.queues);  in g_rr_dumpconf()