git: 9front

ref: 1ff9815b908d9be9bc852da8066ee4d888436f9f
dir: /sys/src/libthread/iocall.c/

#include <u.h>
#include <libc.h>
#include <thread.h>
#include "threadimpl.h"

long
iocall(Ioproc *io, long (*op)(va_list*), ...)
{
	Iocall r;

	r.op = op;
	va_start(r.arg, op);
	if(sendp(io->c, &r) < 0){
		werrstr("interrupted");
		return -1;
	}
	while(recv(io->creply, nil) < 0){
		if(io->ctl < 0)
			continue;
		if(canqlock(io)){
			if(++io->intr == 1)
				write(io->ctl, "interrupt", 9);
			qunlock(io);
		}
	}
	va_end(r.arg);
	if(r.ret < 0)
		errstr(r.err, sizeof r.err);
	return r.ret;
}