1 /* Copyright (c) 2006 Russ Cox */
4 #include <sys/select.h>
12 extern Mouse _drawmouse;
13 int chattydrawclient = 0;
15 static int drawgettag(Mux *mux, void *vmsg);
16 static void* drawrecv(Mux *mux);
17 static int drawnbrecv(Mux *mux, void**);
18 static int drawsend(Mux *mux, void *vmsg);
19 static int drawsettag(Mux *mux, void *vmsg, uint tag);
20 static int canreadfd(int);
23 _displayconnect(Display *d)
27 fmtinstall('W', drawfcallfmt);
28 fmtinstall('H', encodefmt);
42 /* execl("strace", "strace", "-o", "drawsrv.out", "drawsrv", nil); */
44 * The argv0 has no meaning to devdraw.
45 * Pass it along only so that the various
46 * devdraws in psu -a can be distinguished.
47 * The NOLIBTHREADDAEMONIZE keeps devdraw from
48 * forking before threadmain. OS X hates it when
51 * If client didn't use ARGBEGIN, argv0 == nil.
52 * Can't send nil through because OS X expects
53 * argv[0] to be non-nil. Also, OS X apparently
54 * expects argv[0] to be a valid executable name,
55 * so "(argv0)" is not okay. Use "devdraw"
58 putenv("NOLIBTHREADDAEMONIZE", "1");
59 devdraw = getenv("DEVDRAW");
64 execl(devdraw, argv0, argv0, "(devdraw)", nil);
65 sysfatal("exec devdraw: %r");
73 _displaymux(Display *d)
75 if((d->mux = mallocz(sizeof(*d->mux), 1)) == nil)
80 d->mux->send = drawsend;
81 d->mux->recv = drawrecv;
82 d->mux->nbrecv = drawnbrecv;
83 d->mux->gettag = drawgettag;
84 d->mux->settag = drawsettag;
92 drawsend(Mux *mux, void *vmsg)
101 return write(d->srvfd, msg, n);
105 _drawrecv(Mux *mux, int canblock, void **vp)
113 if(!canblock && !canreadfd(d->srvfd))
115 if((n=readn(d->srvfd, buf, 4)) != 4)
120 fprint(2, "out of memory allocating %d in drawrecv\n", n);
124 if(readn(d->srvfd, p+4, n-4) != n-4){
136 _drawrecv(mux, 1, &p);
141 drawnbrecv(Mux *mux, void **vp)
143 return _drawrecv(mux, 0, vp);
147 drawgettag(Mux *mux, void *vmsg)
157 drawsettag(Mux *mux, void *vmsg, uint tag)
168 displayrpc(Display *d, Wsysmsg *tx, Wsysmsg *rx, void **freep)
181 fprint(2, "<- %W\n", tx);
182 nn = convW2M(tx, tpkt, n);
185 werrstr("drawclient: sizeW2M convW2M mismatch");
190 * This is the only point where we might reschedule.
191 * Muxrpc might need to acquire d->mux->lk, which could
192 * be held by some other proc (e.g., the one reading from
193 * the keyboard via Trdkbd messages). If we need to wait
194 * for the lock, don't let other threads from this proc
195 * run. This keeps up the appearance that writes to /dev/draw
196 * don't cause rescheduling. If you *do* allow rescheduling
197 * here, then flushimage(display, 1) happening in two different
198 * threads in the same proc can cause a buffer of commands
199 * to be written out twice, leading to interesting results
202 * Threadpin and threadunpin were added to the thread library
203 * to solve exactly this problem. Be careful! They are dangerous.
205 * _pin and _unpin are aliases for threadpin and threadunpin
206 * in a threaded program and are no-ops in unthreaded programs.
209 rpkt = muxrpc(d->mux, tpkt);
213 werrstr("muxrpc: %r");
216 GET((uchar*)rpkt, n);
217 nn = convM2W(rpkt, n, rx);
220 werrstr("drawclient: convM2W packet size mismatch %d %d %.*H", n, nn, n, rpkt);
225 fprint(2, "-> %W\n", rx);
226 if(rx->type == Rerror){
227 werrstr("%s", rx->error);
231 if(rx->type != tx->type+1){
232 werrstr("packet type mismatch -- tx %d rx %d",
245 _displayinit(Display *d, char *label, char *winsize)
251 tx.winsize = winsize;
252 return displayrpc(d, &tx, &rx, nil);
256 _displayrdmouse(Display *d, Mouse *m, int *resized)
261 if(displayrpc(d, &tx, &rx, nil) < 0)
263 _drawmouse = rx.mouse;
265 *resized = rx.resized;
270 _displayrdkbd(Display *d, Rune *r)
275 if(displayrpc(d, &tx, &rx, nil) < 0)
282 _displaymoveto(Display *d, Point p)
288 if(displayrpc(d, &tx, &rx, nil) < 0)
291 return flushimage(d, 1);
295 _displaycursor(Display *d, Cursor *c)
301 memset(&tx.cursor, 0, sizeof tx.cursor);
307 return displayrpc(d, &tx, &rx, nil);
311 _displaybouncemouse(Display *d, Mouse *m)
315 tx.type = Tbouncemouse;
317 return displayrpc(d, &tx, &rx, nil);
321 _displaylabel(Display *d, char *label)
327 return displayrpc(d, &tx, &rx, nil);
331 _displayrdsnarf(Display *d)
338 if(displayrpc(d, &tx, &rx, &p) < 0)
340 s = strdup(rx.snarf);
346 _displaywrsnarf(Display *d, char *snarf)
352 return displayrpc(d, &tx, &rx, nil);
356 _displayrddraw(Display *d, void *v, int n)
363 if(displayrpc(d, &tx, &rx, &p) < 0)
365 memmove(v, rx.data, rx.count);
371 _displaywrdraw(Display *d, void *v, int n)
378 if(displayrpc(d, &tx, &rx, nil) < 0)
384 _displaytop(Display *d)
389 return displayrpc(d, &tx, &rx, nil);
393 _displayresize(Display *d, Rectangle r)
399 return displayrpc(d, &tx, &rx, nil);
415 if(select(fd+1, &rs, &ws, &xs, &tv) < 0)
417 if(FD_ISSET(fd, &rs) || FD_ISSET(fd, &xs))