ref: 5611a46d8fb04ec3fd60c05a1486743cea98a311
dir: /emu/port/devtk.c/
#include "dat.h" #include "fns.h" #include "error.h" #include <interp.h> #include "draw.h" #include <memdraw.h> #include <memlayer.h> #include <cursor.h> enum{ Qdir, Qtkevents }; static Dirtab tkdirtab[]= { ".", {Qdir, 0, QTDIR}, 0, DMDIR|0555, "tkevents", {Qtkevents, 0}, 0, 0600, }; static struct { QLock l; Queue* eq; Ref inuse; } tkevents; static void tkwiretapper(void *top, char *cmd, char *result, void *image, Rectangle *rp) { Block *b; int n; char *s, *e; //fprint(2, "wiretap %p %q %q\n", top, cmd, result); if(tkevents.eq == nil) return; 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); else freeb(b); poperror(); qunlock(&tkevents.l); acquire(); } } void (*tkwiretap)(void*, char*, char*, void*, Rectangle*) = tkwiretapper; static Chan* tkattach(char* spec) { return devattach(L'τ', spec); } static Walkqid* tkwalk(Chan *c, Chan *nc, char **name, int nname) { return devwalk(c, nc, name, nname, tkdirtab, nelem(tkdirtab), devgen); } static int tkstat(Chan *c, uchar *db, int n) { return devstat(c, db, n, 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 void tkclose(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 long tkread(Chan* c, void* a, long n, vlong offset) { USED(offset); if(c->qid.type & QTDIR) return devdirread(c, a, n, tkdirtab, nelem(tkdirtab), devgen); switch((ulong)c->qid.path){ case Qtkevents: return qread(tkevents.eq, a, n); default: n=0; break; } return n; } static long tkwrite(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, tkwalk, tkstat, tkopen, devcreate, tkclose, tkread, devbread, tkwrite, devbwrite, devremove, devwstat, };