From b3efcdbf5950a4b5bd43a83d3c7afe984e3238d7 Mon Sep 17 00:00:00 2001 From: rsc Date: Mon, 27 Dec 2004 19:13:15 +0000 Subject: change to use new thread library --- src/libplumb/thread.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/libplumb') diff --git a/src/libplumb/thread.c b/src/libplumb/thread.c index 5b375257..4698899e 100644 --- a/src/libplumb/thread.c +++ b/src/libplumb/thread.c @@ -6,7 +6,7 @@ #include "plumb.h" Plumbmsg* -threadplumbrecv(int fd) +ioplumbrecv(Ioproc *io, int fd) { char *buf; Plumbmsg *m; @@ -15,7 +15,7 @@ threadplumbrecv(int fd) buf = malloc(8192); if(buf == nil) return nil; - n = threadread(fd, buf, 8192); + n = ioread(io, fd, buf, 8192); m = nil; if(n > 0){ m = plumbunpackpartial(buf, n, &more); @@ -24,7 +24,7 @@ threadplumbrecv(int fd) buf = realloc(buf, n+more); if(buf == nil) return nil; - if(threadreadn(fd, buf+n, more) == more) + if(ioreadn(io, fd, buf+n, more) == more) m = plumbunpackpartial(buf, n+more, nil); } } -- cgit v1.2.3