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

Remove some TODO and XXX implemented or put in the TODO list.


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@1050 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 455cfea7
...@@ -125,6 +125,7 @@ RC Known bugs ...@@ -125,6 +125,7 @@ RC Known bugs
- Decentralize primary master tasks as much as possible (consider distributed lock mechanisms, ...) - Decentralize primary master tasks as much as possible (consider distributed lock mechanisms, ...)
- Make admin node able to monitor multiple clusters simultaneously - Make admin node able to monitor multiple clusters simultaneously
- Choose how to compute the storage size - Choose how to compute the storage size
- Make storage check if the OID match with it's partitions during a store
- When importing data, objects with non-allocated OIDs are stored. The - When importing data, objects with non-allocated OIDs are stored. The
storage can detect this and could notify the master to not allocatexd lower storage can detect this and could notify the master to not allocatexd lower
OIDs. But during import, each object stored trigger this notification and OIDs. But during import, each object stored trigger this notification and
......
...@@ -237,8 +237,6 @@ class Application(object): ...@@ -237,8 +237,6 @@ class Application(object):
while not self.has_node_information or not self.has_partition_table: while not self.has_node_information or not self.has_partition_table:
self.em.poll(1) self.em.poll(1)
self.ready = True self.ready = True
# TODO: notify the master that I switch to operation state, so other
# nodes can now connect to me
def doOperation(self): def doOperation(self):
"""Handle everything, including replications and transactions.""" """Handle everything, including replications and transactions."""
......
...@@ -108,10 +108,8 @@ class ClientOperationHandler(BaseClientAndStorageOperationHandler): ...@@ -108,10 +108,8 @@ class ClientOperationHandler(BaseClientAndStorageOperationHandler):
def handleAskStoreObject(self, conn, packet, oid, serial, def handleAskStoreObject(self, conn, packet, oid, serial,
compression, checksum, data, tid): compression, checksum, data, tid):
if oid != protocol.INVALID_OID and oid > self.app.loid: if oid != protocol.INVALID_OID and oid > self.app.loid:
# TODO: notify the master to invalidate lower OIDs
args = dump(oid), dump(self.app.loid) args = dump(oid), dump(self.app.loid)
logging.warning('Greater OID used in StoreObject : %s > %s', *args) logging.warning('Greater OID used in StoreObject : %s > %s', *args)
# XXX: should check if the oid match with our partition table
uuid = conn.getUUID() uuid = conn.getUUID()
# First, check for the locking state. # First, check for the locking state.
app = self.app app = self.app
......
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