Commit 0ba8b64c authored by Grégory Wisniewski's avatar Grégory Wisniewski

When a node notification is received, update() on node manager is now called...

When a node notification is received, update() on node manager is now called and the logic is no more in the handler, so remove useless and false checks.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1414 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 32106471
...@@ -565,12 +565,10 @@ class ClientHandlerTests(NeoTestBase): ...@@ -565,12 +565,10 @@ class ClientHandlerTests(NeoTestBase):
NodeStates.RUNNING) NodeStates.RUNNING)
nm = self._testNotifyNodeInformation(test_node, getByUUID=None) nm = self._testNotifyNodeInformation(test_node, getByUUID=None)
# Check that two nodes got added (second is with INVALID_UUID) # Check that two nodes got added (second is with INVALID_UUID)
add_call_list = nm.mockGetNamedCalls('add') update_call_list = nm.mockGetNamedCalls('update')
self.assertEqual(len(add_call_list), 2) self.assertEqual(len(update_call_list), 1)
added_node = add_call_list[0].getParam(0) updated_node_list = update_call_list[0].getParam(0)
self.assertEquals(added_node.getUUID(), uuid) self.assertEquals(len(updated_node_list), 2)
added_node = add_call_list[1].getParam(0)
self.assertEquals(added_node.getUUID(), None)
def test_knownMasterNotifyNodeInformation(self): def test_knownMasterNotifyNodeInformation(self):
node = Mock({}) node = Mock({})
...@@ -580,23 +578,17 @@ class ClientHandlerTests(NeoTestBase): ...@@ -580,23 +578,17 @@ class ClientHandlerTests(NeoTestBase):
nm = self._testNotifyNodeInformation(test_node, getByAddress=node, nm = self._testNotifyNodeInformation(test_node, getByAddress=node,
getByUUID=node) getByUUID=node)
# Check that node got replaced # Check that node got replaced
add_call_list = nm.mockGetNamedCalls('add') update_call_list = nm.mockGetNamedCalls('update')
self.assertEquals(len(add_call_list), 1) self.assertEquals(len(update_call_list), 1)
remove_call_list = nm.mockGetNamedCalls('remove')
self.assertEquals(len(remove_call_list), 1)
# Check node state has been updated
setState_call_list = node.mockGetNamedCalls('setState')
self.assertEqual(len(setState_call_list), 1)
self.assertEqual(setState_call_list[0].getParam(0), test_node[4])
def test_unknownStorageNotifyNodeInformation(self): def test_unknownStorageNotifyNodeInformation(self):
test_node = (NodeTypes.STORAGE, ('127.0.0.1', 10010), self.getNewUUID(), test_node = (NodeTypes.STORAGE, ('127.0.0.1', 10010), self.getNewUUID(),
NodeStates.RUNNING) NodeStates.RUNNING)
nm = self._testNotifyNodeInformation(test_node, getByUUID=None) nm = self._testNotifyNodeInformation(test_node, getByUUID=None)
# Check that node got added # Check that node got added
add_call_list = nm.mockGetNamedCalls('add') update_call_list = nm.mockGetNamedCalls('update')
self.assertEqual(len(add_call_list), 1) self.assertEqual(len(update_call_list), 1)
added_node = add_call_list[0].getParam(0) updateed_node = update_call_list[0].getParam(0)
# XXX: this test does not check that node state got updated. # XXX: this test does not check that node state got updated.
# This is because there would be no way to tell the difference between # This is because there would be no way to tell the difference between
# an updated state and default state if they are the same value (we # an updated state and default state if they are the same value (we
...@@ -609,13 +601,8 @@ class ClientHandlerTests(NeoTestBase): ...@@ -609,13 +601,8 @@ class ClientHandlerTests(NeoTestBase):
NodeStates.RUNNING) NodeStates.RUNNING)
nm = self._testNotifyNodeInformation(test_node, getByUUID=node) nm = self._testNotifyNodeInformation(test_node, getByUUID=node)
# Check that node got replaced # Check that node got replaced
add_call_list = nm.mockGetNamedCalls('add') update_call_list = nm.mockGetNamedCalls('update')
self.assertEquals(len(add_call_list), 1) self.assertEquals(len(update_call_list), 1)
remove_call_list = nm.mockGetNamedCalls('remove')
self.assertEquals(len(remove_call_list), 1)
# Check node state has been updated
node = add_call_list[0].getParam(0)
self.assertEquals(node.getState(), test_node[4])
def test_initialNotifyPartitionChanges(self): def test_initialNotifyPartitionChanges(self):
class App: class App:
......
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