Commit 25c190e1 authored by Grégory Wisniewski's avatar Grégory Wisniewski

Fix accessor on next partition table ID.


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@672 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 6e9b9f15
...@@ -126,7 +126,7 @@ class ServiceEventHandler(MasterEventHandler): ...@@ -126,7 +126,7 @@ class ServiceEventHandler(MasterEventHandler):
app.nm.remove(node) app.nm.remove(node)
elif node.getNodeType() == STORAGE_NODE_TYPE: elif node.getNodeType() == STORAGE_NODE_TYPE:
cell_list = app.pt.dropNode(node) cell_list = app.pt.dropNode(node)
ptid = app.getNextPartitionTableID() ptid = app.pt.setNextID()
app.broadcastPartitionChanges(ptid, cell_list) app.broadcastPartitionChanges(ptid, cell_list)
if not app.pt.operational(): if not app.pt.operational():
# Catastrophic. # Catastrophic.
...@@ -262,7 +262,7 @@ class ServiceEventHandler(MasterEventHandler): ...@@ -262,7 +262,7 @@ class ServiceEventHandler(MasterEventHandler):
logging.info('added %s into a partition table (%d modifications)', logging.info('added %s into a partition table (%d modifications)',
dump(node.getUUID()), len(cell_list)) dump(node.getUUID()), len(cell_list))
if len(cell_list) != 0: if len(cell_list) != 0:
ptid = app.getNextPartitionTableID() ptid = app.pt.setNextID()
app.broadcastPartitionChanges(ptid, cell_list) app.broadcastPartitionChanges(ptid, cell_list)
p = protocol.acceptNodeIdentification(MASTER_NODE_TYPE, p = protocol.acceptNodeIdentification(MASTER_NODE_TYPE,
...@@ -367,12 +367,12 @@ class ServiceEventHandler(MasterEventHandler): ...@@ -367,12 +367,12 @@ class ServiceEventHandler(MasterEventHandler):
# this kind of message with these status except admin node # this kind of message with these status except admin node
cell_list = app.pt.dropNode(node) cell_list = app.pt.dropNode(node)
if len(cell_list) != 0: if len(cell_list) != 0:
ptid = app.getNextPartitionTableID() ptid = app.pt.setNextID()
app.broadcastPartitionChanges(ptid, cell_list) app.broadcastPartitionChanges(ptid, cell_list)
elif state == TEMPORARILY_DOWN_STATE: elif state == TEMPORARILY_DOWN_STATE:
cell_list = app.pt.outdate() cell_list = app.pt.outdate()
if len(cell_list) != 0: if len(cell_list) != 0:
ptid = app.getNextPartitionTableID() ptid = app.pt.setNextID()
app.broadcastPartitionChanges(ptid, cell_list) app.broadcastPartitionChanges(ptid, cell_list)
@decorators.identification_required @decorators.identification_required
...@@ -612,13 +612,13 @@ class ServiceEventHandler(MasterEventHandler): ...@@ -612,13 +612,13 @@ class ServiceEventHandler(MasterEventHandler):
# add to pt # add to pt
cell_list = app.pt.addNode(node) cell_list = app.pt.addNode(node)
if len(cell_list) != 0: if len(cell_list) != 0:
ptid = app.getNextPartitionTableID() ptid = app.pt.setNextID()
app.broadcastPartitionChanges(ptid, cell_list) app.broadcastPartitionChanges(ptid, cell_list)
else: else:
# outdate node in partition table # outdate node in partition table
cell_list = app.pt.outdate() cell_list = app.pt.outdate()
if len(cell_list) != 0: if len(cell_list) != 0:
ptid = app.getNextPartitionTableID() ptid = app.pt.setNextID()
app.broadcastPartitionChanges(ptid, cell_list) app.broadcastPartitionChanges(ptid, cell_list)
@decorators.identification_required @decorators.identification_required
...@@ -655,6 +655,6 @@ class ServiceEventHandler(MasterEventHandler): ...@@ -655,6 +655,6 @@ class ServiceEventHandler(MasterEventHandler):
if s_conn.getUUID() in uuid_set: if s_conn.getUUID() in uuid_set:
s_conn.notify(protocol.startOperation()) s_conn.notify(protocol.startOperation())
# broadcast the new partition table # broadcast the new partition table
app.broadcastPartitionChanges(app.getNextPartitionTableID(), cell_list) app.broadcastPartitionChanges(app.pt.setNextID(), cell_list)
conn.answer(protocol.answerNewNodes(list(uuid_set)), packet) conn.answer(protocol.answerNewNodes(list(uuid_set)), packet)
...@@ -78,7 +78,7 @@ class VerificationEventHandler(MasterEventHandler): ...@@ -78,7 +78,7 @@ class VerificationEventHandler(MasterEventHandler):
app.nm.remove(node) app.nm.remove(node)
elif node.getNodeType() == STORAGE_NODE_TYPE: elif node.getNodeType() == STORAGE_NODE_TYPE:
cell_list = app.pt.dropNode(node) cell_list = app.pt.dropNode(node)
ptid = app.getNextPartitionTableID() ptid = app.pt.setNextID()
app.broadcastPartitionChanges(ptid, cell_list) app.broadcastPartitionChanges(ptid, cell_list)
if not app.pt.operational(): if not app.pt.operational():
# Catastrophic. # Catastrophic.
......
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