Commit 9e15dffe authored by Grégory Wisniewski's avatar Grégory Wisniewski

Ignore non-running storage nodes

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2602 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 8451a462
...@@ -151,6 +151,7 @@ class ConnectionPool(object): ...@@ -151,6 +151,7 @@ class ConnectionPool(object):
getConnForNode = self.getConnForNode getConnForNode = self.getConnForNode
while cell_list: while cell_list:
new_cell_list = [] new_cell_list = []
cell_list = [c for c in cell_list if c.getNode().isRunning()]
shuffle(cell_list) shuffle(cell_list)
cell_list.sort(key=self.getCellSortKey) cell_list.sort(key=self.getCellSortKey)
for cell in cell_list: for cell in cell_list:
...@@ -158,7 +159,7 @@ class ConnectionPool(object): ...@@ -158,7 +159,7 @@ class ConnectionPool(object):
conn = getConnForNode(node) conn = getConnForNode(node)
if conn is not None: if conn is not None:
yield (node, conn) yield (node, conn)
else: elif node.isRunning():
new_cell_list.append(cell) new_cell_list.append(cell)
cell_list = new_cell_list cell_list = new_cell_list
if new_cell_list: if new_cell_list:
......
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