Commit 733e7e90 authored by Vincent Pelletier's avatar Vincent Pelletier

Remove unused parameter.

Update callers.


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@751 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent afbd38a2
...@@ -402,7 +402,7 @@ class PrimaryAnswersHandler(PrimaryBaseHandler): ...@@ -402,7 +402,7 @@ class PrimaryAnswersHandler(PrimaryBaseHandler):
class StorageBaseHandler(BaseHandler): class StorageBaseHandler(BaseHandler):
def _dealWithStorageFailure(self, conn, node, state): def _dealWithStorageFailure(self, conn, node):
app = self.app app = self.app
# Remove from pool connection # Remove from pool connection
...@@ -423,17 +423,17 @@ class StorageBaseHandler(BaseHandler): ...@@ -423,17 +423,17 @@ class StorageBaseHandler(BaseHandler):
def connectionClosed(self, conn): def connectionClosed(self, conn):
node = self.app.nm.getNodeByServer(conn.getAddress()) node = self.app.nm.getNodeByServer(conn.getAddress())
logging.info("connection to storage node %s closed", node.getServer()) logging.info("connection to storage node %s closed", node.getServer())
self._dealWithStorageFailure(conn, node, TEMPORARILY_DOWN_STATE) self._dealWithStorageFailure(conn, node)
super(StorageBaseHandler, self).connectionClosed(conn) super(StorageBaseHandler, self).connectionClosed(conn)
def timeoutExpired(self, conn): def timeoutExpired(self, conn):
node = self.app.nm.getNodeByServer(conn.getAddress()) node = self.app.nm.getNodeByServer(conn.getAddress())
self._dealWithStorageFailure(conn, node, TEMPORARILY_DOWN_STATE) self._dealWithStorageFailure(conn, node)
super(StorageBaseHandler, self).timeoutExpired(conn) super(StorageBaseHandler, self).timeoutExpired(conn)
def peerBroken(self, conn): def peerBroken(self, conn):
node = self.app.nm.getNodeByServer(conn.getAddress()) node = self.app.nm.getNodeByServer(conn.getAddress())
self._dealWithStorageFailure(conn, node, BROKEN_STATE) self._dealWithStorageFailure(conn, node)
super(StorageBaseHandler, self).peerBroken(conn) super(StorageBaseHandler, self).peerBroken(conn)
...@@ -443,7 +443,7 @@ class StorageBootstrapHandler(StorageBaseHandler): ...@@ -443,7 +443,7 @@ class StorageBootstrapHandler(StorageBaseHandler):
def connectionFailed(self, conn): def connectionFailed(self, conn):
# Connection to a storage node failed # Connection to a storage node failed
node = self.app.nm.getNodeByServer(conn.getAddress()) node = self.app.nm.getNodeByServer(conn.getAddress())
self._dealWithStorageFailure(conn, node, TEMPORARILY_DOWN_STATE) self._dealWithStorageFailure(conn, node)
super(StorageBootstrapHandler, self).connectionFailed(conn) super(StorageBootstrapHandler, self).connectionFailed(conn)
def handleNotReady(self, conn, packet, message): def handleNotReady(self, conn, packet, message):
......
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