---------------------
PatchSet 6246 
Date: 2004/07/24 12:50:27
Author: serassio
Branch: nt-2_5
Tag: (none) 
Log:
Added counters to awin32 async-io completetion pipe

Members: 
	src/fs/awin32/aiops.c:1.1.62.15->1.1.62.16 

Index: squid/src/fs/awin32/aiops.c
===================================================================
RCS file: /cvsroot/squid-sf//squid/src/fs/awin32/Attic/aiops.c,v
retrieving revision 1.1.62.15
retrieving revision 1.1.62.16
diff -u -r1.1.62.15 -r1.1.62.16
--- squid/src/fs/awin32/aiops.c	20 Jun 2004 20:28:48 -0000	1.1.62.15
+++ squid/src/fs/awin32/aiops.c	24 Jul 2004 12:50:27 -0000	1.1.62.16
@@ -1,5 +1,5 @@
 /*
- * $Id: aiops.c,v 1.1.62.15 2004/06/20 20:28:48 serassio Exp $
+ * $Id: aiops.c,v 1.1.62.16 2004/07/24 12:50:27 serassio Exp $
  *
  * DEBUG: section 43    AIOPS
  * AUTHOR: Stewart Forster <slf@connect.com.au>
@@ -533,8 +533,11 @@
 	    return 1;
 	}
 	if (!done_signalled) {
+            fde *F = &fd_table[done_fd];
+            int x;
 	    done_signalled = 1;
-	    FD_WRITE_METHOD(done_fd, "!", 1);
+            if ((x = FD_WRITE_METHOD(done_fd, "!", 1)) > 0)
+                F->bytes_written += x;
 	}
 	threadp->requests++;
 /* Relinquish the remainder of thread time slice to any other thread
@@ -984,7 +987,10 @@
     if (request == NULL && !polled) {
 	if (done_signalled) {
 	    char junk[256];
-	    FD_READ_METHOD(done_fd_read, junk, sizeof(junk));
+            fde *F = &fd_table[done_fd_read];
+            int x;
+            if ((x = FD_READ_METHOD(done_fd_read, junk, sizeof(junk))) > 0)
+                F->bytes_read += x;
 	    done_signalled = 0;
 	}
 	squidaio_poll_queues();