#include	"dat.h"#include	"fns.h"#include	"error.h" #include <interp.h> #include	"image.h"#include	<memimage.h>#include	<memlayer.h>#include	<cursor.h> enum{	Qdir,	Qtkevents}; staticDirtab tkdirtab[]={	"tkevents",		{Qtkevents, 0},		0,	0600,}; static struct {	QLock	l;	Queue*	eq;	Ref	inuse;} tkevents; static voidtkwiretapper(void *top, char *cmd, char *result, void *image, Rectangle *rp){	Block *b;	int n;	char *s, *e; 	n = 12;	if(cmd != nil)		n += strlen(cmd)+2+1;	if(result != nil)		n += strlen(result)+2+1;	if(image != nil)		n += 12;	if(rp != nil)		n += 4*20;	n++;	b = allocb(n);	if(b != nil){		s = (char*)b->wp;		e = s+n;		s += snprint(s, e-s, "%p", top);		if(cmd != nil){			*s++ = ' ';			*s++ = '[';			n = strlen(cmd);			memmove(s, cmd, n);			s += n;			*s++ = ']';		}		/* ignore result for now */		if(image != nil)			s += snprint(s, e-s, " %p", image);		if(rp != nil)			s += snprint(s, e-s, " %d %d %d %d", rp->min.x, rp->min.y, rp->max.x, rp->max.y);		b->wp = (uchar*)s;		release();		qlock(&tkevents.l);		if(waserror()){			freeb(b);			qunlock(&tkevents.l);			acquire();			return;		}		if(tkevents.eq != nil)			qbwrite(tkevents.eq, b);		qunlock(&tkevents.l);		acquire();	}} void	(*tkwiretap)(void*, char*, char*, void*, Rectangle*) = tkwiretapper; static Chan*tkattach(char* spec){	return devattach(L'τ', spec);} static inttkwalk(Chan* c, char* name){	return devwalk(c, name, tkdirtab, nelem(tkdirtab), devgen);} static voidtkstat(Chan* c, char* db){	devstat(c, db, tkdirtab, nelem(tkdirtab), devgen);} static Chan*tkopen(Chan* c, int omode){	if(c->qid.type & QTDIR)		return devopen(c, omode, tkdirtab, nelem(tkdirtab), devgen);	switch(c->qid.path){	case Qtkevents:		c = devopen(c, omode, tkdirtab, nelem(tkdirtab), devgen);		qlock(&tkevents.l);		if(incref(&tkevents.inuse) != 1){			qunlock(&tkevents.l);			error(Einuse);		}		if(tkevents.eq == nil)			tkevents.eq = qopen(256*1024, 0, nil, nil);		else			qreopen(tkevents.eq);		qunlock(&tkevents.l);		break;	}	return c;} static voidtkclose(Chan* c){	if(c->qid.type & QTDIR || (c->flag & COPEN) == 0)		return;	qlock(&tkevents.l);	if(decref(&tkevents.inuse) == 0)		qclose(tkevents.eq);	qunlock(&tkevents.l);} static longtkread(Chan* c, void* a, long n, vlong offset){	USED(offset);	switch(c->qid.path & ~CHDIR){	case Qdir:		return devdirread(c, a, n, tkdirtab, nelem(tkdirtab), devgen);	case Qtkevents:		return qread(tkevents.eq, a, n);	default:		n=0;		break;	}	return n;} static longtkwrite(Chan *c, void* a, long n, vlong offset){	USED(c); USED(a); USED(n); USED(offset);	error(Ebadusefd);	return 0;} Dev tkdevtab = {	L'τ',	"tk", //	devreset,	devinit,	tkattach,//	devdetach,	devclone,	tkwalk,	tkstat,	tkopen,	devcreate,	tkclose,	tkread,	devbread,	tkwrite,	devbwrite,	devremove,	devwstat,};