projects
/
IRC.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
a98e3fa
)
fix accounting of bytes received
author
bdemsky
<bdemsky>
Sat, 26 Sep 2009 09:07:50 +0000
(09:07 +0000)
committer
bdemsky
<bdemsky>
Sat, 26 Sep 2009 09:07:50 +0000
(09:07 +0000)
Robust/src/Runtime/DSTM/interface/trans.c
patch
|
blob
|
history
diff --git
a/Robust/src/Runtime/DSTM/interface/trans.c
b/Robust/src/Runtime/DSTM/interface/trans.c
index 8843d829307916f42ace6fcdd134e1e27d4885ce..81cd2081cbd95bbafb5a6bb20e2250255f0bc799 100644
(file)
--- a/
Robust/src/Runtime/DSTM/interface/trans.c
+++ b/
Robust/src/Runtime/DSTM/interface/trans.c
@@
-170,6
+170,7
@@
void recv_data_buf(int fd, struct readstruct * readbuffer, void *buffer, int buf
perror("recv");
exit(0);
}
+ bytesRecv+=numbytes;
buflen-=numbytes;
readbuffer->head+=numbytes;
maxbuf-=numbytes;
@@
-210,6
+211,7
@@
int recv_data_errorcode_buf(int fd, struct readstruct * readbuffer, void *buffer
perror("recvbuf");
return -1;
}
+ bytesRecv+=numbytes;
buflen-=numbytes;
readbuffer->head+=numbytes;
maxbuf-=numbytes;
@@
-248,6
+250,7
@@
int recv_data_errorcode(int fd, void *buf, int buflen) {
perror("recv");
return -1;
}
+ bytesRecv+=numbytes;
buffer += numbytes;
size -= numbytes;
}