Commit 77b3ea88 authored by Aurel's avatar Aurel

in all cases of failure, set primary master node value to -1 if we are

looking for a new one, thus client try to connect to other master
nodes defined
check connection is not None before trying to retrieving its uuid


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@230 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 16a7b5d4
...@@ -74,7 +74,7 @@ class ClientEventHandler(EventHandler): ...@@ -74,7 +74,7 @@ class ClientEventHandler(EventHandler):
conn.addPacket(p) conn.addPacket(p)
finally: finally:
conn.unlock() conn.unlock()
def connectionFailed(self, conn): def connectionFailed(self, conn):
app = self.app app = self.app
uuid = conn.getUUID() uuid = conn.getUUID()
...@@ -98,6 +98,9 @@ class ClientEventHandler(EventHandler): ...@@ -98,6 +98,9 @@ class ClientEventHandler(EventHandler):
def connectionClosed(self, conn): def connectionClosed(self, conn):
uuid = conn.getUUID() uuid = conn.getUUID()
app = self.app app = self.app
if app.primary_master_node is None:
# Failed to connect to a master node
app.primary_master_node = -1
if app.master_conn is not None and uuid == app.master_conn.getUUID(): if app.master_conn is not None and uuid == app.master_conn.getUUID():
logging.critical("connection to primary master node closed") logging.critical("connection to primary master node closed")
# Close connection # Close connection
...@@ -119,7 +122,10 @@ class ClientEventHandler(EventHandler): ...@@ -119,7 +122,10 @@ class ClientEventHandler(EventHandler):
def timeoutExpired(self, conn): def timeoutExpired(self, conn):
uuid = conn.getUUID() uuid = conn.getUUID()
app = self.app app = self.app
if uuid == app.primary_master_node.getUUID(): if app.primary_master_node is None:
# Failed to connect to a master node
app.primary_master_node = -1
if app.master_conn is not None and uuid == app.primary_master_node.getUUID():
logging.critical("connection timeout to primary master node expired") logging.critical("connection timeout to primary master node expired")
if self.dispatcher.connecting_to_master_node == 0: if self.dispatcher.connecting_to_master_node == 0:
logging.critical("trying reconnection to master node...") logging.critical("trying reconnection to master node...")
...@@ -136,7 +142,10 @@ class ClientEventHandler(EventHandler): ...@@ -136,7 +142,10 @@ class ClientEventHandler(EventHandler):
def peerBroken(self, conn): def peerBroken(self, conn):
uuid = conn.getUUID() uuid = conn.getUUID()
app = self.app app = self.app
if uuid == app.primary_master_node.getUUID(): if app.primary_master_node is None:
# Failed to connect to a master node
app.primary_master_node = -1
if app.master_conn is not None and uuid == app.primary_master_node.getUUID():
logging.critical("primary master node is broken") logging.critical("primary master node is broken")
if self.dispatcher.connecting_to_master_node == 0: if self.dispatcher.connecting_to_master_node == 0:
logging.critical("trying reconnection to master node...") logging.critical("trying reconnection to master node...")
......
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