geom/sched/g_sched.c

185 static struct geom_sched_vars me = {
194     &me.gs_write_bytes_in_flight, 0, "Write bytes in flight");
197     &me.gs_bytes_in_flight, 0, "Bytes in flight");
200     &me.gs_writes_in_flight, 0, "Write Requests in flight");
203     &me.gs_in_flight, 0, "Requests in flight");
206     &me.gs_done, 0, "Total done");
209     &me.gs_requests, 0, "Total requests");
212     &me.gs_names, 0, "Algorithm names");
215     &me.gs_sched_count, 0, "Number of algorithms");
218     &me.gs_debug, 0, "Debug level");
221     &me.gs_expire_secs, 0, "Expire time in seconds");
269 	me.gs_done++;
270 	me.gs_in_flight--;
271 	me.gs_bytes_in_flight -= bio->bio_length;
273 		me.gs_writes_in_flight--;
274 		me.gs_write_bytes_in_flight -= bio->bio_length;
411 	gsc->gsc_expire = ticks + me.gs_expire_secs * hz;
426 	gsc->gsc_expire = ticks + me.gs_expire_secs * hz;
491 	sc->sc_flush_ticks = ticks + me.gs_expire_secs * hz;
576 	mtx_lock(&me.gs_mtx);
577 	LIST_FOREACH(gsp, &me.gs_scheds, glist) {
583 	mtx_unlock(&me.gs_mtx);
590  * To be called with me.gs_mtx lock held.
599 	LIST_FOREACH(cur, &me.gs_scheds, glist) {
601 		if (l + pos + 1 + 1 < sizeof(me.gs_names)) {
603 				me.gs_names[pos++] = ' ';
604 			strcpy(me.gs_names + pos, cur->gs_name);
608 	me.gs_names[pos] = '\0';
620 	mtx_lock(&me.gs_mtx);
621 	LIST_FOREACH(cur, &me.gs_scheds, glist) {
630 		LIST_INSERT_HEAD(&me.gs_scheds, gsp, glist);
632 		me.gs_sched_count++;
635 	mtx_unlock(&me.gs_mtx);
661 	mtx_lock(&me.gs_mtx);
675 	LIST_FOREACH_SAFE(cur, &me.gs_scheds, glist, tmp) {
685 			me.gs_sched_count--;
697 	mtx_unlock(&me.gs_mtx);
704 	if (!me.gs_initialized) {
706 		mtx_init(&me.gs_mtx, "gsched", NULL, MTX_DEF);
707 		LIST_INIT(&me.gs_scheds);
708 		gs_bioq_init(&me.gs_pending);
709 		me.gs_initialized = 1;
863 		cbp->bio_caller1 = &me;	/* anything not NULL */
869 	me.gs_in_flight++;
870 	me.gs_requests++;
871 	me.gs_bytes_in_flight += bp->bio_length;
873 		me.gs_writes_in_flight++;
874 		me.gs_write_bytes_in_flight += bp->bio_length;
915 	mtx_lock(&me.gs_mtx);
916 	me.gs_npending++;
917 	gs_bioq_disksort(&me.gs_pending, bio);
918 	mtx_unlock(&me.gs_mtx);
926 	while ((bp = gs_bioq_takefirst(&me.gs_pending)))
944 	me.gs_npending = 0;
948 	while (pp->nstart - pp->nend != me.gs_npending &&
952 	if (pp->nstart - pp->nend != me.gs_npending) {
1136  * requests to the me.gs_pending queue.
1155 		me.gs_npending = 0;
1204  * of issuing the pending requests collected in me.gs_pending (if any).
1468 	if (me.gs_patched)
1486 	me.gs_patched = 1;
1499 	if (me.gs_patched) {
1502 		me.gs_patched = 0;
1578 	KASSERT(LIST_EMPTY(&me.gs_scheds), ("still registered schedulers"));
1579 	mtx_destroy(&me.gs_mtx);