1 76193d7c 2003-09-30 devnull #include "threadimpl.h"
4 76193d7c 2003-09-30 devnull iocall(Ioproc *io, long (*op)(va_list*), ...)
6 76193d7c 2003-09-30 devnull int ret, inted;
7 76193d7c 2003-09-30 devnull Ioproc *msg;
9 76193d7c 2003-09-30 devnull if(send(io->c, &io) == -1){
10 76193d7c 2003-09-30 devnull werrstr("interrupted");
11 76193d7c 2003-09-30 devnull return -1;
13 76193d7c 2003-09-30 devnull assert(!io->inuse);
14 76193d7c 2003-09-30 devnull io->inuse = 1;
15 76193d7c 2003-09-30 devnull io->op = op;
16 76193d7c 2003-09-30 devnull va_start(io->arg, op);
17 76193d7c 2003-09-30 devnull msg = io;
18 76193d7c 2003-09-30 devnull inted = 0;
19 76193d7c 2003-09-30 devnull while(send(io->creply, &msg) == -1){
20 76193d7c 2003-09-30 devnull msg = nil;
21 76193d7c 2003-09-30 devnull inted = 1;
23 76193d7c 2003-09-30 devnull if(inted){
24 76193d7c 2003-09-30 devnull werrstr("interrupted");
25 76193d7c 2003-09-30 devnull return -1;
29 76193d7c 2003-09-30 devnull * If we get interrupted, we have stick around so that
30 76193d7c 2003-09-30 devnull * the IO proc has someone to talk to. Send it an interrupt
31 76193d7c 2003-09-30 devnull * and try again.
33 76193d7c 2003-09-30 devnull inted = 0;
34 76193d7c 2003-09-30 devnull while(recv(io->creply, nil) == -1){
35 76193d7c 2003-09-30 devnull inted = 1;
36 76193d7c 2003-09-30 devnull iointerrupt(io);
38 76193d7c 2003-09-30 devnull USED(inted);
39 76193d7c 2003-09-30 devnull va_end(io->arg);
40 76193d7c 2003-09-30 devnull ret = io->ret;
41 76193d7c 2003-09-30 devnull if(ret < 0)
42 76193d7c 2003-09-30 devnull errstr(io->err, sizeof io->err);
43 76193d7c 2003-09-30 devnull io->inuse = 0;
45 76193d7c 2003-09-30 devnull /* release resources */
46 76193d7c 2003-09-30 devnull while(send(io->creply, &io) == -1)
48 76193d7c 2003-09-30 devnull return ret;