plan9port

commit b3efcdbf5950a4b5bd43a83d3c7afe984e3238d7
parent 1d011ae24253c07be37d9b765d68405df993ea32
Author: rsc <devnull@localhost>
Date:   Mon, 27 Dec 2004 19:13:15 +0000

change to use new thread library

Diffstat:
M
src/libplumb/thread.c
 | 
6
+++---

1 file changed, 3 insertions(+), 3 deletions(-)
diff --git 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);
 		}
 	}