.

neo/client/Storage.py

@@ -136,7 +136,7 @@ class Storage(BaseStorage.BaseStorage,
     def supportsUndo(self):
         return True
 
-    def supportsTransactionalUndo(self):
+    def supportsTransactionalUndo(self):    # TODO remove (ZODB.f595f7e7)
         return True
 
     def loadEx(self, oid, version):

neo/master/app.py

@@ -516,12 +516,13 @@ class Application(BaseApplication):
         tid = txn.getTID()
         transaction_node = txn.getNode()
         invalidate_objects = Packets.InvalidateObjects(tid, txn.getOIDList())
+        # NOTE send invalidation to clients
         for client_node in self.nm.getClientList(only_identified=True):
             if client_node is transaction_node:
                 client_node.send(Packets.AnswerTransactionFinished(ttid, tid),
                                  msg_id=txn.getMessageId())                       # NOTE msgid: out-of-order answer
             else:
-                # NOTE notifies clients sequentially & irregardless of whether client was subscribed
+                # NOTE notifies clients irregardless of whether client was subscribed
                 client_node.send(invalidate_objects)
 
         # Unlock Information to relevant storage nodes.

neo/master/handlers/client.py

@@ -69,7 +69,10 @@ class ClientServiceHandler(MasterHandler):
         if tid:
             p = Packets.AskLockInformation(ttid, tid)
             for node in node_list:
-                node.ask(p, timeout=60)
+                node.ask(p, timeout=60) # NOTE
+
+            # NOTE continues in onTransactionCommitted
+
         else:
             conn.answer(Errors.IncompleteTransaction())
             # It's simpler to abort automatically rather than asking the client

neo/neoctl/app.py

@@ -40,6 +40,7 @@ action_dict = {
     'truncate': 'truncate',
 }
 
+# ex 'S2' -> u32
 uuid_int = (lambda ns: lambda uuid:
     (ns[uuid[0]] << 24) + int(uuid[1:])
     )({str(k)[0]: v for k, v in UUID_NAMESPACES.iteritems()})