fix: XLogFlush replication slot drop (#396)

Signed-off-by: Alex Chi Z <chi@neon.tech>
neondatabase · Mar 28, 2024 · a7b4c66 · a7b4c66
1 parent 748643b
commit a7b4c66
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c
@@ -612,7 +612,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));
 	}
 
 	/*
@@ -1585,7 +1585,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;