Add check for maximal number of write transactions at replica

knizhnik · knizhnik · commit 46874e22842a · 2019-09-26T11:54:23.000+03:00
diff --git a/src/backend/access/transam/xact.c b/src/backend/access/transam/xact.c
@@ -463,7 +463,11 @@ GetReplicaTransactionId(void)
 {
 	TransactionState s = CurrentTransactionState;
 	if (!TransactionIdIsValid(s->replicaTransactionId))
-		s->replicaTransactionId = ++replicaTransIdCount;
+	{
+		if (!TransactionIdIsValid(++replicaTransIdCount))
+			elog(ERROR, "Too many write transactions at replica");
+		s->replicaTransactionId = replicaTransIdCount;
+	}
 	return s->replicaTransactionId;
 }
 

Original file line number	Diff line number	Diff line change
`@@ -463,7 +463,11 @@ GetReplicaTransactionId(void)`
`463`	`463`	`{`
`464`	`464`	`TransactionState s = CurrentTransactionState;`
`465`	`465`	`if (!TransactionIdIsValid(s->replicaTransactionId))`
`466`		`- s->replicaTransactionId = ++replicaTransIdCount;`
	`466`	`+ {`
	`467`	`+ if (!TransactionIdIsValid(++replicaTransIdCount))`
	`468`	`+ elog(ERROR, "Too many write transactions at replica");`
	`469`	`+ s->replicaTransactionId = replicaTransIdCount;`
	`470`	`+ }`
`467`	`471`	`return s->replicaTransactionId;`
`468`	`472`	`}`
`469`	`473`