diff options
| author | forsyth <forsyth@vitanuova.com> | 2010-02-21 12:11:43 +0000 |
|---|---|---|
| committer | forsyth <forsyth@vitanuova.com> | 2010-02-21 12:11:43 +0000 |
| commit | c93eaa9a36d5071c19f42debcef978afd89ec994 (patch) | |
| tree | c3a3b8048c3ceaf7aa887922f754826c74ff1591 /appl/lib/styx.b | |
| parent | aee7f58dfcd519d45482e45ab1ce6026c846dc21 (diff) | |
20100221-1211
Diffstat (limited to 'appl/lib/styx.b')
| -rw-r--r-- | appl/lib/styx.b | 28 |
1 files changed, 7 insertions, 21 deletions
diff --git a/appl/lib/styx.b b/appl/lib/styx.b index f4534c6c..c862c9a1 100644 --- a/appl/lib/styx.b +++ b/appl/lib/styx.b @@ -571,7 +571,7 @@ Tmsg.read(fd: ref Sys->FD, msglim: int): ref Tmsg return nil; (nil, m) := Tmsg.unpack(msg); if(m == nil) - return ref Tmsg.Readerror(0, "bad Styx T-message format"); + return ref Tmsg.Readerror(0, "bad 9P T-message format"); return m; } @@ -843,7 +843,7 @@ Rmsg.read(fd: ref Sys->FD, msglim: int): ref Rmsg return nil; (nil, m) := Rmsg.unpack(msg); if(m == nil) - return ref Rmsg.Readerror(0, "bad Styx R-message format"); + return ref Rmsg.Readerror(0, "bad 9P R-message format"); return m; } @@ -863,7 +863,7 @@ readmsg(fd: ref Sys->FD, msglim: int): (array of byte, string) if(msglim <= 0) msglim = MAXRPC; sbuf := array[BIT32SZ] of byte; - if((n := readn(fd, sbuf, BIT32SZ)) != BIT32SZ){ + if((n := sys->readn(fd, sbuf, BIT32SZ)) != BIT32SZ){ if(n == 0) return (nil, nil); return (nil, sys->sprint("%r")); @@ -871,33 +871,19 @@ readmsg(fd: ref Sys->FD, msglim: int): (array of byte, string) ml := (int sbuf[1] << 8) | int sbuf[0]; ml |= ((int sbuf[3] << 8) | int sbuf[2]) << 16; if(ml <= BIT32SZ) - return (nil, "invalid Styx message size"); + return (nil, "invalid 9P message size"); if(ml > msglim) - return (nil, "Styx message longer than agreed"); + return (nil, "9P message longer than agreed"); buf := array[ml] of byte; buf[0:] = sbuf; - if((n = readn(fd, buf[BIT32SZ:], ml-BIT32SZ)) != ml-BIT32SZ){ + if((n = sys->readn(fd, buf[BIT32SZ:], ml-BIT32SZ)) != ml-BIT32SZ){ if(n == 0) - return (nil, "Styx message truncated"); + return (nil, "9P message truncated"); return (nil, sys->sprint("%r")); } return (buf, nil); } -readn(fd: ref Sys->FD, buf: array of byte, nb: int): int -{ - for(nr := 0; nr < nb;){ - n := sys->read(fd, buf[nr:], nb-nr); - if(n <= 0){ - if(nr == 0) - return n; - break; - } - nr += n; - } - return nr; -} - istmsg(f: array of byte): int { if(len f < H) |
