From a5fc83ef63de267e84abe014510041dbda7a2da9 Mon Sep 17 00:00:00 2001
From: Jeremy Fincher <jemfinch@users.sourceforge.net>
Date: Thu, 3 Apr 2003 06:56:22 +0000
Subject: [PATCH] Finally fixed looping bug

---
 src/asyncoreDrivers.py | 32 ++++++++++++++++++--------------
 1 file changed, 18 insertions(+), 14 deletions(-)

diff --git a/src/asyncoreDrivers.py b/src/asyncoreDrivers.py
index f8a5e8dd4..ba56ec126 100644
--- a/src/asyncoreDrivers.py
+++ b/src/asyncoreDrivers.py
@@ -67,7 +67,21 @@ class AsyncoreDriver(asynchat.async_chat, object):
         self.buffer = ''
         self.set_terminator('\n')
         self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
-        self.connect(self.server)
+        try:
+            self.connect(self.server)
+        except:
+            debug.recoverableException()
+            self.scheduleReconnect()
+            self.close()
+
+    def scheduleReconnect(self):
+        if self.reconnect:
+            def makeNewDriver():
+                self.irc.reset()
+                driver = self.__class__(self.server, reconnect=self.reconnect)
+                driver.irc = self.irc
+                driver.irc.driver = driver
+            schedule.addEvent(makeNewDriver, time.time() + 60)
 
     def writable(self):
         #debug.methodNamePrintf(self, 'writable')
@@ -83,6 +97,8 @@ class AsyncoreDriver(asynchat.async_chat, object):
 
     def handle_error(self):
         debug.recoverableException()
+        self.scheduleReconnect()
+        self.close()
 
     def collect_incoming_data(self, s):
         #debug.methodNamePrintf(self, 'collect_incoming_data')
@@ -109,19 +125,7 @@ class AsyncoreDriver(asynchat.async_chat, object):
 
     def handle_close(self):
         #debug.methodNamePrintf(self, 'handle_close')
-        if self.reconnect:
-            #debug.printf('Yes, reconnect.')
-            def makeNewDriver():
-                #debug.printf('Called makeNewDriver')
-                self.irc.reset()
-                driver = self.__class__(self.server, reconnect=self.reconnect)
-                driver.irc = self.irc
-                driver.irc.driver = driver
-            schedule.addEvent(makeNewDriver, time.time() + 60)
-        self.die()
-
-    def die(self):
-        #debug.methodNamePrintf(self, 'die')
+        self.scheduleReconnect()
         self.close()