Handle keepalives while receiving WAL in recovery.

Since c310932 safekeeper sometimes sends it. ref #843
neondatabase · Feb 9, 2022 · a3e992f · a3e992f
1 parent bcbf12c
commit a3e992f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/backend/replication/walproposer.c b/src/backend/replication/walproposer.c
@@ -978,7 +978,9 @@ WalProposerRecovery(int donor, TimeLineID timeline, XLogRecPtr startpos, XLogRec
 			}
 			else
 			{
-				Assert(buf[0] == 'w');
+				Assert(buf[0] == 'w' || buf[0] == 'k');
+				if (buf[0] == 'k')
+					continue; /* keepalive */
 				memcpy(&rec_start_lsn, &buf[XLOG_HDR_START_POS],
 					   sizeof rec_start_lsn);
 				rec_start_lsn = pg_ntoh64(rec_start_lsn);