Do not wallog AUX files at replica (#515)

Co-authored-by: Konstantin Knizhnik <knizhnik@neon.tech>
neondatabase · Nov 11, 2024 · de0a000 · de0a000
1 parent ea70383
commit de0a000
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 8 deletions.
diff --git a/src/backend/access/heap/rewriteheap.c b/src/backend/access/heap/rewriteheap.c
@@ -793,6 +793,11 @@ static void
 wallog_mapping_file(char const* path, int fd)
 {
 	char	prefix[MAXPGPATH];
+
+	/* Do not wallog AUX file at replica */
+	if (!XLogInsertAllowed())
+		return;
+
 	snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
 	if (fd < 0)
 	{

diff --git a/src/backend/replication/logical/snapbuild.c b/src/backend/replication/logical/snapbuild.c
@@ -1737,9 +1737,13 @@ SnapBuildSerialize(SnapBuild *builder, XLogRecPtr lsn)
 				(errcode_for_file_access(),
 				 errmsg("could not open file \"%s\": %m", tmppath)));
 
-	/* NEON specific: persist snapshot in storage using logical message */
-	snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
-	XLogFlush(LogLogicalMessage(prefix, (char*)ondisk, needed_length, false));
+	/* Do not wallog AUX file at replica */
+	if (XLogInsertAllowed())
+	{
+		/* NEON specific: persist snapshot in storage using logical message */
+		snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
+		XLogFlush(LogLogicalMessage(prefix, (char*)ondisk, needed_length, false));
+	}
 
 	errno = 0;
 	pgstat_report_wait_start(WAIT_EVENT_SNAPBUILD_WRITE);
@@ -2106,9 +2110,13 @@ CheckPointSnapBuild(void)
 		{
 			elog(DEBUG1, "removing snapbuild snapshot %s", path);
 
-			/* NEON specific: delete file from storage using logical message */
-			snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
-			XLogFlush(LogLogicalMessage(prefix, NULL, 0, false));
+			/* Do not wallog AUX file at replica */
+			if (XLogInsertAllowed())
+			{
+				/* NEON specific: delete file from storage using logical message */
+				snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
+				XLogFlush(LogLogicalMessage(prefix, NULL, 0, false));
+			}
 
 			/*
 			 * It's not particularly harmful, though strange, if we can't

diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c
@@ -606,7 +606,7 @@ ReplicationSlotDropPtr(ReplicationSlot *slot)
 	sprintf(path, "pg_replslot/%s", NameStr(slot->data.name));
 	sprintf(tmppath, "pg_replslot/%s.tmp", NameStr(slot->data.name));
 
-	if (SlotIsLogical(slot))
+	if (SlotIsLogical(slot) && XLogInsertAllowed())
 	{
 		/* NEON specific: delete slot from storage using logical message */
 		char		prefix[MAXPGPATH];
@@ -1579,7 +1579,7 @@ SaveSlotToPath(ReplicationSlot *slot, const char *dir, int elevel)
 				SnapBuildOnDiskChecksummedSize);
 	FIN_CRC32C(cp.checksum);
 
-	if (SlotIsLogical(slot) && cp.slotdata.restart_lsn != InvalidXLogRecPtr)
+	if (SlotIsLogical(slot) && XLogInsertAllowed() && cp.slotdata.restart_lsn != InvalidXLogRecPtr)
 	{
 		/* NEON specific: persist slot in storage using logical message */
 		char		prefix[MAXPGPATH];