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

Commit 9bf1789

Browse files
committed
alter MtmPollStatusOfPreparedTransactions logic: ask neighbours for foreign transactions
1 parent f07ac48 commit 9bf1789

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

multimaster.c

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2133,6 +2133,11 @@ MtmPollStatusOfPreparedTransactions(bool majorMode)
21332133
MTM_LOG1("Abort our in-progress transaction %s", ts->gid);
21342134
MtmFinishPreparedTransaction(ts, false);
21352135
}
2136+
else
2137+
{
2138+
MTM_LOG1("Ask neighbours for help with transaction %s", ts->gid);
2139+
MtmBroadcastPollMessage(ts);
2140+
}
21362141
}
21372142
} else {
21382143
MTM_LOG2("Skip prepared transaction %s ("XID_FMT") with status %s gtid.node=%d gtid.xid=%llu votedMask=%llx",

0 commit comments

Comments
 (0)