branch | stable |
changeset 4710 | 4d9ad6a4f261 |
parent 4252 | 6c4f109c2b03 |
child 4721 | 8f63691ccb7f |
--- 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)