diff options
author | Peter Geoghegan <pg@bowt.ie> | 2022-09-19 19:18:36 -0700 |
---|---|---|
committer | Peter Geoghegan <pg@bowt.ie> | 2022-09-19 19:18:36 -0700 |
commit | bfcf1b34805f70df48eedeec237230d0cc1154a6 (patch) | |
tree | baf824c317ecf02c49d758e75e72d69c5b6a4ec6 /src/backend/replication | |
parent | c47885bd8b6997ccb0cc1997f61f6f98a79ce32a (diff) | |
download | postgresql-bfcf1b34805f70df48eedeec237230d0cc1154a6.tar.gz postgresql-bfcf1b34805f70df48eedeec237230d0cc1154a6.zip |
Harmonize parameter names in storage and AM code.
Make sure that function declarations use names that exactly match the
corresponding names from function definitions in storage, catalog,
access method, executor, and logical replication code, as well as in
miscellaneous utility/library code.
Like other recent commits that cleaned up function parameter names, this
commit was written with help from clang-tidy. Later commits will do the
same for other parts of the codebase.
Author: Peter Geoghegan <pg@bowt.ie>
Reviewed-By: David Rowley <dgrowleyml@gmail.com>
Discussion: https://postgr.es/m/CAH2-WznJt9CMM9KJTMjJh_zbL5hD9oX44qdJ4aqZtjFi-zA3Tg@mail.gmail.com
Diffstat (limited to 'src/backend/replication')
-rw-r--r-- | src/backend/replication/logical/decode.c | 4 | ||||
-rw-r--r-- | src/backend/replication/logical/worker.c | 3 | ||||
-rw-r--r-- | src/backend/replication/pgoutput/pgoutput.c | 4 | ||||
-rw-r--r-- | src/backend/replication/slot.c | 2 |
4 files changed, 7 insertions, 6 deletions
diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c index 4264da5bb00..98c40e17b6c 100644 --- a/src/backend/replication/logical/decode.c +++ b/src/backend/replication/logical/decode.c @@ -62,13 +62,13 @@ static void DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf, /* common function to decode tuples */ -static void DecodeXLogTuple(char *data, Size len, ReorderBufferTupleBuf *tup); +static void DecodeXLogTuple(char *data, Size len, ReorderBufferTupleBuf *tuple); /* helper functions for decoding transactions */ static inline bool FilterPrepare(LogicalDecodingContext *ctx, TransactionId xid, const char *gid); static bool DecodeTXNNeedSkip(LogicalDecodingContext *ctx, - XLogRecordBuffer *buf, Oid dbId, + XLogRecordBuffer *buf, Oid txn_dbid, RepOriginId origin_id); /* diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index eaca406d301..56f753d987d 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -312,7 +312,8 @@ static inline void cleanup_subxact_info(void); * Serialize and deserialize changes for a toplevel transaction. */ static void stream_cleanup_files(Oid subid, TransactionId xid); -static void stream_open_file(Oid subid, TransactionId xid, bool first); +static void stream_open_file(Oid subid, TransactionId xid, + bool first_segment); static void stream_write_change(char action, StringInfo s); static void stream_close_file(void); diff --git a/src/backend/replication/pgoutput/pgoutput.c b/src/backend/replication/pgoutput/pgoutput.c index 62e0ffecd8f..03b13ae6798 100644 --- a/src/backend/replication/pgoutput/pgoutput.c +++ b/src/backend/replication/pgoutput/pgoutput.c @@ -44,7 +44,7 @@ static void pgoutput_begin_txn(LogicalDecodingContext *ctx, static void pgoutput_commit_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn); static void pgoutput_change(LogicalDecodingContext *ctx, - ReorderBufferTXN *txn, Relation rel, + ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change); static void pgoutput_truncate(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, int nrelations, Relation relations[], @@ -212,7 +212,7 @@ typedef struct PGOutputTxnData /* Map used to remember which relation schemas we sent. */ static HTAB *RelationSyncCache = NULL; -static void init_rel_sync_cache(MemoryContext decoding_context); +static void init_rel_sync_cache(MemoryContext cachectx); static void cleanup_rel_sync_cache(TransactionId xid, bool is_commit); static RelationSyncEntry *get_rel_sync_entry(PGOutputData *data, Relation relation); diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c index 8fec1cb4a54..0bd00311888 100644 --- a/src/backend/replication/slot.c +++ b/src/backend/replication/slot.c @@ -108,7 +108,7 @@ static void ReplicationSlotDropPtr(ReplicationSlot *slot); /* internal persistency functions */ static void RestoreSlotFromDisk(const char *name); static void CreateSlotOnDisk(ReplicationSlot *slot); -static void SaveSlotToPath(ReplicationSlot *slot, const char *path, int elevel); +static void SaveSlotToPath(ReplicationSlot *slot, const char *dir, int elevel); /* * Report shared-memory space needed by ReplicationSlotsShmemInit. |