Commit 6cca2327 authored by Vincent Pelletier's avatar Vincent Pelletier

Close last replication connection when done.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2258 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 8d420adf
...@@ -232,6 +232,9 @@ class Replicator(object): ...@@ -232,6 +232,9 @@ class Replicator(object):
except KeyError: except KeyError:
pass pass
self.current_partition = None self.current_partition = None
if not self.pending():
self.current_connection.close()
self.current_connection = None
def act(self): def act(self):
# If the new partition list is not empty, I must ask a critical # If the new partition list is not empty, I must ask a critical
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment