88 #define	TTYINQ_INSERT_TAIL(ti, tib) do {				\  argument
89 	if (ti->ti_end == 0) {						\
91 		tib->tib_next = ti->ti_firstblock;			\
92 		ti->ti_firstblock = tib;				\
94 		tib->tib_prev = ti->ti_lastblock;			\
95 		tib->tib_next = ti->ti_lastblock->tib_next;		\
96 		ti->ti_lastblock->tib_next = tib;			\
100 	ti->ti_nblocks++;						\
103 #define	TTYINQ_REMOVE_HEAD(ti) do {					\  argument
104 	ti->ti_firstblock = ti->ti_firstblock->tib_next;		\
105 	if (ti->ti_firstblock != NULL)					\
106 		ti->ti_firstblock->tib_prev = NULL;			\
107 	ti->ti_nblocks--;						\
110 #define	TTYINQ_RECYCLE(ti, tib) do {					\  argument
111 	if (ti->ti_quota <= ti->ti_nblocks)				\
114 		TTYINQ_INSERT_TAIL(ti, tib);				\
118 ttyinq_setsize(struct ttyinq *ti, struct tty *tp, size_t size)  in ttyinq_setsize()  argument
122 	ti->ti_quota = howmany(size, TTYINQ_DATASIZE);  in ttyinq_setsize()
124 	while (ti->ti_quota > ti->ti_nblocks) {  in ttyinq_setsize()
144 		TTYINQ_INSERT_TAIL(ti, tib);  in ttyinq_setsize()
150 ttyinq_free(struct ttyinq *ti)  in ttyinq_free()  argument
154 	ttyinq_flush(ti);  in ttyinq_free()
155 	ti->ti_quota = 0;  in ttyinq_free()
157 	while ((tib = ti->ti_firstblock) != NULL) {  in ttyinq_free()
158 		TTYINQ_REMOVE_HEAD(ti);  in ttyinq_free()
162 	MPASS(ti->ti_nblocks == 0);  in ttyinq_free()
166 ttyinq_read_uio(struct ttyinq *ti, struct tty *tp, struct uio *uio,  in ttyinq_read_uio()  argument
178 		if (ti->ti_begin == ti->ti_linestart)  in ttyinq_read_uio()
180 		tib = ti->ti_firstblock;  in ttyinq_read_uio()
190 		cbegin = ti->ti_begin;  in ttyinq_read_uio()
191 		cend = MIN(MIN(ti->ti_linestart, ti->ti_begin + rlen),  in ttyinq_read_uio()
204 		if (cend == TTYINQ_DATASIZE || cend == ti->ti_end) {  in ttyinq_read_uio()
209 			TTYINQ_REMOVE_HEAD(ti);  in ttyinq_read_uio()
210 			ti->ti_begin = 0;  in ttyinq_read_uio()
222 			CORRECT_BLOCK(ti->ti_linestart);  in ttyinq_read_uio()
223 			CORRECT_BLOCK(ti->ti_reprint);  in ttyinq_read_uio()
224 			CORRECT_BLOCK(ti->ti_end);  in ttyinq_read_uio()
238 			TTYINQ_RECYCLE(ti, tib);  in ttyinq_read_uio()
246 			ti->ti_begin += clen;  in ttyinq_read_uio()
247 			MPASS(ti->ti_begin < TTYINQ_DATASIZE);  in ttyinq_read_uio()
281 ttyinq_write(struct ttyinq *ti, const void *buf, size_t nbytes, int quote)  in ttyinq_write()  argument
289 		boff = ti->ti_end % TTYINQ_DATASIZE;  in ttyinq_write()
291 		if (ti->ti_end == 0) {  in ttyinq_write()
293 			MPASS(ti->ti_begin == 0);  in ttyinq_write()
294 			tib = ti->ti_firstblock;  in ttyinq_write()
299 			ti->ti_lastblock = tib;  in ttyinq_write()
302 			tib = ti->ti_lastblock->tib_next;  in ttyinq_write()
307 			ti->ti_lastblock = tib;  in ttyinq_write()
309 			tib = ti->ti_lastblock;  in ttyinq_write()
322 		ti->ti_end += l;  in ttyinq_write()
329 ttyinq_write_nofrag(struct ttyinq *ti, const void *buf, size_t nbytes, int quote)  in ttyinq_write_nofrag()  argument
333 	if (ttyinq_bytesleft(ti) < nbytes)  in ttyinq_write_nofrag()
337 	ret = ttyinq_write(ti, buf, nbytes, quote);  in ttyinq_write_nofrag()
344 ttyinq_canonicalize(struct ttyinq *ti)  in ttyinq_canonicalize()  argument
347 	ti->ti_linestart = ti->ti_reprint = ti->ti_end;  in ttyinq_canonicalize()
348 	ti->ti_startblock = ti->ti_reprintblock = ti->ti_lastblock;  in ttyinq_canonicalize()
352 ttyinq_findchar(struct ttyinq *ti, const char *breakc, size_t maxlen,  in ttyinq_findchar()  argument
355 	struct ttyinq_block *tib = ti->ti_firstblock;  in ttyinq_findchar()
356 	unsigned int boff = ti->ti_begin;  in ttyinq_findchar()
357 	unsigned int bend = MIN(MIN(TTYINQ_DATASIZE, ti->ti_linestart),  in ttyinq_findchar()
358 	    ti->ti_begin + maxlen);  in ttyinq_findchar()
368 			return (boff - ti->ti_begin + 1);  in ttyinq_findchar()
374 	return (bend - ti->ti_begin);  in ttyinq_findchar()
378 ttyinq_flush(struct ttyinq *ti)  in ttyinq_flush()  argument
382 	ti->ti_begin = 0;  in ttyinq_flush()
383 	ti->ti_linestart = 0;  in ttyinq_flush()
384 	ti->ti_reprint = 0;  in ttyinq_flush()
385 	ti->ti_end = 0;  in ttyinq_flush()
389 		for (tib = ti->ti_firstblock; tib != NULL; tib = tib->tib_next)  in ttyinq_flush()
395 ttyinq_peekchar(struct ttyinq *ti, char *c, int *quote)  in ttyinq_peekchar()  argument
398 	struct ttyinq_block *tib = ti->ti_lastblock;  in ttyinq_peekchar()
400 	if (ti->ti_linestart == ti->ti_end)  in ttyinq_peekchar()
403 	MPASS(ti->ti_end > 0);  in ttyinq_peekchar()
404 	boff = (ti->ti_end - 1) % TTYINQ_DATASIZE;  in ttyinq_peekchar()
413 ttyinq_unputchar(struct ttyinq *ti)  in ttyinq_unputchar()  argument
416 	MPASS(ti->ti_linestart < ti->ti_end);  in ttyinq_unputchar()
418 	if (--ti->ti_end % TTYINQ_DATASIZE == 0) {  in ttyinq_unputchar()
420 		ti->ti_lastblock = ti->ti_lastblock->tib_prev;  in ttyinq_unputchar()
425 		MPASS((ti->ti_lastblock == NULL) == (ti->ti_end == 0));  in ttyinq_unputchar()
430 ttyinq_reprintpos_set(struct ttyinq *ti)  in ttyinq_reprintpos_set()  argument
433 	ti->ti_reprint = ti->ti_end;  in ttyinq_reprintpos_set()
434 	ti->ti_reprintblock = ti->ti_lastblock;  in ttyinq_reprintpos_set()
438 ttyinq_reprintpos_reset(struct ttyinq *ti)  in ttyinq_reprintpos_reset()  argument
441 	ti->ti_reprint = ti->ti_linestart;  in ttyinq_reprintpos_reset()
442 	ti->ti_reprintblock = ti->ti_startblock;  in ttyinq_reprintpos_reset()
446 ttyinq_line_iterate(struct ttyinq *ti,  in ttyinq_line_iterate()  argument
454 		tib = ti->ti_firstblock;  in ttyinq_line_iterate()
457 	for (; offset < ti->ti_end; offset++) {  in ttyinq_line_iterate()
472 ttyinq_line_iterate_from_linestart(struct ttyinq *ti,  in ttyinq_line_iterate_from_linestart()  argument
476 	ttyinq_line_iterate(ti, iterator, data,  in ttyinq_line_iterate_from_linestart()
477 	    ti->ti_linestart, ti->ti_startblock);  in ttyinq_line_iterate_from_linestart()
481 ttyinq_line_iterate_from_reprintpos(struct ttyinq *ti,  in ttyinq_line_iterate_from_reprintpos()  argument
485 	ttyinq_line_iterate(ti, iterator, data,  in ttyinq_line_iterate_from_reprintpos()
486 	    ti->ti_reprint, ti->ti_reprintblock);  in ttyinq_line_iterate_from_reprintpos()