From 044cfbb57caf3f24dba7c5ab859e0476f6c17228 Mon Sep 17 00:00:00 2001
From: wessels <>
Date: Tue, 12 Jan 1999 02:40:29 +0000
Subject: [PATCH] clear current_hdl_fd after each handler call

---
 src/comm_select.cc | 22 +++++++++-------------
 1 file changed, 9 insertions(+), 13 deletions(-)

diff --git a/src/comm_select.cc b/src/comm_select.cc
index 4e9766ec0c..e06c9ca0e7 100644
--- a/src/comm_select.cc
+++ b/src/comm_select.cc
@@ -1,6 +1,6 @@
 
 /*
- * $Id: comm_select.cc,v 1.24 1999/01/08 21:12:09 wessels Exp $
+ * $Id: comm_select.cc,v 1.25 1999/01/11 19:40:29 wessels Exp $
  *
  * DEBUG: section 5     Socket Functions
  *
@@ -363,12 +363,11 @@ comm_poll(int msec)
 		if ((hdl = F->read_handler)) {
 		    F->read_handler = NULL;
 		    hdl(current_hdl_fd = fd, F->read_data);
+		    current_hdl_fd = -1;
 		    Counter.select_fds++;
 		}
-		if (F->flags.delayed_comm_close) {
-		    current_hdl_fd = -1;
+		if (F->flags.delayed_comm_close)
 		    comm_close(fd);
-		}
 		if (commCheckICPIncoming)
 		    comm_poll_icp_incoming();
 		if (commCheckHTTPIncoming)
@@ -379,12 +378,11 @@ comm_poll(int msec)
 		if ((hdl = F->write_handler)) {
 		    F->write_handler = NULL;
 		    hdl(current_hdl_fd = fd, F->write_data);
+		    current_hdl_fd = -1;
 		    Counter.select_fds++;
 		}
-		if (F->flags.delayed_comm_close) {
-		    current_hdl_fd = -1;
+		if (F->flags.delayed_comm_close)
 		    comm_close(fd);
-		}
 		if (commCheckICPIncoming)
 		    comm_poll_icp_incoming();
 		if (commCheckHTTPIncoming)
@@ -671,12 +669,11 @@ comm_select(int msec)
 		    F->read_handler = NULL;
 		    commUpdateReadBits(fd, NULL);
 		    hdl(current_hdl_fd = fd, F->read_data);
+		    current_hdl_fd = -1;
 		    Counter.select_fds++;
 		}
-		if (F->flags.delayed_comm_close) {
-		    current_hdl_fd = -1;
+		if (F->flags.delayed_comm_close)
 		    comm_close(fd);
-		}
 		if (commCheckICPIncoming)
 		    comm_select_icp_incoming();
 		if (commCheckHTTPIncoming)
@@ -714,12 +711,11 @@ comm_select(int msec)
 		    F->write_handler = NULL;
 		    commUpdateWriteBits(fd, NULL);
 		    hdl(current_hdl_fd = fd, F->write_data);
+		    current_hdl_fd = -1;
 		    Counter.select_fds++;
 		}
-		if (F->flags.delayed_comm_close) {
-		    current_hdl_fd = -1;
+		if (F->flags.delayed_comm_close)
 		    comm_close(fd);
-		}
 		if (commCheckICPIncoming)
 		    comm_select_icp_incoming();
 		if (commCheckHTTPIncoming)
-- 
2.47.3