diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/backend/replication/logical/snapbuild.c | 8 | ||||
| -rw-r--r-- | src/backend/replication/walsender.c | 2 | ||||
| -rw-r--r-- | src/include/replication/snapbuild.h | 2 |
3 files changed, 6 insertions, 6 deletions
diff --git a/src/backend/replication/logical/snapbuild.c b/src/backend/replication/logical/snapbuild.c index a73a7b98f97..227960452d6 100644 --- a/src/backend/replication/logical/snapbuild.c +++ b/src/backend/replication/logical/snapbuild.c @@ -499,14 +499,14 @@ SnapBuildBuildSnapshot(SnapBuild *builder, TransactionId xid) } /* - * Build the initial slot snapshot and convert it to normal snapshot that + * Build the initial slot snapshot and convert it to a normal snapshot that * is understood by HeapTupleSatisfiesMVCC. * * The snapshot will be usable directly in current transaction or exported * for loading in different transaction. */ Snapshot -SnapBuildInitalSnapshot(SnapBuild *builder) +SnapBuildInitialSnapshot(SnapBuild *builder) { Snapshot snap; TransactionId xid; @@ -514,7 +514,7 @@ SnapBuildInitalSnapshot(SnapBuild *builder) int newxcnt = 0; Assert(!FirstSnapshotSet); - Assert(XactIsoLevel = XACT_REPEATABLE_READ); + Assert(XactIsoLevel == XACT_REPEATABLE_READ); if (builder->state != SNAPBUILD_CONSISTENT) elog(ERROR, "cannot build an initial slot snapshot before reaching a consistent state"); @@ -604,7 +604,7 @@ SnapBuildExportSnapshot(SnapBuild *builder) XactIsoLevel = XACT_REPEATABLE_READ; XactReadOnly = true; - snap = SnapBuildInitalSnapshot(builder); + snap = SnapBuildInitialSnapshot(builder); /* * now that we've built a plain snapshot, make it active and use the diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c index 59ae22df8c8..040ad7b7371 100644 --- a/src/backend/replication/walsender.c +++ b/src/backend/replication/walsender.c @@ -938,7 +938,7 @@ CreateReplicationSlot(CreateReplicationSlotCmd *cmd) { Snapshot snap; - snap = SnapBuildInitalSnapshot(ctx->snapshot_builder); + snap = SnapBuildInitialSnapshot(ctx->snapshot_builder); RestoreTransactionSnapshot(snap, MyProc); } diff --git a/src/include/replication/snapbuild.h b/src/include/replication/snapbuild.h index 091a9f91e36..a8ae63116a6 100644 --- a/src/include/replication/snapbuild.h +++ b/src/include/replication/snapbuild.h @@ -59,7 +59,7 @@ extern void FreeSnapshotBuilder(SnapBuild *cache); extern void SnapBuildSnapDecRefcount(Snapshot snap); -extern Snapshot SnapBuildInitalSnapshot(SnapBuild *builder); +extern Snapshot SnapBuildInitialSnapshot(SnapBuild *builder); extern const char *SnapBuildExportSnapshot(SnapBuild *snapstate); extern void SnapBuildClearExportedSnapshot(void); |