sys/kern/tty_inq.c

86 #define	TTYINQ_INSERT_TAIL(ti, tib) do {				\
87 	if (ti->ti_end == 0) {						\
89 		tib->tib_next = ti->ti_firstblock;			\
90 		ti->ti_firstblock = tib;				\
92 		tib->tib_prev = ti->ti_lastblock;			\
93 		tib->tib_next = ti->ti_lastblock->tib_next;		\
94 		ti->ti_lastblock->tib_next = tib;			\
98 	ti->ti_nblocks++;						\
101 #define	TTYINQ_REMOVE_HEAD(ti) do {					\
102 	ti->ti_firstblock = ti->ti_firstblock->tib_next;		\
103 	if (ti->ti_firstblock != NULL)					\
104 		ti->ti_firstblock->tib_prev = NULL;			\
105 	ti->ti_nblocks--;						\
108 #define	TTYINQ_RECYCLE(ti, tib) do {					\
109 	if (ti->ti_quota <= ti->ti_nblocks)				\
112 		TTYINQ_INSERT_TAIL(ti, tib);				\
116 ttyinq_setsize(struct ttyinq *ti, struct tty *tp, size_t size)
120 	ti->ti_quota = howmany(size, TTYINQ_DATASIZE);
122 	while (ti->ti_quota > ti->ti_nblocks) {
137 		TTYINQ_INSERT_TAIL(ti, tib);
142 ttyinq_free(struct ttyinq *ti)
146 	ttyinq_flush(ti);
147 	ti->ti_quota = 0;
149 	while ((tib = ti->ti_firstblock) != NULL) {
150 		TTYINQ_REMOVE_HEAD(ti);
154 	MPASS(ti->ti_nblocks == 0);
158 ttyinq_read_uio(struct ttyinq *ti, struct tty *tp, struct uio *uio,
170 		if (ti->ti_begin == ti->ti_linestart)
172 		tib = ti->ti_firstblock;
182 		cbegin = ti->ti_begin;
183 		cend = MIN(MIN(ti->ti_linestart, ti->ti_begin + rlen),
196 		if (cend == TTYINQ_DATASIZE || cend == ti->ti_end) {
201 			TTYINQ_REMOVE_HEAD(ti);
202 			ti->ti_begin = 0;
214 			CORRECT_BLOCK(ti->ti_linestart);
215 			CORRECT_BLOCK(ti->ti_reprint);
216 			CORRECT_BLOCK(ti->ti_end);
230 			TTYINQ_RECYCLE(ti, tib);
238 			ti->ti_begin += clen;
239 			MPASS(ti->ti_begin < TTYINQ_DATASIZE);
273 ttyinq_write(struct ttyinq *ti, const void *buf, size_t nbytes, int quote)
281 		boff = ti->ti_end % TTYINQ_DATASIZE;
283 		if (ti->ti_end == 0) {
285 			MPASS(ti->ti_begin == 0);
286 			tib = ti->ti_firstblock;
291 			ti->ti_lastblock = tib;
294 			tib = ti->ti_lastblock->tib_next;
299 			ti->ti_lastblock = tib;
301 			tib = ti->ti_lastblock;
314 		ti->ti_end += l;
321 ttyinq_write_nofrag(struct ttyinq *ti, const void *buf, size_t nbytes, int quote)
325 	if (ttyinq_bytesleft(ti) < nbytes)
329 	ret = ttyinq_write(ti, buf, nbytes, quote);
336 ttyinq_canonicalize(struct ttyinq *ti)
339 	ti->ti_linestart = ti->ti_reprint = ti->ti_end;
340 	ti->ti_startblock = ti->ti_reprintblock = ti->ti_lastblock;
344 ttyinq_findchar(struct ttyinq *ti, const char *breakc, size_t maxlen,
347 	struct ttyinq_block *tib = ti->ti_firstblock;
348 	unsigned int boff = ti->ti_begin;
349 	unsigned int bend = MIN(MIN(TTYINQ_DATASIZE, ti->ti_linestart),
350 	    ti->ti_begin + maxlen);
360 			return (boff - ti->ti_begin + 1);
366 	return (bend - ti->ti_begin);
370 ttyinq_flush(struct ttyinq *ti)
374 	ti->ti_begin = 0;
375 	ti->ti_linestart = 0;
376 	ti->ti_reprint = 0;
377 	ti->ti_end = 0;
381 		for (tib = ti->ti_firstblock; tib != NULL; tib = tib->tib_next)
387 ttyinq_peekchar(struct ttyinq *ti, char *c, int *quote)
390 	struct ttyinq_block *tib = ti->ti_lastblock;
392 	if (ti->ti_linestart == ti->ti_end)
395 	MPASS(ti->ti_end > 0);
396 	boff = (ti->ti_end - 1) % TTYINQ_DATASIZE;
405 ttyinq_unputchar(struct ttyinq *ti)
408 	MPASS(ti->ti_linestart < ti->ti_end);
410 	if (--ti->ti_end % TTYINQ_DATASIZE == 0) {
412 		ti->ti_lastblock = ti->ti_lastblock->tib_prev;
417 		MPASS((ti->ti_lastblock == NULL) == (ti->ti_end == 0));
422 ttyinq_reprintpos_set(struct ttyinq *ti)
425 	ti->ti_reprint = ti->ti_end;
426 	ti->ti_reprintblock = ti->ti_lastblock;
430 ttyinq_reprintpos_reset(struct ttyinq *ti)
433 	ti->ti_reprint = ti->ti_linestart;
434 	ti->ti_reprintblock = ti->ti_startblock;
438 ttyinq_line_iterate(struct ttyinq *ti,
446 		tib = ti->ti_firstblock;
449 	for (; offset < ti->ti_end; offset++) {
464 ttyinq_line_iterate_from_linestart(struct ttyinq *ti,
468 	ttyinq_line_iterate(ti, iterator, data,
469 	    ti->ti_linestart, ti->ti_startblock);
473 ttyinq_line_iterate_from_reprintpos(struct ttyinq *ti,
477 	ttyinq_line_iterate(ti, iterator, data,
478 	    ti->ti_reprint, ti->ti_reprintblock);