Check replication slot in prepare transaction

knizhnik · knizhnik · commit 9a706c940d6a · 2016-08-23T13:06:39.000+03:00
diff --git a/contrib/mmts/multimaster.c b/contrib/mmts/multimaster.c
@@ -897,7 +897,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)
 		if (!found) { 
 			ts->isEnqueued = false;
 		}
-		if (Mtm->status != MTM_RECOVERY) { 
+		if (Mtm->status != MTM_RECOVERY || Mtm->recoverySlot != MtmReplicationNodeId) { 
 			MtmSendNotificationMessage(ts, MSG_READY); /* send notification to coordinator */
 			if (!MtmUseDtm) { 
 				ts->status = TRANSACTION_STATUS_UNKNOWN;

Original file line number	Diff line number	Diff line change
`@@ -897,7 +897,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)`
`897`	`897`	`if (!found) {`
`898`	`898`	`ts->isEnqueued = false;`
`899`	`899`	`}`
`900`		`- if (Mtm->status != MTM_RECOVERY) {`
	`900`	`+ if (Mtm->status != MTM_RECOVERY \|\| Mtm->recoverySlot != MtmReplicationNodeId) {`
`901`	`901`	`MtmSendNotificationMessage(ts, MSG_READY); /* send notification to coordinator */`
`902`	`902`	`if (!MtmUseDtm) {`
`903`	`903`	`ts->status = TRANSACTION_STATUS_UNKNOWN;`