Storage ask itself the last IDs when entering in service state.

This fix a race condition when switching from recovery to verification
steps where NotifyLastOID packet could be handled by verification handler
instead of initialisation (storage side).

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1983 71dcc9de-d417-0410-9af5-da40c76e7ee4

neo/master/handlers/administration.py

@@ -146,7 +146,6 @@ class AdministrationHandler(MasterHandler):
         app.broadcastNodesInformation(node_list)
         # start nodes
         for node in self.app.nm.getIdentifiedList(pool_set=uuid_set):
-            node.notify(Packets.NotifyLastOID(app.loid))
             node.notify(Packets.StartOperation())
         # broadcast the new partition table
         app.broadcastPartitionChanges(cell_list)

neo/master/handlers/storage.py

@@ -30,7 +30,6 @@ class StorageServiceHandler(BaseServiceHandler):
     def connectionCompleted(self, conn):
         node = self.app.nm.getByUUID(conn.getUUID())
         if node.isRunning():
-            conn.notify(Packets.NotifyLastOID(self.app.loid))
             conn.notify(Packets.StartOperation())
 
     def nodeLost(self, conn, node):

neo/storage/app.py

@@ -222,10 +222,13 @@ class Application(object):
         # ask node list and partition table
         self.has_node_information = False
         self.has_partition_table = False
+        self.has_last_ids = False
         self.pt.clear()
+        self.master_conn.ask(Packets.AskLastIDs())
         self.master_conn.ask(Packets.AskNodeInformation())
         self.master_conn.ask(Packets.AskPartitionTable(()))
-        while not self.has_node_information or not self.has_partition_table:
+        while not self.has_node_information or not self.has_partition_table \
+                or not self.has_last_ids:
             self.em.poll(1)
         self.ready = True
 

neo/storage/handlers/initialization.py

@@ -58,6 +58,11 @@ class InitializationHandler(BaseMasterHandler):
         app.dm.setPartitionTable(ptid, cell_list)
         self.app.has_partition_table = True
 
+    def answerLastIDs(self, conn, loid, ltid, lptid):
+        self.app.tm.setLastOID(loid)
+        self.app.dm.setLastOID(loid)
+        self.app.has_last_ids = True
+
     def notifyPartitionChanges(self, conn, ptid, cell_list):
         # XXX: This is safe to ignore those notifications because all of the
         # following applies: