diff options
| author | Amit Kapila <akapila@postgresql.org> | 2021-07-30 08:17:38 +0530 |
|---|---|---|
| committer | Amit Kapila <akapila@postgresql.org> | 2021-07-30 08:17:38 +0530 |
| commit | 16bd4becee32240d09db5c6cbec87957fdfcd2d9 (patch) | |
| tree | 2acaa30a17594b1761f182b291d64cd085c83f19 | |
| parent | ce197e91d02ca38ac1b956a3e0c11596099e7893 (diff) | |
| download | postgresql-16bd4becee32240d09db5c6cbec87957fdfcd2d9.tar.gz postgresql-16bd4becee32240d09db5c6cbec87957fdfcd2d9.zip | |
Remove unused argument in apply_handle_commit_internal().
Oversight in commit 0926e96c49.
Author: Masahiko Sawada
Reviewed-By: Amit Kapila
Backpatch-through: 14, where it was introduced
Discussion: https://postgr.es/m/CAD21AoDeScrsHhLyEPYqN3sydg6PxAPVBboK=30xJfUVihNZDA@mail.gmail.com
| -rw-r--r-- | src/backend/replication/logical/worker.c | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index 3f499b11f72..249de807984 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -309,8 +309,7 @@ static void maybe_reread_subscription(void); /* prototype needed because of stream_commit */ static void apply_dispatch(StringInfo s); -static void apply_handle_commit_internal(StringInfo s, - LogicalRepCommitData *commit_data); +static void apply_handle_commit_internal(LogicalRepCommitData *commit_data); static void apply_handle_insert_internal(ApplyExecutionData *edata, ResultRelInfo *relinfo, TupleTableSlot *remoteslot); @@ -855,7 +854,7 @@ apply_handle_commit(StringInfo s) LSN_FORMAT_ARGS(commit_data.commit_lsn), LSN_FORMAT_ARGS(remote_final_lsn)))); - apply_handle_commit_internal(s, &commit_data); + apply_handle_commit_internal(&commit_data); /* Process any tables that are being synchronized in parallel. */ process_syncing_tables(commit_data.end_lsn); @@ -1415,7 +1414,7 @@ apply_handle_stream_commit(StringInfo s) apply_spooled_messages(xid, commit_data.commit_lsn); - apply_handle_commit_internal(s, &commit_data); + apply_handle_commit_internal(&commit_data); /* unlink the files with serialized changes and subxact info */ stream_cleanup_files(MyLogicalRepWorker->subid, xid); @@ -1430,7 +1429,7 @@ apply_handle_stream_commit(StringInfo s) * Helper function for apply_handle_commit and apply_handle_stream_commit. */ static void -apply_handle_commit_internal(StringInfo s, LogicalRepCommitData *commit_data) +apply_handle_commit_internal(LogicalRepCommitData *commit_data) { if (IsTransactionState()) { |