Commit d15eef7a authored by Grégory Wisniewski's avatar Grégory Wisniewski

Get a connection for a storage node only if it's known as RUNNING.


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@904 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent ed3cfda9
...@@ -26,7 +26,6 @@ from neo.client.mq import MQ ...@@ -26,7 +26,6 @@ from neo.client.mq import MQ
from neo.node import NodeManager, MasterNode, StorageNode from neo.node import NodeManager, MasterNode, StorageNode
from neo.connection import MTClientConnection from neo.connection import MTClientConnection
from neo import protocol from neo import protocol
from neo.protocol import DOWN_STATE, HIDDEN_STATE
from neo.client.handlers.master import PrimaryBootstrapHandler, \ from neo.client.handlers.master import PrimaryBootstrapHandler, \
PrimaryNotificationsHandler, PrimaryAnswersHandler PrimaryNotificationsHandler, PrimaryAnswersHandler
from neo.client.handlers.storage import StorageBootstrapHandler, \ from neo.client.handlers.storage import StorageBootstrapHandler, \
...@@ -146,7 +145,7 @@ class ConnectionPool(object): ...@@ -146,7 +145,7 @@ class ConnectionPool(object):
def getConnForNode(self, node): def getConnForNode(self, node):
"""Return a locked connection object to a given node """Return a locked connection object to a given node
If no connection exists, create a new one""" If no connection exists, create a new one"""
if node.getState() in (DOWN_STATE, HIDDEN_STATE): if node.getState() != protocol.RUNNING_STATE:
return None return None
uuid = node.getUUID() uuid = node.getUUID()
self.connection_lock_acquire() self.connection_lock_acquire()
......
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