Commit 4a269eaf authored by Jim Fulton's avatar Jim Fulton

Fixed: tpc_vote return wasn't handled correctly.

I'd lazily assumed that undo and tpc_vote has the same sorts of
returns, but they don't.  When tpc_vote isn't None (ZEO), the retrun
is a list of oid and serial pairs.
parent 1731c16f
...@@ -256,7 +256,8 @@ class UndoAdapterInstance(Base): ...@@ -256,7 +256,8 @@ class UndoAdapterInstance(Base):
def tpc_vote(self, transaction): def tpc_vote(self, transaction):
result = self._storage.tpc_vote(transaction) result = self._storage.tpc_vote(transaction)
if result: if result:
self._undone.update(result[1]) for oid, serial in result:
self._undone.add(oid)
def tpc_finish(self, transaction, func = lambda tid: None): def tpc_finish(self, transaction, func = lambda tid: None):
......
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