Check replication slot in prepare transaction

knizhnik · kelvich · commit 301e79aa0b15 · 2017-11-13T02:17:31.000+03:00
diff --git a/multimaster.c b/multimaster.c
@@ -896,7 +896,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
`@@ -896,7 +896,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)`
`896`	`896`	`if (!found) {`
`897`	`897`	`ts->isEnqueued = false;`
`898`	`898`	`}`
`899`		`- if (Mtm->status != MTM_RECOVERY) {`
	`899`	`+ if (Mtm->status != MTM_RECOVERY \|\| Mtm->recoverySlot != MtmReplicationNodeId) {`
`900`	`900`	`MtmSendNotificationMessage(ts, MSG_READY); /* send notification to coordinator */`
`901`	`901`	`if (!MtmUseDtm) {`
`902`	`902`	`ts->status = TRANSACTION_STATUS_UNKNOWN;`