diff options
Diffstat (limited to 'src/backend/replication/logical/origin.c')
| -rw-r--r-- | src/backend/replication/logical/origin.c | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/backend/replication/logical/origin.c b/src/backend/replication/logical/origin.c index 419e4814f05..baf696d8e68 100644 --- a/src/backend/replication/logical/origin.c +++ b/src/backend/replication/logical/origin.c @@ -95,6 +95,10 @@ #include "utils/snapmgr.h" #include "utils/syscache.h" +/* paths for replication origin checkpoint files */ +#define PG_REPLORIGIN_CHECKPOINT_FILENAME PG_LOGICAL_DIR "/replorigin_checkpoint" +#define PG_REPLORIGIN_CHECKPOINT_TMPFILE PG_REPLORIGIN_CHECKPOINT_FILENAME ".tmp" + /* * Replay progress of a single remote node. */ @@ -572,8 +576,8 @@ ReplicationOriginShmemInit(void) void CheckPointReplicationOrigin(void) { - const char *tmppath = "pg_logical/replorigin_checkpoint.tmp"; - const char *path = "pg_logical/replorigin_checkpoint"; + const char *tmppath = PG_REPLORIGIN_CHECKPOINT_TMPFILE; + const char *path = PG_REPLORIGIN_CHECKPOINT_FILENAME; int tmpfd; int i; uint32 magic = REPLICATION_STATE_MAGIC; @@ -698,7 +702,7 @@ CheckPointReplicationOrigin(void) void StartupReplicationOrigin(void) { - const char *path = "pg_logical/replorigin_checkpoint"; + const char *path = PG_REPLORIGIN_CHECKPOINT_FILENAME; int fd; int readBytes; uint32 magic = REPLICATION_STATE_MAGIC; |