Commit 67f21f13 authored by Yoshinori Okuji's avatar Yoshinori Okuji

The paremeters to doSetPartitionTable were reverse..

git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@207 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 073ce093
...@@ -376,9 +376,10 @@ class Application(object): ...@@ -376,9 +376,10 @@ class Application(object):
logging.debug('creating a new partition table') logging.debug('creating a new partition table')
self.pt.make(nm.getStorageNodeList()) self.pt.make(nm.getStorageNodeList())
else: else:
# Obtain a partition table. It is necessary to split this message # Obtain a partition table. It is necessary to split this
# because the packet size can be huge. # message, because the packet size can be huge.
logging.debug('asking a partition table to %s:%d', *(node.getServer())) logging.debug('asking a partition table to %s:%d',
*(node.getServer()))
start = 0 start = 0
size = self.num_partitions size = self.num_partitions
while size: while size:
...@@ -407,8 +408,8 @@ class Application(object): ...@@ -407,8 +408,8 @@ class Application(object):
self.pt.log() self.pt.log()
continue continue
# Wait until the cluster gets operational or the Partition Table ID # Wait until the cluster gets operational or the Partition
# turns out to be not the latest. # Table ID turns out to be not the latest.
logging.debug('waiting for the cluster to be operational') logging.debug('waiting for the cluster to be operational')
self.pt.log() self.pt.log()
while 1: while 1:
......
...@@ -359,10 +359,10 @@ class MySQLDatabaseManager(DatabaseManager): ...@@ -359,10 +359,10 @@ class MySQLDatabaseManager(DatabaseManager):
self.commit() self.commit()
def changePartitionTable(self, ptid, cell_list): def changePartitionTable(self, ptid, cell_list):
self.doSetPartitionTable(ptid, cell_list, True) self.doSetPartitionTable(ptid, cell_list, False)
def setPartitionTable(self, ptid, cell_list): def setPartitionTable(self, ptid, cell_list):
self.doSetPartitionTable(ptid, cell_list, False) self.doSetPartitionTable(ptid, cell_list, True)
def dropUnfinishedData(self): def dropUnfinishedData(self):
q = self.query q = self.query
......
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