1 76193d7c 2003-09-30 devnull #include "threadimpl.h"
4 76193d7c 2003-09-30 devnull iocall(Ioproc *io, long (*op)(va_list*), ...)
6 d51419bf 2004-02-09 devnull char e[ERRMAX];
7 76193d7c 2003-09-30 devnull int ret, inted;
8 76193d7c 2003-09-30 devnull Ioproc *msg;
10 76193d7c 2003-09-30 devnull if(send(io->c, &io) == -1){
11 76193d7c 2003-09-30 devnull werrstr("interrupted");
12 76193d7c 2003-09-30 devnull return -1;
14 76193d7c 2003-09-30 devnull assert(!io->inuse);
15 76193d7c 2003-09-30 devnull io->inuse = 1;
16 76193d7c 2003-09-30 devnull io->op = op;
17 76193d7c 2003-09-30 devnull va_start(io->arg, op);
18 76193d7c 2003-09-30 devnull msg = io;
19 76193d7c 2003-09-30 devnull inted = 0;
20 76193d7c 2003-09-30 devnull while(send(io->creply, &msg) == -1){
21 76193d7c 2003-09-30 devnull msg = nil;
22 76193d7c 2003-09-30 devnull inted = 1;
24 76193d7c 2003-09-30 devnull if(inted){
25 76193d7c 2003-09-30 devnull werrstr("interrupted");
26 76193d7c 2003-09-30 devnull return -1;
30 76193d7c 2003-09-30 devnull * If we get interrupted, we have stick around so that
31 76193d7c 2003-09-30 devnull * the IO proc has someone to talk to. Send it an interrupt
32 76193d7c 2003-09-30 devnull * and try again.
34 76193d7c 2003-09-30 devnull inted = 0;
35 76193d7c 2003-09-30 devnull while(recv(io->creply, nil) == -1){
36 76193d7c 2003-09-30 devnull inted = 1;
37 76193d7c 2003-09-30 devnull iointerrupt(io);
39 76193d7c 2003-09-30 devnull USED(inted);
40 76193d7c 2003-09-30 devnull va_end(io->arg);
41 76193d7c 2003-09-30 devnull ret = io->ret;
42 76193d7c 2003-09-30 devnull if(ret < 0)
43 d51419bf 2004-02-09 devnull strecpy(e, e+sizeof e, io->err);
44 76193d7c 2003-09-30 devnull io->inuse = 0;
46 76193d7c 2003-09-30 devnull /* release resources */
47 76193d7c 2003-09-30 devnull while(send(io->creply, &io) == -1)
49 d51419bf 2004-02-09 devnull if(ret < 0)
50 d51419bf 2004-02-09 devnull errstr(e, sizeof e);
51 76193d7c 2003-09-30 devnull return ret;