diff options
| author | rsc <devnull@localhost> | 2004-12-27 19:13:15 +0000 |
|---|---|---|
| committer | rsc <devnull@localhost> | 2004-12-27 19:13:15 +0000 |
| commit | b3efcdbf5950a4b5bd43a83d3c7afe984e3238d7 (patch) | |
| tree | 4229abf0c5a51525561be9b7582bd40c58155262 /src/libplumb | |
| parent | 1d011ae24253c07be37d9b765d68405df993ea32 (diff) | |
| download | plan9port-b3efcdbf5950a4b5bd43a83d3c7afe984e3238d7.tar.gz plan9port-b3efcdbf5950a4b5bd43a83d3c7afe984e3238d7.tar.bz2 plan9port-b3efcdbf5950a4b5bd43a83d3c7afe984e3238d7.zip | |
change to use new thread library
Diffstat (limited to 'src/libplumb')
| -rw-r--r-- | src/libplumb/thread.c | 6 |
1 files changed, 3 insertions, 3 deletions
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); } } |