diff --git a/src/libthread/read9pmsg.c b/src/libthread/read9pmsg.c new file mode 100644 index 00000000..652fc82f --- /dev/null +++ b/src/libthread/read9pmsg.c @@ -0,0 +1,32 @@ +#include +#include +#include +#include + +int +threadread9pmsg(int fd, void *abuf, uint n) +{ + int m, len; + uchar *buf; + + buf = abuf; + + /* read count */ + m = threadreadn(fd, buf, BIT32SZ); + if(m != BIT32SZ){ + if(m < 0) + return -1; + return 0; + } + + len = GBIT32(buf); + if(len <= BIT32SZ || len > n){ + werrstr("bad length in 9P2000 message header"); + return -1; + } + len -= BIT32SZ; + m = threadreadn(fd, buf+BIT32SZ, len); + if(m < len) + return 0; + return BIT32SZ+m; +}