--- a/server/pool.py	Fri Feb 26 07:44:18 2010 +0100
+++ b/server/pool.py	Fri Feb 26 07:58:02 2010 +0100
@@ -109,6 +109,11 @@
         else:
             sources = (source,)
         for source in sources:
+            try:
+                # properly close existing connection if any
+                self.source_cnxs[source.uri][1].close()
+            except:
+                pass
             source.info('trying to reconnect')
             self.source_cnxs[source.uri] = (source, source.get_connection())
             self._cursors.pop(source.uri, None)