Panic on receiving higher term (#176)

neondatabase · Feb 10, 2023 · 81bbf69 · 81bbf69
1 parent 60e3d0d
commit 81bbf69
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/backend/replication/walproposer.c b/src/backend/replication/walproposer.c
@@ -1762,6 +1762,14 @@ RecvAppendResponses(Safekeeper *sk)
 						LSN_FORMAT_ARGS(sk->appendResponse.commitLsn),
 						sk->host, sk->port)));
 
+		if (sk->appendResponse.term > propTerm)
+		{
+			/* Another compute with higher term is running. */
+			elog(PANIC, "WAL acceptor %s:%s with term " INT64_FORMAT " rejected our request, our term " INT64_FORMAT "",
+					sk->host, sk->port,
+					sk->appendResponse.term, propTerm);
+		}
+
 		readAnything = true;
 	}