diff options
| author | rsc <devnull@localhost> | 2004-05-23 00:59:17 +0000 |
|---|---|---|
| committer | rsc <devnull@localhost> | 2004-05-23 00:59:17 +0000 |
| commit | a09e80f9c414ffc815641d49836be3a2a6a07800 (patch) | |
| tree | 0854a21767989f10d109db6949aa3861e32a579d /src/libventi/send.c | |
| parent | 7e0e6522e576bc35b55a7182c23fb752cc1ec636 (diff) | |
| download | plan9port-a09e80f9c414ffc815641d49836be3a2a6a07800.tar.gz plan9port-a09e80f9c414ffc815641d49836be3a2a6a07800.tar.bz2 plan9port-a09e80f9c414ffc815641d49836be3a2a6a07800.zip | |
various debugging
Diffstat (limited to 'src/libventi/send.c')
| -rw-r--r-- | src/libventi/send.c | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/src/libventi/send.c b/src/libventi/send.c index a72a6c23..fd6fa57a 100644 --- a/src/libventi/send.c +++ b/src/libventi/send.c @@ -59,7 +59,9 @@ _vtrecv(VtConn *z) while(size < 2) { b = packettrailer(p, MaxFragSize); assert(b != nil); + if(0) fprint(2, "%d read hdr\n", getpid()); n = read(z->infd, b, MaxFragSize); + if(0) fprint(2, "%d got %d (%r)\n", getpid(), n); if(n <= 0) goto Err; size += n; @@ -72,13 +74,18 @@ _vtrecv(VtConn *z) size -= 2; while(size < len) { - n = len - size; - if(n > MaxFragSize) + // n = len - size; + // if(n > MaxFragSize) n = MaxFragSize; b = packettrailer(p, n); - if(readn(z->infd, b, n) != n) + if(0) fprint(2, "%d read body %d\n", getpid(), n); + n = read(z->infd, b, n); + if(0) fprint(2, "%d got %d (%r)\n", getpid(), n); + if(n > 0) + size += n; + packettrim(p, 0, size); + if(n <= 0) goto Err; - size += n; } p = packetsplit(p, len); return p; |