1 /* Copyright (c) 2006 Russ Cox */
4 #include <sys/select.h>
12 int chattydrawclient = 0;
14 static int drawgettag(Mux *mux, void *vmsg);
15 static void* drawrecv(Mux *mux);
16 static int drawnbrecv(Mux *mux, void**);
17 static int drawsend(Mux *mux, void *vmsg);
18 static int drawsettag(Mux *mux, void *vmsg, uint tag);
19 static int canreadfd(int);
22 _displayconnect(Display *d)
26 fmtinstall('W', drawfcallfmt);
27 fmtinstall('H', encodefmt);
41 /* execl("strace", "strace", "-o", "drawsrv.out", "drawsrv", nil); */
43 * The argv0 has no meaning to devdraw.
44 * Pass it along only so that the various
45 * devdraws in psu -a can be distinguished.
46 * The NOLIBTHREADDAEMONIZE keeps devdraw from
47 * forking before threadmain. OS X hates it when
50 * If client didn't use ARGBEGIN, argv0 == nil.
51 * Can't send nil through because OS X expects
52 * argv[0] to be non-nil. Also, OS X apparently
53 * expects argv[0] to be a valid executable name,
54 * so "(argv0)" is not okay. Use "devdraw"
57 putenv("NOLIBTHREADDAEMONIZE", "1");
58 devdraw = getenv("DEVDRAW");
63 execl(devdraw, argv0, argv0, "(devdraw)", nil);
64 sysfatal("exec devdraw: %r");
72 _displaymux(Display *d)
74 if((d->mux = mallocz(sizeof(*d->mux), 1)) == nil)
79 d->mux->send = drawsend;
80 d->mux->recv = drawrecv;
81 d->mux->nbrecv = drawnbrecv;
82 d->mux->gettag = drawgettag;
83 d->mux->settag = drawsettag;
91 drawsend(Mux *mux, void *vmsg)
100 return write(d->srvfd, msg, n);
104 _drawrecv(Mux *mux, int canblock, void **vp)
112 if(!canblock && !canreadfd(d->srvfd))
114 if((n=readn(d->srvfd, buf, 4)) != 4)
119 fprint(2, "out of memory allocating %d in drawrecv\n", n);
123 if(readn(d->srvfd, p+4, n-4) != n-4){
135 _drawrecv(mux, 1, &p);
140 drawnbrecv(Mux *mux, void **vp)
142 return _drawrecv(mux, 0, vp);
146 drawgettag(Mux *mux, void *vmsg)
156 drawsettag(Mux *mux, void *vmsg, uint tag)
167 displayrpc(Display *d, Wsysmsg *tx, Wsysmsg *rx, void **freep)
180 fprint(2, "<- %W\n", tx);
181 nn = convW2M(tx, tpkt, n);
184 werrstr("drawclient: sizeW2M convW2M mismatch");
189 * This is the only point where we might reschedule.
190 * Muxrpc might need to acquire d->mux->lk, which could
191 * be held by some other proc (e.g., the one reading from
192 * the keyboard via Trdkbd messages). If we need to wait
193 * for the lock, don't let other threads from this proc
194 * run. This keeps up the appearance that writes to /dev/draw
195 * don't cause rescheduling. If you *do* allow rescheduling
196 * here, then flushimage(display, 1) happening in two different
197 * threads in the same proc can cause a buffer of commands
198 * to be written out twice, leading to interesting results
201 * Threadpin and threadunpin were added to the thread library
202 * to solve exactly this problem. Be careful! They are dangerous.
204 * _pin and _unpin are aliases for threadpin and threadunpin
205 * in a threaded program and are no-ops in unthreaded programs.
208 rpkt = muxrpc(d->mux, tpkt);
212 werrstr("muxrpc: %r");
215 GET((uchar*)rpkt, n);
216 nn = convM2W(rpkt, n, rx);
219 werrstr("drawclient: convM2W packet size mismatch %d %d %.*H", n, nn, n, rpkt);
224 fprint(2, "-> %W\n", rx);
225 if(rx->type == Rerror){
226 werrstr("%s", rx->error);
230 if(rx->type != tx->type+1){
231 werrstr("packet type mismatch -- tx %d rx %d",
244 _displayinit(Display *d, char *label, char *winsize)
250 tx.winsize = winsize;
251 return displayrpc(d, &tx, &rx, nil);
255 _displayrdmouse(Display *d, Mouse *m, int *resized)
260 if(displayrpc(d, &tx, &rx, nil) < 0)
263 *resized = rx.resized;
268 _displayrdkbd(Display *d, Rune *r)
273 if(displayrpc(d, &tx, &rx, nil) < 0)
280 _displaymoveto(Display *d, Point p)
286 return displayrpc(d, &tx, &rx, nil);
290 _displaycursor(Display *d, Cursor *c)
296 memset(&tx.cursor, 0, sizeof tx.cursor);
302 return displayrpc(d, &tx, &rx, nil);
306 _displaybouncemouse(Display *d, Mouse *m)
310 tx.type = Tbouncemouse;
312 return displayrpc(d, &tx, &rx, nil);
316 _displaylabel(Display *d, char *label)
322 return displayrpc(d, &tx, &rx, nil);
326 _displayrdsnarf(Display *d)
333 if(displayrpc(d, &tx, &rx, &p) < 0)
335 s = strdup(rx.snarf);
341 _displaywrsnarf(Display *d, char *snarf)
347 return displayrpc(d, &tx, &rx, nil);
351 _displayrddraw(Display *d, void *v, int n)
358 if(displayrpc(d, &tx, &rx, &p) < 0)
360 memmove(v, rx.data, rx.count);
366 _displaywrdraw(Display *d, void *v, int n)
373 if(displayrpc(d, &tx, &rx, nil) < 0)
379 _displaytop(Display *d)
384 return displayrpc(d, &tx, &rx, nil);
388 _displayresize(Display *d, Rectangle r)
394 return displayrpc(d, &tx, &rx, nil);
410 if(select(fd+1, &rs, &ws, &xs, &tv) < 0)
412 if(FD_ISSET(fd, &rs) || FD_ISSET(fd, &xs))