Fix a missing ptid argument.

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

neo/handler.py

@@ -145,13 +145,13 @@ class EventHandler(object):
     def handleAskPartitionTable(self, conn, packet, offset_list):
         self.handleUnexpectedPacket(conn, packet)
 
-    def handleAnswerPartitionTable(self, conn, packet, row_list):
+    def handleAnswerPartitionTable(self, conn, packet, ptid, row_list):
         self.handleUnexpectedPacket(conn, packet)
 
-    def handleSendPartitionTable(self, conn, packet, row_list):
+    def handleSendPartitionTable(self, conn, packet, ptid, row_list):
         self.handleUnexpectedPacket(conn, packet)
 
-    def handleNotifyPartitionChanges(self, conn, packet, cell_list):
+    def handleNotifyPartitionChanges(self, conn, packet, ptid, cell_list):
         self.handleUnexpectedPacket(conn, packet)
 
     def handleStartOperation(self, conn, packet):

neo/master/handler.py

@@ -29,7 +29,7 @@ class MasterEventHandler(EventHandler):
         logging.info('ignoring Answer Last IDs')
         pass
 
-    def handleAnswerPartitionTable(self, conn, packet, cell_list):
+    def handleAnswerPartitionTable(self, conn, packet, ptid, cell_list):
         logging.info('ignoring Answer Partition Table')
         pass
 

neo/master/recovery.py

@@ -301,7 +301,7 @@ class RecoveryEventHandler(MasterEventHandler):
         elif app.lptid == lptid and app.target_uuid is None:
             app.target_uuid = uuid
 
-    def handleAnswerPartitionTable(self, conn, packet, cell_list):
+    def handleAnswerPartitionTable(self, conn, packet, ptid, cell_list):
         uuid = conn.getUUID()
         if uuid is None:
             self.handleUnexpectedPacket(conn, packet)

neo/master/verification.py

@@ -310,7 +310,7 @@ class VerificationEventHandler(MasterEventHandler):
             logging.critical('got later information in verification')
             raise VerificationFailure
 
-    def handleAnswerPartitionTable(self, conn, packet, cell_list):
+    def handleAnswerPartitionTable(self, conn, packet, ptid, cell_list):
         # Ignore this packet.
         pass
 

neo/storage/bootstrap.py

@@ -206,10 +206,10 @@ class BootstrapEventHandler(StorageEventHandler):
     def handleAskPartitionTable(self, conn, packet, offset_list):
         pass
 
-    def handleSendPartitionTable(self, conn, packet, row_list):
+    def handleSendPartitionTable(self, conn, packet, ptid, row_list):
         pass
 
-    def handleNotifyPartitionChanges(self, conn, packet, cell_list):
+    def handleNotifyPartitionChanges(self, conn, packet, ptid, cell_list):
         pass
 
     def handleStartOperation(self, conn, packet):

neo/storage/handler.py

@@ -148,10 +148,10 @@ class StorageEventHandler(EventHandler):
     def handleAskPartitionTable(self, conn, packet, offset_list):
         raise NotImplementedError('this method must be overridden')
 
-    def handleSendPartitionTable(self, conn, packet, row_list):
+    def handleSendPartitionTable(self, conn, packet, ptid, row_list):
         raise NotImplementedError('this method must be overridden')
 
-    def handleNotifyPartitionChanges(self, conn, packet, cell_list):
+    def handleNotifyPartitionChanges(self, conn, packet, ptid, cell_list):
         raise NotImplementedError('this method must be overridden')
 
     def handleStartOperation(self, conn, packet):