fix: XLogFlush replication slot save/drop (#395)

* fix: XLogFlush replication slot drop Signed-off-by: Alex Chi Z <chi@neon.tech> * fix all occurrences Signed-off-by: Alex Chi Z <chi@neon.tech> --------- Signed-off-by: Alex Chi Z <chi@neon.tech>
neondatabase · Mar 28, 2024 · 64b8c7b · 64b8c7b
1 parent e7651e7
commit 64b8c7b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c
@@ -690,7 +690,7 @@ ReplicationSlotDropPtr(ReplicationSlot *slot)
 		char		prefix[MAXPGPATH];
 		snprintf(prefix, sizeof(prefix), "neon-file:%s/state", path);
 		elog(LOG, "Drop replication slot %s", path);
-		LogLogicalMessage(prefix, NULL, 0, false);
+		XLogFlush(LogLogicalMessage(prefix, NULL, 0, false));
 	}
 
 	/*
@@ -1665,7 +1665,7 @@ SaveSlotToPath(ReplicationSlot *slot, const char *dir, int elevel)
 		char		prefix[MAXPGPATH];
 		snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
 		elog(LOG, "Save replication slot at %s restart_lsn=%X/%X", path, 	LSN_FORMAT_ARGS(cp.slotdata.restart_lsn));
-		LogLogicalMessage(prefix, (char*)&cp, sizeof cp, false);
+		XLogFlush(LogLogicalMessage(prefix, (char*)&cp, sizeof cp, false));
 	}
 
 	errno = 0;