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

Commit 047ef98

Browse files
committed
try to fix MtmDistributedTransactionSnapshot
1 parent 4f487d9 commit 047ef98

File tree

1 file changed

+8
-7
lines changed

1 file changed

+8
-7
lines changed

multimaster.c

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -583,13 +583,14 @@ csn_t MtmDistributedTransactionSnapshot(TransactionId xid, int nodeId, nodemask_
583583
if (ts != NULL) {
584584
*participantsMask = ts->participantsMask;
585585
/* If node is disables, then we are in a process of recovery of this node */
586-
if (!ts->isLocal && BIT_CHECK(ts->participantsMask|Mtm->disabledNodeMask, nodeId-1)) {
587-
snapshot = ts->snapshot;
588-
Assert(ts->gtid.node == MtmNodeId || MtmIsRecoverySession);
589-
} else {
590-
MTM_LOG1("Do not send transaction %s (%llu) to node %d participants mask %llx",
591-
ts->gid, (long64)ts->xid, nodeId, ts->participantsMask);
592-
}
586+
snapshot = ts->snapshot;
587+
// if (!ts->isLocal && BIT_CHECK(ts->participantsMask|Mtm->disabledNodeMask, nodeId-1)) {
588+
// snapshot = ts->snapshot;
589+
// Assert(ts->gtid.node == MtmNodeId || MtmIsRecoverySession);
590+
// } else {
591+
// MTM_LOG1("Do not send transaction %s (%llu) to node %d participants mask %llx",
592+
// ts->gid, (long64)ts->xid, nodeId, ts->participantsMask);
593+
// }
593594
}
594595
}
595596
MtmUnlock();

0 commit comments

Comments
 (0)