Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit e2a0823

Browse files
committed
fix 2pc issued by client, which was broken by b714215
1 parent 658bc75 commit e2a0823

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

multimaster.c

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -602,8 +602,9 @@ csn_t MtmDistributedTransactionSnapshot(TransactionId xid, int nodeId, nodemask_
602602
MtmTransState* ts = (MtmTransState*)hash_search(MtmXid2State, &xid, HASH_FIND, NULL);
603603
if (ts != NULL) {
604604
*participantsMask = ts->participantsMask;
605-
/* If node is disables, then we are in a process of recovery of this node */
606-
snapshot = ts->snapshot;
605+
if (!ts->isLocal)
606+
snapshot = ts->snapshot;
607+
// /* If node is disables, then we are in a process of recovery of this node */
607608
// if (!ts->isLocal && BIT_CHECK(ts->participantsMask|Mtm->disabledNodeMask, nodeId-1)) {
608609
// snapshot = ts->snapshot;
609610
// Assert(ts->gtid.node == MtmNodeId || MtmIsRecoverySession);

0 commit comments

Comments
 (0)