commit - e04d5bee6949d103a588659ee155f13f755cc2e2
commit + c3a72d77dc9e59e2498d68692feb098bf565e119
blob - /dev/null
blob + c31fdfb1972c7a6e6a928c1791194ed29f5e1e9e (mode 644)
--- /dev/null
+++ src/libplumb/thread.c
+#include <u.h>
+#include <libc.h>
+#include <thread.h>
+#include <fcall.h>
+#include <fs.h>
+#include "plumb.h"
+
+Plumbmsg*
+threadplumbrecv(int fd)
+{
+ char *buf;
+ Plumbmsg *m;
+ int n, more;
+
+ buf = malloc(8192);
+ if(buf == nil)
+ return nil;
+ n = threadread(fd, buf, 8192);
+ m = nil;
+ if(n > 0){
+ m = plumbunpackpartial(buf, n, &more);
+ if(m==nil && more>0){
+ /* we now know how many more bytes to read for complete message */
+ buf = realloc(buf, n+more);
+ if(buf == nil)
+ return nil;
+ if(threadreadn(fd, buf+n, more) == more)
+ m = plumbunpackpartial(buf, n+more, nil);
+ }
+ }
+ free(buf);
+ return m;
+}