Commit c16d4d91 authored by Grégory Wisniewski's avatar Grégory Wisniewski

Use ZERO_OID/ZERO_TID in recovery.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2302 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent f277f519
...@@ -20,7 +20,7 @@ from struct import pack ...@@ -20,7 +20,7 @@ from struct import pack
from neo import logging from neo import logging
from neo.util import dump from neo.util import dump
from neo.protocol import Packets, ProtocolError, ClusterStates, NodeStates from neo.protocol import Packets, ProtocolError, ClusterStates, NodeStates
from neo.protocol import NotReadyError from neo.protocol import NotReadyError, ZERO_OID, ZERO_TID
from neo.master.handlers import MasterHandler from neo.master.handlers import MasterHandler
REQUIRED_NODE_NUMBER = 1 REQUIRED_NODE_NUMBER = 1
...@@ -96,9 +96,9 @@ class RecoveryManager(MasterHandler): ...@@ -96,9 +96,9 @@ class RecoveryManager(MasterHandler):
node.setRunning() node.setRunning()
self.app.broadcastNodesInformation(node_list) self.app.broadcastNodesInformation(node_list)
# resert IDs generators # resert IDs generators
self.app.tm.setLastOID('\0' * 8) self.app.tm.setLastOID(ZERO_OID)
# build the partition with this node # build the partition with this node
pt.setID(pack('!Q', 1)) pt.setID(ZERO_TID)
pt.make(node_list) pt.make(node_list)
def connectionLost(self, conn, new_state): def connectionLost(self, conn, new_state):
......
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