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

Commit 2426ca9

Browse files
committed
do not filter post-falure voting decisions
1 parent b8fa192 commit 2426ca9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

arbiter.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1050,7 +1050,7 @@ void MtmReceiver(Datum arg)
10501050
MTM_ELOG(LOG, "Abort prepared transaction %s because it is in state %s at node %d",
10511051
msg->gid, MtmTxnStatusMnem[msg->status], node);
10521052

1053-
replorigin_session_origin = DoNotReplicateId;
1053+
replorigin_session_origin = InvalidRepOriginId;
10541054
TXFINISH("%s ABORT, MSG_POLL_STATUS", msg->gid);
10551055
MtmFinishPreparedTransaction(ts, false);
10561056
replorigin_session_origin = InvalidRepOriginId;
@@ -1064,7 +1064,7 @@ void MtmReceiver(Datum arg)
10641064
if ((ts->participantsMask & ~Mtm->disabledNodeMask & ~ts->votedMask) == 0) {
10651065
MTM_ELOG(LOG, "Commit transaction %s because it is prepared at all live nodes", msg->gid);
10661066

1067-
replorigin_session_origin = DoNotReplicateId;
1067+
replorigin_session_origin = InvalidRepOriginId;
10681068
TXFINISH("%s COMMIT, MSG_POLL_STATUS", msg->gid);
10691069
MtmFinishPreparedTransaction(ts, true);
10701070
replorigin_session_origin = InvalidRepOriginId;

0 commit comments

Comments
 (0)