1 6f4d00ee 2013-09-23 0intro #include "stdinc.h"
  2 6f4d00ee 2013-09-23 0intro 
  3 6f4d00ee 2013-09-23 0intro #include "9.h"
  4 6f4d00ee 2013-09-23 0intro 
  5 6f4d00ee 2013-09-23 0intro enum {
  6 6f4d00ee 2013-09-23 0intro 	Nl	= 256,			/* max. command line length */
  7 6f4d00ee 2013-09-23 0intro 	Nq	= 8*1024,		/* amount of I/O buffered */
  8 6f4d00ee 2013-09-23 0intro };
  9 6f4d00ee 2013-09-23 0intro 
 10 6f4d00ee 2013-09-23 0intro typedef struct Q {
 11 4b576658 2013-09-23 0intro 	QLock	lock;
 12 4b576658 2013-09-23 0intro 	Rendez	full;
 13 4b576658 2013-09-23 0intro 	Rendez	empty;
 14 6f4d00ee 2013-09-23 0intro 
 15 6f4d00ee 2013-09-23 0intro 	char	q[Nq];
 16 6f4d00ee 2013-09-23 0intro 	int	n;
 17 6f4d00ee 2013-09-23 0intro 	int	r;
 18 6f4d00ee 2013-09-23 0intro 	int	w;
 19 6f4d00ee 2013-09-23 0intro } Q;
 20 6f4d00ee 2013-09-23 0intro 
 21 6f4d00ee 2013-09-23 0intro typedef struct Cons {
 22 4b576658 2013-09-23 0intro 	QLock	lock;
 23 6f4d00ee 2013-09-23 0intro 	int	ref;
 24 6f4d00ee 2013-09-23 0intro 	int	closed;
 25 6f4d00ee 2013-09-23 0intro 	int	fd;
 26 6f4d00ee 2013-09-23 0intro 	int	srvfd;
 27 6f4d00ee 2013-09-23 0intro 	int	ctlfd;
 28 6f4d00ee 2013-09-23 0intro 	Q*	iq;		/* points to console.iq */
 29 6f4d00ee 2013-09-23 0intro 	Q*	oq;		/* points to console.oq */
 30 6f4d00ee 2013-09-23 0intro } Cons;
 31 6f4d00ee 2013-09-23 0intro 
 32 6f4d00ee 2013-09-23 0intro char *currfsysname;
 33 6f4d00ee 2013-09-23 0intro 
 34 6f4d00ee 2013-09-23 0intro static struct {
 35 6f4d00ee 2013-09-23 0intro 	Q*	iq;		/* input */
 36 6f4d00ee 2013-09-23 0intro 	Q*	oq;		/* output */
 37 6f4d00ee 2013-09-23 0intro 	char	l[Nl];		/* command line assembly */
 38 6f4d00ee 2013-09-23 0intro 	int	nl;		/* current line length */
 39 6f4d00ee 2013-09-23 0intro 	int	nopens;
 40 6f4d00ee 2013-09-23 0intro 
 41 6f4d00ee 2013-09-23 0intro 	char*	prompt;
 42 6f4d00ee 2013-09-23 0intro 	int	np;
 43 6f4d00ee 2013-09-23 0intro } console;
 44 6f4d00ee 2013-09-23 0intro 
 45 6f4d00ee 2013-09-23 0intro static void
 46 6f4d00ee 2013-09-23 0intro consClose(Cons* cons)
 47 6f4d00ee 2013-09-23 0intro {
 48 4b576658 2013-09-23 0intro 	qlock(&cons->lock);
 49 6f4d00ee 2013-09-23 0intro 	cons->closed = 1;
 50 6f4d00ee 2013-09-23 0intro 
 51 6f4d00ee 2013-09-23 0intro 	cons->ref--;
 52 6f4d00ee 2013-09-23 0intro 	if(cons->ref > 0){
 53 4b576658 2013-09-23 0intro 		qlock(&cons->iq->lock);
 54 4b576658 2013-09-23 0intro 		rwakeup(&cons->iq->full);
 55 4b576658 2013-09-23 0intro 		qunlock(&cons->iq->lock);
 56 4b576658 2013-09-23 0intro 		qlock(&cons->oq->lock);
 57 4b576658 2013-09-23 0intro 		rwakeup(&cons->oq->empty);
 58 4b576658 2013-09-23 0intro 		qunlock(&cons->oq->lock);
 59 4b576658 2013-09-23 0intro 		qunlock(&cons->lock);
 60 6f4d00ee 2013-09-23 0intro 		return;
 61 6f4d00ee 2013-09-23 0intro 	}
 62 6f4d00ee 2013-09-23 0intro 
 63 6f4d00ee 2013-09-23 0intro 	if(cons->ctlfd != -1){
 64 6f4d00ee 2013-09-23 0intro 		close(cons->ctlfd);
 65 6f4d00ee 2013-09-23 0intro 		cons->srvfd = -1;
 66 6f4d00ee 2013-09-23 0intro 	}
 67 6f4d00ee 2013-09-23 0intro 	if(cons->srvfd != -1){
 68 6f4d00ee 2013-09-23 0intro 		close(cons->srvfd);
 69 6f4d00ee 2013-09-23 0intro 		cons->srvfd = -1;
 70 6f4d00ee 2013-09-23 0intro 	}
 71 6f4d00ee 2013-09-23 0intro 	if(cons->fd != -1){
 72 6f4d00ee 2013-09-23 0intro 		close(cons->fd);
 73 6f4d00ee 2013-09-23 0intro 		cons->fd = -1;
 74 6f4d00ee 2013-09-23 0intro 	}
 75 4b576658 2013-09-23 0intro 	qunlock(&cons->lock);
 76 4b576658 2013-09-23 0intro 	vtfree(cons);
 77 6f4d00ee 2013-09-23 0intro 	console.nopens--;
 78 6f4d00ee 2013-09-23 0intro }
 79 6f4d00ee 2013-09-23 0intro 
 80 6f4d00ee 2013-09-23 0intro static void
 81 6f4d00ee 2013-09-23 0intro consIProc(void* v)
 82 6f4d00ee 2013-09-23 0intro {
 83 6f4d00ee 2013-09-23 0intro 	Q *q;
 84 6f4d00ee 2013-09-23 0intro 	Cons *cons;
 85 6f4d00ee 2013-09-23 0intro 	int n, w;
 86 6f4d00ee 2013-09-23 0intro 	char buf[Nq/4];
 87 6f4d00ee 2013-09-23 0intro 
 88 4b576658 2013-09-23 0intro 	threadsetname("consI");
 89 6f4d00ee 2013-09-23 0intro 
 90 6f4d00ee 2013-09-23 0intro 	cons = v;
 91 6f4d00ee 2013-09-23 0intro 	q = cons->iq;
 92 6f4d00ee 2013-09-23 0intro 	for(;;){
 93 6f4d00ee 2013-09-23 0intro 		/*
 94 6f4d00ee 2013-09-23 0intro 		 * Can't tell the difference between zero-length read
 95 6f4d00ee 2013-09-23 0intro 		 * and eof, so keep calling read until we get an error.
 96 6f4d00ee 2013-09-23 0intro 		 */
 97 6f4d00ee 2013-09-23 0intro 		if(cons->closed || (n = read(cons->fd, buf, Nq/4)) < 0)
 98 6f4d00ee 2013-09-23 0intro 			break;
 99 4b576658 2013-09-23 0intro 		qlock(&q->lock);
100 6f4d00ee 2013-09-23 0intro 		while(Nq - q->n < n && !cons->closed)
101 4b576658 2013-09-23 0intro 			rsleep(&q->full);
102 6f4d00ee 2013-09-23 0intro 		w = Nq - q->w;
103 6f4d00ee 2013-09-23 0intro 		if(w < n){
104 6f4d00ee 2013-09-23 0intro 			memmove(&q->q[q->w], buf, w);
105 6f4d00ee 2013-09-23 0intro 			memmove(&q->q[0], buf + w, n - w);
106 6f4d00ee 2013-09-23 0intro 		}
107 6f4d00ee 2013-09-23 0intro 		else
108 6f4d00ee 2013-09-23 0intro 			memmove(&q->q[q->w], buf, n);
109 6f4d00ee 2013-09-23 0intro 		q->w = (q->w + n) % Nq;
110 6f4d00ee 2013-09-23 0intro 		q->n += n;
111 4b576658 2013-09-23 0intro 		rwakeup(&q->empty);
112 4b576658 2013-09-23 0intro 		qunlock(&q->lock);
113 6f4d00ee 2013-09-23 0intro 	}
114 6f4d00ee 2013-09-23 0intro 	consClose(cons);
115 6f4d00ee 2013-09-23 0intro }
116 6f4d00ee 2013-09-23 0intro 
117 6f4d00ee 2013-09-23 0intro static void
118 6f4d00ee 2013-09-23 0intro consOProc(void* v)
119 6f4d00ee 2013-09-23 0intro {
120 6f4d00ee 2013-09-23 0intro 	Q *q;
121 6f4d00ee 2013-09-23 0intro 	Cons *cons;
122 6f4d00ee 2013-09-23 0intro 	char buf[Nq];
123 6f4d00ee 2013-09-23 0intro 	int lastn, n, r;
124 6f4d00ee 2013-09-23 0intro 
125 4b576658 2013-09-23 0intro 	threadsetname("consO");
126 6f4d00ee 2013-09-23 0intro 
127 6f4d00ee 2013-09-23 0intro 	cons = v;
128 6f4d00ee 2013-09-23 0intro 	q = cons->oq;
129 4b576658 2013-09-23 0intro 	qlock(&q->lock);
130 6f4d00ee 2013-09-23 0intro 	lastn = 0;
131 6f4d00ee 2013-09-23 0intro 	for(;;){
132 6f4d00ee 2013-09-23 0intro 		while(lastn == q->n && !cons->closed)
133 4b576658 2013-09-23 0intro 			rsleep(&q->empty);
134 6f4d00ee 2013-09-23 0intro 		if((n = q->n - lastn) > Nq)
135 6f4d00ee 2013-09-23 0intro 			n = Nq;
136 6f4d00ee 2013-09-23 0intro 		if(n > q->w){
137 6f4d00ee 2013-09-23 0intro 			r = n - q->w;
138 6f4d00ee 2013-09-23 0intro 			memmove(buf, &q->q[Nq - r], r);
139 6f4d00ee 2013-09-23 0intro 			memmove(buf+r, &q->q[0], n - r);
140 6f4d00ee 2013-09-23 0intro 		}
141 6f4d00ee 2013-09-23 0intro 		else
142 6f4d00ee 2013-09-23 0intro 			memmove(buf, &q->q[q->w - n], n);
143 6f4d00ee 2013-09-23 0intro 		lastn = q->n;
144 4b576658 2013-09-23 0intro 		qunlock(&q->lock);
145 6f4d00ee 2013-09-23 0intro 		if(cons->closed || write(cons->fd, buf, n) < 0)
146 6f4d00ee 2013-09-23 0intro 			break;
147 4b576658 2013-09-23 0intro 		qlock(&q->lock);
148 4b576658 2013-09-23 0intro 		rwakeup(&q->empty);
149 6f4d00ee 2013-09-23 0intro 	}
150 6f4d00ee 2013-09-23 0intro 	consClose(cons);
151 6f4d00ee 2013-09-23 0intro }
152 6f4d00ee 2013-09-23 0intro 
153 6f4d00ee 2013-09-23 0intro int
154 6f4d00ee 2013-09-23 0intro consOpen(int fd, int srvfd, int ctlfd)
155 6f4d00ee 2013-09-23 0intro {
156 6f4d00ee 2013-09-23 0intro 	Cons *cons;
157 6f4d00ee 2013-09-23 0intro 
158 4b576658 2013-09-23 0intro 	cons = vtmallocz(sizeof(Cons));
159 6f4d00ee 2013-09-23 0intro 	cons->fd = fd;
160 6f4d00ee 2013-09-23 0intro 	cons->srvfd = srvfd;
161 6f4d00ee 2013-09-23 0intro 	cons->ctlfd = ctlfd;
162 6f4d00ee 2013-09-23 0intro 	cons->iq = console.iq;
163 6f4d00ee 2013-09-23 0intro 	cons->oq = console.oq;
164 6f4d00ee 2013-09-23 0intro 	console.nopens++;
165 6f4d00ee 2013-09-23 0intro 
166 4b576658 2013-09-23 0intro 	qlock(&cons->lock);
167 6f4d00ee 2013-09-23 0intro 	cons->ref = 2;
168 6f4d00ee 2013-09-23 0intro 	cons->closed = 0;
169 4b576658 2013-09-23 0intro 	if(proccreate(consOProc, cons, STACK) < 0){
170 6f4d00ee 2013-09-23 0intro 		cons->ref--;
171 4b576658 2013-09-23 0intro 		qunlock(&cons->lock);
172 6f4d00ee 2013-09-23 0intro 		consClose(cons);
173 6f4d00ee 2013-09-23 0intro 		return 0;
174 6f4d00ee 2013-09-23 0intro 	}
175 4b576658 2013-09-23 0intro 	qunlock(&cons->lock);
176 6f4d00ee 2013-09-23 0intro 
177 6f4d00ee 2013-09-23 0intro 	if(ctlfd >= 0)
178 6f4d00ee 2013-09-23 0intro 		consIProc(cons);
179 4b576658 2013-09-23 0intro 	else if(proccreate(consIProc, cons, STACK) < 0){
180 6f4d00ee 2013-09-23 0intro 		consClose(cons);
181 6f4d00ee 2013-09-23 0intro 		return 0;
182 6f4d00ee 2013-09-23 0intro 	}
183 6f4d00ee 2013-09-23 0intro 
184 6f4d00ee 2013-09-23 0intro 	return 1;
185 6f4d00ee 2013-09-23 0intro }
186 6f4d00ee 2013-09-23 0intro 
187 6f4d00ee 2013-09-23 0intro static int
188 6f4d00ee 2013-09-23 0intro qWrite(Q* q, char* p, int n)
189 6f4d00ee 2013-09-23 0intro {
190 6f4d00ee 2013-09-23 0intro 	int w;
191 6f4d00ee 2013-09-23 0intro 
192 4b576658 2013-09-23 0intro 	qlock(&q->lock);
193 6f4d00ee 2013-09-23 0intro 	if(n > Nq - q->w){
194 6f4d00ee 2013-09-23 0intro 		w = Nq - q->w;
195 6f4d00ee 2013-09-23 0intro 		memmove(&q->q[q->w], p, w);
196 6f4d00ee 2013-09-23 0intro 		memmove(&q->q[0], p + w, n - w);
197 6f4d00ee 2013-09-23 0intro 		q->w = n - w;
198 6f4d00ee 2013-09-23 0intro 	}
199 6f4d00ee 2013-09-23 0intro 	else{
200 6f4d00ee 2013-09-23 0intro 		memmove(&q->q[q->w], p, n);
201 6f4d00ee 2013-09-23 0intro 		q->w += n;
202 6f4d00ee 2013-09-23 0intro 	}
203 6f4d00ee 2013-09-23 0intro 	q->n += n;
204 4b576658 2013-09-23 0intro 	rwakeup(&q->empty);
205 4b576658 2013-09-23 0intro 	qunlock(&q->lock);
206 6f4d00ee 2013-09-23 0intro 
207 6f4d00ee 2013-09-23 0intro 	return n;
208 6f4d00ee 2013-09-23 0intro }
209 6f4d00ee 2013-09-23 0intro 
210 6f4d00ee 2013-09-23 0intro static Q*
211 6f4d00ee 2013-09-23 0intro qAlloc(void)
212 6f4d00ee 2013-09-23 0intro {
213 6f4d00ee 2013-09-23 0intro 	Q *q;
214 6f4d00ee 2013-09-23 0intro 
215 4b576658 2013-09-23 0intro 	q = vtmallocz(sizeof(Q));
216 4b576658 2013-09-23 0intro 	q->full.l = &q->lock;
217 4b576658 2013-09-23 0intro 	q->empty.l = &q->lock;
218 6f4d00ee 2013-09-23 0intro 	q->n = q->r = q->w = 0;
219 6f4d00ee 2013-09-23 0intro 
220 6f4d00ee 2013-09-23 0intro 	return q;
221 6f4d00ee 2013-09-23 0intro }
222 6f4d00ee 2013-09-23 0intro 
223 6f4d00ee 2013-09-23 0intro static void
224 b32de4ae 2013-09-26 0intro consProc(void* v)
225 6f4d00ee 2013-09-23 0intro {
226 b32de4ae 2013-09-26 0intro 	USED(v);
227 6f4d00ee 2013-09-23 0intro 	Q *q;
228 6f4d00ee 2013-09-23 0intro 	int argc, i, n, r;
229 6f4d00ee 2013-09-23 0intro 	char *argv[20], buf[Nq], *lp, *wbuf;
230 6f4d00ee 2013-09-23 0intro 	char procname[64];
231 6f4d00ee 2013-09-23 0intro 
232 6f4d00ee 2013-09-23 0intro 	snprint(procname, sizeof procname, "cons %s", currfsysname);
233 4b576658 2013-09-23 0intro 	threadsetname(procname);
234 6f4d00ee 2013-09-23 0intro 
235 6f4d00ee 2013-09-23 0intro 	q = console.iq;
236 6f4d00ee 2013-09-23 0intro 	qWrite(console.oq, console.prompt, console.np);
237 4b576658 2013-09-23 0intro 	qlock(&q->lock);
238 6f4d00ee 2013-09-23 0intro 	for(;;){
239 6f4d00ee 2013-09-23 0intro 		while((n = q->n) == 0)
240 4b576658 2013-09-23 0intro 			rsleep(&q->empty);
241 6f4d00ee 2013-09-23 0intro 		r = Nq - q->r;
242 6f4d00ee 2013-09-23 0intro 		if(r < n){
243 6f4d00ee 2013-09-23 0intro 			memmove(buf, &q->q[q->r], r);
244 6f4d00ee 2013-09-23 0intro 			memmove(buf + r, &q->q[0], n - r);
245 6f4d00ee 2013-09-23 0intro 		}
246 6f4d00ee 2013-09-23 0intro 		else
247 6f4d00ee 2013-09-23 0intro 			memmove(buf, &q->q[q->r], n);
248 6f4d00ee 2013-09-23 0intro 		q->r = (q->r + n) % Nq;
249 6f4d00ee 2013-09-23 0intro 		q->n -= n;
250 4b576658 2013-09-23 0intro 		rwakeup(&q->full);
251 4b576658 2013-09-23 0intro 		qunlock(&q->lock);
252 6f4d00ee 2013-09-23 0intro 
253 6f4d00ee 2013-09-23 0intro 		for(i = 0; i < n; i++){
254 6f4d00ee 2013-09-23 0intro 			switch(buf[i]){
255 6f4d00ee 2013-09-23 0intro 			case '\004':				/* ^D */
256 6f4d00ee 2013-09-23 0intro 				if(console.nl == 0){
257 6f4d00ee 2013-09-23 0intro 					qWrite(console.oq, "\n", 1);
258 6f4d00ee 2013-09-23 0intro 					break;
259 6f4d00ee 2013-09-23 0intro 				}
260 6f4d00ee 2013-09-23 0intro 				/*FALLTHROUGH*/
261 6f4d00ee 2013-09-23 0intro 			default:
262 6f4d00ee 2013-09-23 0intro 				if(console.nl < Nl-1){
263 6f4d00ee 2013-09-23 0intro 					qWrite(console.oq, &buf[i], 1);
264 6f4d00ee 2013-09-23 0intro 					console.l[console.nl++] = buf[i];
265 6f4d00ee 2013-09-23 0intro 				}
266 6f4d00ee 2013-09-23 0intro 				continue;
267 6f4d00ee 2013-09-23 0intro 			case '\b':
268 6f4d00ee 2013-09-23 0intro 				if(console.nl != 0){
269 6f4d00ee 2013-09-23 0intro 					qWrite(console.oq, &buf[i], 1);
270 6f4d00ee 2013-09-23 0intro 					console.nl--;
271 6f4d00ee 2013-09-23 0intro 				}
272 6f4d00ee 2013-09-23 0intro 				continue;
273 6f4d00ee 2013-09-23 0intro 			case '\n':
274 6f4d00ee 2013-09-23 0intro 				qWrite(console.oq, &buf[i], 1);
275 6f4d00ee 2013-09-23 0intro 				break;
276 6f4d00ee 2013-09-23 0intro 			case '\025':				/* ^U */
277 6f4d00ee 2013-09-23 0intro 				qWrite(console.oq, "^U\n", 3);
278 6f4d00ee 2013-09-23 0intro 				console.nl = 0;
279 6f4d00ee 2013-09-23 0intro 				break;
280 6f4d00ee 2013-09-23 0intro 			case '\027':				/* ^W */
281 6f4d00ee 2013-09-23 0intro 				console.l[console.nl] = '\0';
282 4b576658 2013-09-23 0intro 				wbuf = vtmalloc(console.nl+1);
283 6f4d00ee 2013-09-23 0intro 				memmove(wbuf, console.l, console.nl+1);
284 6f4d00ee 2013-09-23 0intro 				argc = tokenize(wbuf, argv, nelem(argv));
285 6f4d00ee 2013-09-23 0intro 				if(argc > 0)
286 6f4d00ee 2013-09-23 0intro 					argc--;
287 6f4d00ee 2013-09-23 0intro 				console.nl = 0;
288 6f4d00ee 2013-09-23 0intro 				lp = console.l;
289 6f4d00ee 2013-09-23 0intro 				for(i = 0; i < argc; i++)
290 6f4d00ee 2013-09-23 0intro 					lp += sprint(lp, "%q ", argv[i]);
291 6f4d00ee 2013-09-23 0intro 				console.nl = lp - console.l;
292 4b576658 2013-09-23 0intro 				vtfree(wbuf);
293 6f4d00ee 2013-09-23 0intro 				qWrite(console.oq, "^W\n", 3);
294 6f4d00ee 2013-09-23 0intro 				if(console.nl == 0)
295 6f4d00ee 2013-09-23 0intro 					break;
296 6f4d00ee 2013-09-23 0intro 				qWrite(console.oq, console.l, console.nl);
297 6f4d00ee 2013-09-23 0intro 				continue;
298 6f4d00ee 2013-09-23 0intro 			case '\177':
299 6f4d00ee 2013-09-23 0intro 				qWrite(console.oq, "\n", 1);
300 6f4d00ee 2013-09-23 0intro 				console.nl = 0;
301 6f4d00ee 2013-09-23 0intro 				break;
302 6f4d00ee 2013-09-23 0intro 			}
303 6f4d00ee 2013-09-23 0intro 
304 6f4d00ee 2013-09-23 0intro 			console.l[console.nl] = '\0';
305 6f4d00ee 2013-09-23 0intro 			if(console.nl != 0)
306 6f4d00ee 2013-09-23 0intro 				cliExec(console.l);
307 6f4d00ee 2013-09-23 0intro 
308 6f4d00ee 2013-09-23 0intro 			console.nl = 0;
309 6f4d00ee 2013-09-23 0intro 			qWrite(console.oq, console.prompt, console.np);
310 6f4d00ee 2013-09-23 0intro 		}
311 6f4d00ee 2013-09-23 0intro 
312 4b576658 2013-09-23 0intro 		qlock(&q->lock);
313 6f4d00ee 2013-09-23 0intro 	}
314 6f4d00ee 2013-09-23 0intro }
315 6f4d00ee 2013-09-23 0intro 
316 6f4d00ee 2013-09-23 0intro int
317 6f4d00ee 2013-09-23 0intro consWrite(char* buf, int len)
318 6f4d00ee 2013-09-23 0intro {
319 6f4d00ee 2013-09-23 0intro 	if(console.oq == nil)
320 6f4d00ee 2013-09-23 0intro 		return write(2, buf, len);
321 6f4d00ee 2013-09-23 0intro 	if(console.nopens == 0)
322 6f4d00ee 2013-09-23 0intro 		write(2, buf, len);
323 6f4d00ee 2013-09-23 0intro 	return qWrite(console.oq, buf, len);
324 6f4d00ee 2013-09-23 0intro }
325 6f4d00ee 2013-09-23 0intro 
326 6f4d00ee 2013-09-23 0intro int
327 6f4d00ee 2013-09-23 0intro consPrompt(char* prompt)
328 6f4d00ee 2013-09-23 0intro {
329 6f4d00ee 2013-09-23 0intro 	char buf[ERRMAX];
330 6f4d00ee 2013-09-23 0intro 
331 6f4d00ee 2013-09-23 0intro 	if(prompt == nil)
332 6f4d00ee 2013-09-23 0intro 		prompt = "prompt";
333 6f4d00ee 2013-09-23 0intro 
334 4b576658 2013-09-23 0intro 	vtfree(console.prompt);
335 6f4d00ee 2013-09-23 0intro 	console.np = snprint(buf, sizeof(buf), "%s: ", prompt);
336 4b576658 2013-09-23 0intro 	console.prompt = vtstrdup(buf);
337 6f4d00ee 2013-09-23 0intro 
338 6f4d00ee 2013-09-23 0intro 	return console.np;
339 6f4d00ee 2013-09-23 0intro }
340 6f4d00ee 2013-09-23 0intro 
341 6f4d00ee 2013-09-23 0intro int
342 6f4d00ee 2013-09-23 0intro consTTY(void)
343 6f4d00ee 2013-09-23 0intro {
344 6f4d00ee 2013-09-23 0intro 	int ctl, fd;
345 6f4d00ee 2013-09-23 0intro 	char *name, *p;
346 6f4d00ee 2013-09-23 0intro 
347 6f4d00ee 2013-09-23 0intro 	name = "/dev/cons";
348 6f4d00ee 2013-09-23 0intro 	if((fd = open(name, ORDWR)) < 0){
349 b32de4ae 2013-09-26 0intro #ifdef PLAN9PORT
350 b32de4ae 2013-09-26 0intro 		name = "/dev/tty";
351 b32de4ae 2013-09-26 0intro #else
352 6f4d00ee 2013-09-23 0intro 		name = "#c/cons";
353 b32de4ae 2013-09-26 0intro #endif
354 6f4d00ee 2013-09-23 0intro 		if((fd = open(name, ORDWR)) < 0){
355 4b576658 2013-09-23 0intro 			werrstr("consTTY: open %s: %r", name);
356 6f4d00ee 2013-09-23 0intro 			return 0;
357 6f4d00ee 2013-09-23 0intro 		}
358 6f4d00ee 2013-09-23 0intro 	}
359 6f4d00ee 2013-09-23 0intro 
360 b32de4ae 2013-09-26 0intro #ifdef PLAN9PORT
361 b32de4ae 2013-09-26 0intro 	USED(p);
362 b32de4ae 2013-09-26 0intro 	ctl = 0;
363 b32de4ae 2013-09-26 0intro #else
364 6f4d00ee 2013-09-23 0intro 	p = smprint("%sctl", name);
365 6f4d00ee 2013-09-23 0intro 	if((ctl = open(p, OWRITE)) < 0){
366 6f4d00ee 2013-09-23 0intro 		close(fd);
367 4b576658 2013-09-23 0intro 		werrstr("consTTY: open %s: %r", p);
368 6f4d00ee 2013-09-23 0intro 		free(p);
369 6f4d00ee 2013-09-23 0intro 		return 0;
370 6f4d00ee 2013-09-23 0intro 	}
371 6f4d00ee 2013-09-23 0intro 	if(write(ctl, "rawon", 5) < 0){
372 6f4d00ee 2013-09-23 0intro 		close(ctl);
373 6f4d00ee 2013-09-23 0intro 		close(fd);
374 4b576658 2013-09-23 0intro 		werrstr("consTTY: write %s: %r", p);
375 6f4d00ee 2013-09-23 0intro 		free(p);
376 6f4d00ee 2013-09-23 0intro 		return 0;
377 6f4d00ee 2013-09-23 0intro 	}
378 6f4d00ee 2013-09-23 0intro 	free(p);
379 b32de4ae 2013-09-26 0intro #endif
380 6f4d00ee 2013-09-23 0intro 
381 6f4d00ee 2013-09-23 0intro 	if(consOpen(fd, fd, ctl) == 0){
382 6f4d00ee 2013-09-23 0intro 		close(ctl);
383 6f4d00ee 2013-09-23 0intro 		close(fd);
384 6f4d00ee 2013-09-23 0intro 		return 0;
385 6f4d00ee 2013-09-23 0intro 	}
386 6f4d00ee 2013-09-23 0intro 
387 6f4d00ee 2013-09-23 0intro 	return 1;
388 6f4d00ee 2013-09-23 0intro }
389 6f4d00ee 2013-09-23 0intro 
390 6f4d00ee 2013-09-23 0intro int
391 6f4d00ee 2013-09-23 0intro consInit(void)
392 6f4d00ee 2013-09-23 0intro {
393 6f4d00ee 2013-09-23 0intro 	console.iq = qAlloc();
394 6f4d00ee 2013-09-23 0intro 	console.oq = qAlloc();
395 6f4d00ee 2013-09-23 0intro 	console.nl = 0;
396 6f4d00ee 2013-09-23 0intro 
397 6f4d00ee 2013-09-23 0intro 	consPrompt(nil);
398 6f4d00ee 2013-09-23 0intro 
399 4b576658 2013-09-23 0intro 	if(proccreate(consProc, nil, STACK) < 0){
400 4b576658 2013-09-23 0intro 		sysfatal("can't start console proc");
401 6f4d00ee 2013-09-23 0intro 		return 0;
402 6f4d00ee 2013-09-23 0intro 	}
403 6f4d00ee 2013-09-23 0intro 
404 6f4d00ee 2013-09-23 0intro 	return 1;
405 6f4d00ee 2013-09-23 0intro }