Cross Reference: /src/sys/kern/bufq

Lines Matching defs:prio
111 	struct bufq_prio *prio = bufq_private(bufq);
121 		TAILQ_INSERT_TAIL(&prio->bq_read, bp, b_actq);
125 	bq = TAILQ_FIRST(&prio->bq_write);
131 		TAILQ_INSERT_TAIL(&prio->bq_write, bp, b_actq);
132 		prio->bq_write_next = bp;
139 	if (buf_inorder(prio->bq_write_next, bp, sortby))
140 		bq = prio->bq_write_next;
152 		TAILQ_INSERT_TAIL(&prio->bq_write, bp, b_actq);
158 	struct bufq_prio *prio = bufq_private(bufq);
164 	if (prio->bq_next == NULL) {
168 		if (TAILQ_FIRST(&prio->bq_read) == NULL) {
169 			prio->bq_next = prio->bq_write_next;
170 			prio->bq_read_burst = 0;
171 		} else if (prio->bq_write_next == NULL) {
172 			bp = prio->bq_next = TAILQ_FIRST(&prio->bq_read);
173 			prio->bq_read_burst = 0;
182 			if (prio->bq_read_burst++ < PRIO_READ_BURST)
183 				prio->bq_next = TAILQ_FIRST(&prio->bq_read);
184 			else if (prio->bq_read_burst <
186 				prio->bq_next = prio->bq_write_next;
188 				prio->bq_next = TAILQ_FIRST(&prio->bq_read);
189 				prio->bq_read_burst = 0;
194 	bp = prio->bq_next;
198 			TAILQ_REMOVE(&prio->bq_read, bp, b_actq);
202 			 * bp since it is actually prio->bq_write_next.
204 			prio->bq_write_next =
205 			    TAILQ_NEXT(prio->bq_write_next, b_actq);
206 			TAILQ_REMOVE(&prio->bq_write, bp, b_actq);
207 			if (prio->bq_write_next == NULL)
208 				prio->bq_write_next =
209 				    TAILQ_FIRST(&prio->bq_write);
212 		prio->bq_next = NULL;
221 	struct bufq_prio *prio = bufq_private(bufq);
225 	TAILQ_FOREACH(bq, &prio->bq_read, b_actq) {
227 			TAILQ_REMOVE(&prio->bq_read, bq, b_actq);
229 			prio->bq_next = NULL;
235 	TAILQ_FOREACH(bq, &prio->bq_write, b_actq) {
237 			if (bq == prio->bq_write_next) {
240 				 * bp since it is actually prio->bq_write_next.
242 				prio->bq_write_next =
243 				    TAILQ_NEXT(prio->bq_write_next, b_actq);
244 				TAILQ_REMOVE(&prio->bq_write, bq, b_actq);
245 				if (prio->bq_write_next == NULL)
246 					prio->bq_write_next =
247 					    TAILQ_FIRST(&prio->bq_write);
249 				TAILQ_REMOVE(&prio->bq_write, bq, b_actq);
252 			prio->bq_next = NULL;
272 	struct bufq_prio *prio;
279 	prio = (struct bufq_prio *)bufq->bq_private;
280 	TAILQ_INIT(&prio->bq_read);
281 	TAILQ_INIT(&prio->bq_write);
OpenGrok
