#include	"dat.h"#include	"fns.h"#include	"error.h"#include	"version.h"#include	"mp.h"#include	"libsec.h"#include	"keyboard.h" extern int cflag;int	exdebug;extern int keepbroken; enum{	Qdir,	Qcons,	Qconsctl,	Qdrivers,	Qhostowner,	Qhoststdin,	Qhoststdout,	Qhoststderr,	Qjit,	Qkeyboard,	Qkprint,	Qmemory,	Qmsec,	Qnotquiterandom,	Qnull,	Qrandom,	Qscancode,	Qsysctl,	Qsysname,	Qtime,	Quser}; Dirtab contab[] ={	".",	{Qdir, 0, QTDIR},	0,		DMDIR|0555,	"cons",		{Qcons},	0,	0666,	"consctl",	{Qconsctl},	0,	0222,	"drivers",	{Qdrivers},	0,	0444,	"hostowner",	{Qhostowner},	0,	0644,	"hoststdin",	{Qhoststdin},	0,	0444,	"hoststdout",	{Qhoststdout},	0,	0222,	"hoststderr",	{Qhoststderr},	0,	0222,	"jit",	{Qjit},	0,	0666,	"keyboard",	{Qkeyboard},	0,	0666,	"kprint",	{Qkprint},	0,	0444,	"memory",	{Qmemory},	0,	0444,	"msec",		{Qmsec},	NUMSIZE,	0444,	"notquiterandom",	{Qnotquiterandom},	0,	0444,	"null",		{Qnull},	0,	0666,	"random",	{Qrandom},	0,	0444,	"scancode",	{Qscancode},	0,	0444,	"sysctl",	{Qsysctl},	0,	0644,	"sysname",	{Qsysname},	0,	0644,	"time",		{Qtime},	0,	0644,	"user",		{Quser},	0,	0644,}; Queue*	gkscanq;		/* Graphics keyboard raw scancodes */char*	gkscanid;		/* name of raw scan format (if defined) */Queue*	gkbdq;			/* Graphics keyboard unprocessed input */Queue*	kbdq;			/* Console window unprocessed keyboard input */Queue*	lineq;			/* processed console input */ char	*ossysname; static struct{	RWlock l;	Queue*	q;} kprintq; vlong	timeoffset; extern int	dflag; static int	sysconwrite(void*, ulong);extern char**	rebootargv; static struct{	QLock	q;	QLock	gq;		/* separate lock for the graphical input */ 	int	raw;		/* true if we shouldn't process input */	Ref	ctl;		/* number of opens to the control file */	Ref	ptr;		/* number of opens to the ptr file */	int	scan;		/* true if reading raw scancodes */	int	x;		/* index into line */	char	line[1024];	/* current input line */ 	Rune	c;	int	count;} kbd; voidkbdslave(void *a){	char b; 	USED(a);	for(;;) {		b = readkbd();		if(kbd.raw == 0){			switch(b){			case 0x15:				write(1, "^U\n", 3);				break;			default:				write(1, &b, 1);				break;			}		}		qproduce(kbdq, &b, 1);	}	/* pexit("kbdslave", 0); */	/* not reached */} voidgkbdputc(Queue *q, int ch){	int n;	Rune r;	static uchar kc[5*UTFmax];	static int nk, collecting = 0;	char buf[UTFmax]; 	r = ch;	if(r == Latin) {		collecting = 1;		nk = 0;		return;	}	if(collecting) {		int c;		nk += runetochar((char*)&kc[nk], &r);		c = latin1(kc, nk);		if(c < -1)	/* need more keystrokes */			return;		collecting = 0;		if(c == -1) {	/* invalid sequence */			qproduce(q, kc, nk);			return;		}		r = (Rune)c;	}	n = runetochar(buf, &r);	if(n == 0)		return;	/* if(!isdbgkey(r)) */ 		qproduce(q, buf, n);} voidconsinit(void){	kbdq = qopen(512, 0, nil, nil);	if(kbdq == 0)		panic("no memory");	lineq = qopen(2*1024, 0, nil, nil);	if(lineq == 0)		panic("no memory");	gkbdq = qopen(512, 0, nil, nil);	if(gkbdq == 0)		panic("no memory");	randominit();} /* *  return true if current user is eve */intiseve(void){	return strcmp(eve, up->env->user) == 0;} static Chan*consattach(char *spec){	static int kp; 	if(kp == 0 && !dflag) {		kp = 1;		kproc("kbd", kbdslave, 0, 0);	}	return devattach('c', spec);} static Walkqid*conswalk(Chan *c, Chan *nc, char **name, int nname){	return devwalk(c, nc, name, nname, contab, nelem(contab), devgen);} static intconsstat(Chan *c, uchar *db, int n){	return devstat(c, db, n, contab, nelem(contab), devgen);} static Chan*consopen(Chan *c, int omode){	c = devopen(c, omode, contab, nelem(contab), devgen);	switch((ulong)c->qid.path) {	case Qconsctl:		incref(&kbd.ctl);		break; 	case Qscancode:		qlock(&kbd.gq);		if(gkscanq != nil || gkscanid == nil) {			qunlock(&kbd.q);			c->flag &= ~COPEN;			if(gkscanq)				error(Einuse);			else				error("not supported");		}		gkscanq = qopen(256, 0, nil, nil);		qunlock(&kbd.gq);		break; 	case Qkprint:		wlock(&kprintq.l);		if(waserror()){			wunlock(&kprintq.l);			c->flag &= ~COPEN;			nexterror();		}		if(kprintq.q != nil)			error(Einuse);		kprintq.q = qopen(32*1024, Qcoalesce, nil, nil);		if(kprintq.q == nil)			error(Enomem);		qnoblock(kprintq.q, 1);		poperror();		wunlock(&kprintq.l);		c->iounit = qiomaxatomic;		break;	}	return c;} static voidconsclose(Chan *c){	if((c->flag & COPEN) == 0)		return; 	switch((ulong)c->qid.path) {	case Qconsctl:		/* last close of control file turns off raw */		if(decref(&kbd.ctl) == 0)			kbd.raw = 0;		break; 	case Qscancode:		qlock(&kbd.gq);		if(gkscanq) {			qfree(gkscanq);			gkscanq = nil;		}		qunlock(&kbd.gq);		break; 	case Qkprint:		wlock(&kprintq.l);		qfree(kprintq.q);		kprintq.q = nil;		wunlock(&kprintq.l);		break;	}} static longconsread(Chan *c, void *va, long n, vlong offset){	int send;	char *p, buf[64], ch; 	if(c->qid.type & QTDIR)		return devdirread(c, va, n, contab, nelem(contab), devgen); 	switch((ulong)c->qid.path) {	default:		error(Egreg); 	case Qsysctl:		return readstr(offset, va, n, VERSION); 	case Qsysname:		if(ossysname == nil)			return 0;		return readstr(offset, va, n, ossysname); 	case Qrandom:		return randomread(va, n); 	case Qnotquiterandom:		genrandom(va, n);		return n; 	case Qhostowner:		return readstr(offset, va, n, eve); 	case Qhoststdin:		return read(0, va, n);	/* should be pread */ 	case Quser:		return readstr(offset, va, n, up->env->user); 	case Qjit:		snprint(buf, sizeof(buf), "%d", cflag);		return readstr(offset, va, n, buf); 	case Qtime:		snprint(buf, sizeof(buf), "%.lld", timeoffset + osusectime());		return readstr(offset, va, n, buf); 	case Qdrivers:		return devtabread(c, va, n, offset); 	case Qmemory:		return poolread(va, n, offset); 	case Qnull:		return 0; 	case Qmsec:		return readnum(offset, va, n, osmillisec(), NUMSIZE); 	case Qcons:		qlock(&kbd.q);		if(waserror()){			qunlock(&kbd.q);			nexterror();		} 		if(dflag)			error(Enonexist); 		while(!qcanread(lineq)) {			if(qread(kbdq, &ch, 1) == 0)				continue;			send = 0;			if(ch == 0){				/* flush output on rawoff -> rawon */				if(kbd.x > 0)					send = !qcanread(kbdq);			}else if(kbd.raw){				kbd.line[kbd.x++] = ch;				send = !qcanread(kbdq);			}else{				switch(ch){				case '\b':					if(kbd.x)						kbd.x--;					break;				case 0x15:					kbd.x = 0;					break;				case 0x04:					send = 1;					break;				case '\n':					send = 1;				default:					kbd.line[kbd.x++] = ch;					break;				}			}			if(send || kbd.x == sizeof kbd.line){				qwrite(lineq, kbd.line, kbd.x);				kbd.x = 0;			}		}		n = qread(lineq, va, n);		qunlock(&kbd.q);		poperror();		return n; 	case Qscancode:		if(offset == 0)			return readstr(0, va, n, gkscanid);		return qread(gkscanq, va, n); 	case Qkeyboard:		return qread(gkbdq, va, n); 	case Qkprint:		rlock(&kprintq.l);		if(waserror()){			runlock(&kprintq.l);			nexterror();		}		n = qread(kprintq.q, va, n);		poperror();		runlock(&kprintq.l);		return n;	}} static longconswrite(Chan *c, void *va, long n, vlong offset){	char buf[128], *a, ch;	int x; 	if(c->qid.type & QTDIR)		error(Eperm); 	switch((ulong)c->qid.path) {	default:		error(Egreg); 	case Qcons:		if(canrlock(&kprintq.l)){			if(kprintq.q != nil){				if(waserror()){					runlock(&kprintq.l);					nexterror();				}				qwrite(kprintq.q, va, n);				poperror();				runlock(&kprintq.l);				return n;			}			runlock(&kprintq.l);		}		return write(1, va, n); 	case Qsysctl:		return sysconwrite(va, n); 	case Qconsctl:		if(n >= sizeof(buf))			n = sizeof(buf)-1;		strncpy(buf, va, n);		buf[n] = 0;		for(a = buf; a;){			if(strncmp(a, "rawon", 5) == 0){				kbd.raw = 1;				/* clumsy hack - wake up reader */				ch = 0;				qwrite(kbdq, &ch, 1);			} else if(strncmp(buf, "rawoff", 6) == 0){				kbd.raw = 0;			}			if((a = strchr(a, ' ')) != nil)				a++;		}		break; 	case Qkeyboard:		for(x=0; x<n; ) {			Rune r;			x += chartorune(&r, &((char*)va)[x]);			gkbdputc(gkbdq, r);		}		break; 	case Qnull:		break; 	case Qtime:		if(n >= sizeof(buf))			n = sizeof(buf)-1;		strncpy(buf, va, n);		buf[n] = '\0';		timeoffset = strtoll(buf, 0, 0)-osusectime();		break; 	case Qhostowner:		if(!iseve())			error(Eperm);		if(offset != 0 || n >= sizeof(buf))			error(Ebadarg);		memmove(buf, va, n);		buf[n] = '\0';		if(n > 0 && buf[n-1] == '\n')			buf[--n] = '\0';		if(n == 0)			error(Ebadarg);		/* renameuser(eve, buf); */		/* renameproguser(eve, buf); */		kstrdup(&eve, buf);		kstrdup(&up->env->user, buf);		break; 	case Quser:		if(!iseve())			error(Eperm);		if(offset != 0)			error(Ebadarg);

Lines 1–500 of 643. Load more