Skip to content

Commit c4ccf38

Browse files
skyzhtristan957
authored andcommitted
fix: XLogFlush replication slot drop (#396)
Signed-off-by: Alex Chi Z <[email protected]>
1 parent bb8d738 commit c4ccf38

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/backend/replication/slot.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -612,7 +612,7 @@ ReplicationSlotDropPtr(ReplicationSlot *slot)
612612
char prefix[MAXPGPATH];
613613
snprintf(prefix, sizeof(prefix), "neon-file:%s/state", path);
614614
elog(LOG, "Drop replication slot %s", path);
615-
LogLogicalMessage(prefix, NULL, 0, false);
615+
XLogFlush(LogLogicalMessage(prefix, NULL, 0, false));
616616
}
617617

618618
/*
@@ -1585,7 +1585,7 @@ SaveSlotToPath(ReplicationSlot *slot, const char *dir, int elevel)
15851585
char prefix[MAXPGPATH];
15861586
snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
15871587
elog(LOG, "Save replication slot at %s restart_lsn=%X/%X", path, LSN_FORMAT_ARGS(cp.slotdata.restart_lsn));
1588-
LogLogicalMessage(prefix, (char*)&cp, sizeof cp, false);
1588+
XLogFlush(LogLogicalMessage(prefix, (char*)&cp, sizeof cp, false));
15891589
}
15901590

15911591
errno = 0;

0 commit comments

Comments
 (0)