36#include <sys/kernel.h>
39#include <sys/sysctl.h>
67SYSCTL_INT(_kern, OID_AUTO, tty_inq_flush_secure, CTLFLAG_RW,
70#define TTYINQ_QUOTESIZE (TTYINQ_DATASIZE / BMSIZE)
72#define GETBIT(tib,boff) \
73 ((tib)->tib_quotes[(boff) / BMSIZE] & (1 << ((boff) % BMSIZE)))
74#define SETBIT(tib,boff) \
75 ((tib)->tib_quotes[(boff) / BMSIZE] |= (1 << ((boff) % BMSIZE)))
76#define CLRBIT(tib,boff) \
77 ((tib)->tib_quotes[(boff) / BMSIZE] &= ~(1 << ((boff) % BMSIZE)))
88#define TTYINQ_INSERT_TAIL(ti, tib) do { \
89 if (ti->ti_end == 0) { \
90 tib->tib_prev = NULL; \
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; \
98 if (tib->tib_next != NULL) \
99 tib->tib_next->tib_prev = tib; \
103#define TTYINQ_REMOVE_HEAD(ti) do { \
104 ti->ti_firstblock = ti->ti_firstblock->tib_next; \
105 if (ti->ti_firstblock != NULL) \
106 ti->ti_firstblock->tib_prev = NULL; \
110#define TTYINQ_RECYCLE(ti, tib) do { \
111 if (ti->ti_quota <= ti->ti_nblocks) \
112 uma_zfree(ttyinq_zone, tib); \
114 TTYINQ_INSERT_TAIL(ti, tib); \
122 ti->ti_quota = howmany(size, TTYINQ_DATASIZE);
124 while (ti->ti_quota > ti->ti_nblocks) {
157 while ((tib = ti->ti_firstblock) != NULL) {
162 MPASS(ti->ti_nblocks == 0);
167 size_t rlen,
size_t flen)
170 MPASS(rlen <= uio->uio_resid);
175 size_t cbegin, cend, clen;
178 if (ti->ti_begin == ti->ti_linestart)
180 tib = ti->ti_firstblock;
190 cbegin = ti->ti_begin;
191 cend = MIN(MIN(ti->ti_linestart, ti->ti_begin + rlen),
193 clen = cend - cbegin;
204 if (cend == TTYINQ_DATASIZE || cend == ti->ti_end) {
216#define CORRECT_BLOCK(t) do { \
217 if (t <= TTYINQ_DATASIZE) \
220 t -= TTYINQ_DATASIZE; \
240 char ob[TTYINQ_DATASIZE - 1];
245 memcpy(ob, tib->
tib_data + cbegin, clen - flen);
246 ti->ti_begin += clen;
247 MPASS(ti->ti_begin < TTYINQ_DATASIZE);
251 error =
uiomove(ob, clen - flen, uio);
266 size_t length,
int value)
271 for (; length > 0; length--, offset++)
275 for (; length > 0; length--, offset++)
283 const char *cbuf =
buf;
289 boff = ti->ti_end % TTYINQ_DATASIZE;
291 if (ti->ti_end == 0) {
293 MPASS(ti->ti_begin == 0);
294 tib = ti->ti_firstblock;
299 ti->ti_lastblock = tib;
300 }
else if (boff == 0) {
307 ti->ti_lastblock = tib;
309 tib = ti->ti_lastblock;
313 l = MIN(
nbytes, TTYINQ_DATASIZE - boff);
315 memcpy(tib->
tib_data + boff, cbuf, l);
325 return (cbuf - (
const char *)
buf);
333 if (ttyinq_bytesleft(ti) <
nbytes)
347 ti->ti_linestart = ti->ti_reprint = ti->ti_end;
348 ti->ti_startblock = ti->ti_reprintblock = ti->ti_lastblock;
356 unsigned int boff = ti->ti_begin;
357 unsigned int bend = MIN(MIN(TTYINQ_DATASIZE, ti->ti_linestart),
358 ti->ti_begin + maxlen);
365 while (boff < bend) {
368 return (boff - ti->ti_begin + 1);
374 return (bend - ti->ti_begin);
383 ti->ti_linestart = 0;
389 for (tib = ti->ti_firstblock; tib != NULL; tib = tib->
tib_next)
400 if (ti->ti_linestart == ti->ti_end)
403 MPASS(ti->ti_end > 0);
404 boff = (ti->ti_end - 1) % TTYINQ_DATASIZE;
407 *quote =
GETBIT(tib, boff);
416 MPASS(ti->ti_linestart < ti->ti_end);
418 if (--ti->ti_end % TTYINQ_DATASIZE == 0) {
420 ti->ti_lastblock = ti->ti_lastblock->tib_prev;
425 MPASS((ti->ti_lastblock == NULL) == (ti->ti_end == 0));
433 ti->ti_reprint = ti->ti_end;
434 ti->ti_reprintblock = ti->ti_lastblock;
441 ti->ti_reprint = ti->ti_linestart;
442 ti->ti_reprintblock = ti->ti_startblock;
447 ttyinq_line_iterator_t *iterator,
void *
data,
454 tib = ti->ti_firstblock;
457 for (; offset < ti->ti_end; offset++) {
458 boff = offset % TTYINQ_DATASIZE;
465 if (boff == TTYINQ_DATASIZE - 1)
473 ttyinq_line_iterator_t *iterator,
void *
data)
477 ti->ti_linestart, ti->ti_startblock);
482 ttyinq_line_iterator_t *iterator,
void *
data)
486 ti->ti_reprint, ti->ti_reprintblock);
494 NULL, NULL, NULL, NULL, UMA_ALIGN_PTR, 0);
char tib_data[TTYINQ_DATASIZE]
struct ttyinq_block * tib_prev
uint32_t tib_quotes[TTYINQ_QUOTESIZE]
struct ttyinq_block * tib_next
int uiomove(void *cp, int n, struct uio *uio)
SYSINIT(ttyinq, SI_SUB_DRIVERS, SI_ORDER_FIRST, ttyinq_startup, NULL)
void ttyinq_canonicalize(struct ttyinq *ti)
size_t ttyinq_write(struct ttyinq *ti, const void *buf, size_t nbytes, int quote)
int ttyinq_setsize(struct ttyinq *ti, struct tty *tp, size_t size)
#define TTYINQ_REMOVE_HEAD(ti)
SYSCTL_INT(_kern, OID_AUTO, tty_inq_flush_secure, CTLFLAG_RW, &ttyinq_flush_secure, 0, "Zero buffers while flushing")
void ttyinq_free(struct ttyinq *ti)
void ttyinq_flush(struct ttyinq *ti)
#define SETBIT(tib, boff)
int ttyinq_peekchar(struct ttyinq *ti, char *c, int *quote)
int ttyinq_read_uio(struct ttyinq *ti, struct tty *tp, struct uio *uio, size_t rlen, size_t flen)
static uma_zone_t ttyinq_zone
#define CLRBIT(tib, boff)
static void ttyinq_startup(void *dummy)
int ttyinq_write_nofrag(struct ttyinq *ti, const void *buf, size_t nbytes, int quote)
void ttyinq_line_iterate_from_linestart(struct ttyinq *ti, ttyinq_line_iterator_t *iterator, void *data)
void ttyinq_reprintpos_reset(struct ttyinq *ti)
static __inline void ttyinq_set_quotes(struct ttyinq_block *tib, size_t offset, size_t length, int value)
void ttyinq_unputchar(struct ttyinq *ti)
#define TTYINQ_RECYCLE(ti, tib)
void ttyinq_reprintpos_set(struct ttyinq *ti)
size_t ttyinq_findchar(struct ttyinq *ti, const char *breakc, size_t maxlen, char *lastc)
void ttyinq_line_iterate_from_reprintpos(struct ttyinq *ti, ttyinq_line_iterator_t *iterator, void *data)
#define TTYINQ_INSERT_TAIL(ti, tib)
static int ttyinq_flush_secure
static void ttyinq_line_iterate(struct ttyinq *ti, ttyinq_line_iterator_t *iterator, void *data, unsigned int offset, struct ttyinq_block *tib)
#define GETBIT(tib, boff)