Commit e2536c08 authored by Julien Muchembled's avatar Julien Muchembled

fixup! Recover from failures during tpc_finish when the transaction got successfully committed

parent c329ab95
...@@ -145,7 +145,7 @@ class Transaction(object): ...@@ -145,7 +145,7 @@ class Transaction(object):
else: else:
return True # abort return True # abort
else: else:
self._notification_set.discard(uuid) self._notification_set.discard(node.getUUID())
return False return False
def lock(self, uuid): def lock(self, uuid):
...@@ -372,7 +372,6 @@ class TransactionManager(object): ...@@ -372,7 +372,6 @@ class TransactionManager(object):
self._on_commit(txn) self._on_commit(txn)
def clientLost(self, node): def clientLost(self, node):
uuid = node.getUUID()
for txn in self._ttid_dict.values(): for txn in self._ttid_dict.values():
if txn.clientLost(node): if txn.clientLost(node):
del self[txn.getTTID()] del self[txn.getTTID()]
......
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