ttyqueue.h revision 256281
1/*-
2 * Copyright (c) 2008 Ed Schouten <ed@FreeBSD.org>
3 * All rights reserved.
4 *
5 * Portions of this software were developed under sponsorship from Snow
6 * B.V., the Netherlands.
7 *
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions
10 * are met:
11 * 1. Redistributions of source code must retain the above copyright
12 *    notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 *    notice, this list of conditions and the following disclaimer in the
15 *    documentation and/or other materials provided with the distribution.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20 * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
21 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27 * SUCH DAMAGE.
28 *
29 * $FreeBSD: stable/10/sys/sys/ttyqueue.h 198223 2009-10-19 07:17:37Z ed $
30 */
31
32#ifndef _SYS_TTYQUEUE_H_
33#define	_SYS_TTYQUEUE_H_
34
35#ifndef _SYS_TTY_H_
36#error "can only be included through <sys/tty.h>"
37#endif /* !_SYS_TTY_H_ */
38
39struct tty;
40struct ttyinq_block;
41struct ttyoutq_block;
42struct uio;
43
44/* Data input queue. */
45struct ttyinq {
46	struct ttyinq_block	*ti_firstblock;
47	struct ttyinq_block	*ti_startblock;
48	struct ttyinq_block	*ti_reprintblock;
49	struct ttyinq_block	*ti_lastblock;
50	unsigned int		ti_begin;
51	unsigned int		ti_linestart;
52	unsigned int		ti_reprint;
53	unsigned int		ti_end;
54	unsigned int		ti_nblocks;
55	unsigned int		ti_quota;
56};
57#define TTYINQ_DATASIZE 128
58
59/* Data output queue. */
60struct ttyoutq {
61	struct ttyoutq_block	*to_firstblock;
62	struct ttyoutq_block	*to_lastblock;
63	unsigned int		to_begin;
64	unsigned int		to_end;
65	unsigned int		to_nblocks;
66	unsigned int		to_quota;
67};
68#define TTYOUTQ_DATASIZE (256 - sizeof(struct ttyoutq_block *))
69
70#ifdef _KERNEL
71/* Input queue handling routines. */
72void	ttyinq_setsize(struct ttyinq *ti, struct tty *tp, size_t len);
73void	ttyinq_free(struct ttyinq *ti);
74int	ttyinq_read_uio(struct ttyinq *ti, struct tty *tp, struct uio *uio,
75    size_t readlen, size_t flushlen);
76size_t	ttyinq_write(struct ttyinq *ti, const void *buf, size_t len,
77    int quote);
78int	ttyinq_write_nofrag(struct ttyinq *ti, const void *buf, size_t len,
79    int quote);
80void	ttyinq_canonicalize(struct ttyinq *ti);
81size_t	ttyinq_findchar(struct ttyinq *ti, const char *breakc, size_t maxlen,
82    char *lastc);
83void	ttyinq_flush(struct ttyinq *ti);
84int	ttyinq_peekchar(struct ttyinq *ti, char *c, int *quote);
85void	ttyinq_unputchar(struct ttyinq *ti);
86void	ttyinq_reprintpos_set(struct ttyinq *ti);
87void	ttyinq_reprintpos_reset(struct ttyinq *ti);
88
89static __inline size_t
90ttyinq_getsize(struct ttyinq *ti)
91{
92	return (ti->ti_nblocks * TTYINQ_DATASIZE);
93}
94
95static __inline size_t
96ttyinq_getallocatedsize(struct ttyinq *ti)
97{
98
99	return (ti->ti_quota * TTYINQ_DATASIZE);
100}
101
102static __inline size_t
103ttyinq_bytesleft(struct ttyinq *ti)
104{
105	size_t len;
106
107	/* Make sure the usage never exceeds the length. */
108	len = ti->ti_nblocks * TTYINQ_DATASIZE;
109	MPASS(len >= ti->ti_end);
110
111	return (len - ti->ti_end);
112}
113
114static __inline size_t
115ttyinq_bytescanonicalized(struct ttyinq *ti)
116{
117	MPASS(ti->ti_begin <= ti->ti_linestart);
118
119	return (ti->ti_linestart - ti->ti_begin);
120}
121
122static __inline size_t
123ttyinq_bytesline(struct ttyinq *ti)
124{
125	MPASS(ti->ti_linestart <= ti->ti_end);
126
127	return (ti->ti_end - ti->ti_linestart);
128}
129
130/* Input buffer iteration. */
131typedef void ttyinq_line_iterator_t(void *data, char c, int flags);
132void	ttyinq_line_iterate_from_linestart(struct ttyinq *ti,
133    ttyinq_line_iterator_t *iterator, void *data);
134void	ttyinq_line_iterate_from_reprintpos(struct ttyinq *ti,
135    ttyinq_line_iterator_t *iterator, void *data);
136
137/* Output queue handling routines. */
138void	ttyoutq_flush(struct ttyoutq *to);
139void	ttyoutq_setsize(struct ttyoutq *to, struct tty *tp, size_t len);
140void	ttyoutq_free(struct ttyoutq *to);
141size_t	ttyoutq_read(struct ttyoutq *to, void *buf, size_t len);
142int	ttyoutq_read_uio(struct ttyoutq *to, struct tty *tp, struct uio *uio);
143size_t	ttyoutq_write(struct ttyoutq *to, const void *buf, size_t len);
144int	ttyoutq_write_nofrag(struct ttyoutq *to, const void *buf, size_t len);
145
146static __inline size_t
147ttyoutq_getsize(struct ttyoutq *to)
148{
149	return (to->to_nblocks * TTYOUTQ_DATASIZE);
150}
151
152static __inline size_t
153ttyoutq_getallocatedsize(struct ttyoutq *to)
154{
155
156	return (to->to_quota * TTYOUTQ_DATASIZE);
157}
158
159static __inline size_t
160ttyoutq_bytesleft(struct ttyoutq *to)
161{
162	size_t len;
163
164	/* Make sure the usage never exceeds the length. */
165	len = to->to_nblocks * TTYOUTQ_DATASIZE;
166	MPASS(len >= to->to_end);
167
168	return (len - to->to_end);
169}
170
171static __inline size_t
172ttyoutq_bytesused(struct ttyoutq *to)
173{
174	return (to->to_end - to->to_begin);
175}
176#endif /* _KERNEL */
177
178#endif /* !_SYS_TTYQUEUE_H_ */
179