Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Flush slot creation/drop.
  • Loading branch information
arssher authored and tristan957 committed Feb 6, 2024
commit cd0769113a2e19c9183969fd28f1189e5def8f90
4 changes: 2 additions & 2 deletions src/backend/replication/slot.c
Original file line number Diff line number Diff line change
Expand Up @@ -692,7 +692,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));
}

/*
Expand Down Expand Up @@ -1811,7 +1811,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;
Expand Down