commloops delay pools updates

diff --git a/src/ssl.cc b/src/ssl.cc
index 6b88976b8c11740bdbf12b47615ec8a0f92a8e9d..19d263ab87b6f334f58be917d537a4c9b38ead63 100644 (file)
--- a/src/ssl.cc
+++ b/src/ssl.cc
@@ -1,6 +1,6 @@
 
 /*
- * $Id: ssl.cc,v 1.126 2002/10/14 08:16:59 robertc Exp $
+ * $Id: ssl.cc,v 1.127 2002/10/14 08:51:03 robertc Exp $
  *
  * DEBUG: section 26    Secure Sockets Layer Proxy
  * AUTHOR: Duane Wessels
@@ -138,7 +138,7 @@ sslReadServer(int fd, char *buf, size_t len, comm_err_t errcode, int xerrno, voi
     assert(fd == sslState->server.fd);
     errno = 0;
 #if DELAY_POOLS
-    read_sz = delayBytesWanted(sslState->delayId, 1, read_sz);
+    len = delayBytesWanted(sslState->delayId, 1, len);
 #endif
     /* Bail out early on COMM_ERR_CLOSING - close handlers will tidy up for us */
     if (errcode == COMM_ERR_CLOSING) {

diff --git a/src/tunnel.cc b/src/tunnel.cc
index d8f9a427b75e29bb89a0f639431ed3880c22fba8..33b3da22d47e4221acb734a55b8f5675ffce707e 100644 (file)
--- a/src/tunnel.cc
+++ b/src/tunnel.cc
@@ -1,6 +1,6 @@
 
 /*
- * $Id: tunnel.cc,v 1.126 2002/10/14 08:16:59 robertc Exp $
+ * $Id: tunnel.cc,v 1.127 2002/10/14 08:51:03 robertc Exp $
  *
  * DEBUG: section 26    Secure Sockets Layer Proxy
  * AUTHOR: Duane Wessels
@@ -138,7 +138,7 @@ sslReadServer(int fd, char *buf, size_t len, comm_err_t errcode, int xerrno, voi
     assert(fd == sslState->server.fd);
     errno = 0;
 #if DELAY_POOLS
-    read_sz = delayBytesWanted(sslState->delayId, 1, read_sz);
+    len = delayBytesWanted(sslState->delayId, 1, len);
 #endif
     /* Bail out early on COMM_ERR_CLOSING - close handlers will tidy up for us */
     if (errcode == COMM_ERR_CLOSING) {

diff --git a/src/wais.cc b/src/wais.cc
index 1791253c81694a561251a34221daf31942e25151..ff3c50d9c4ee4557f9384493c96d259577d5c61e 100644 (file)
--- a/src/wais.cc
+++ b/src/wais.cc
@@ -1,6 +1,6 @@
 
 /*
- * $Id: wais.cc,v 1.142 2002/10/14 08:16:59 robertc Exp $
+ * $Id: wais.cc,v 1.143 2002/10/14 08:52:23 robertc Exp $
  *
  * DEBUG: section 24    WAIS Relay
  * AUTHOR: Harvest Derived
@@ -113,7 +113,7 @@ waisReadReply(int fd, char *buf, size_t len, comm_err_t flag, int xerrno, void *
        kb_incr(&statCounter.server.other.kbytes_in, len);
     }
 #if DELAY_POOLS
-    read_sz = delayBytesWanted(delay_id, 1, read_sz);
+    read_sz = delayBytesWanted(delayId, 1, read_sz);
 #endif
     debug(24, 5) ("waisReadReply: FD %d read len:%d\n", fd, (int)len);
     if (flag == COMM_OK && len > 0) {