Remove unused argument in apply_handle_commit_internal().
authorAmit Kapila <akapila@postgresql.org>
Fri, 30 Jul 2021 02:47:38 +0000 (08:17 +0530)
committerAmit Kapila <akapila@postgresql.org>
Fri, 30 Jul 2021 02:47:38 +0000 (08:17 +0530)
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

src/backend/replication/logical/worker.c

index 3f499b11f72d9c7919a0273bcd821b5512bf9e3c..249de807984ea0c9d41c241a4e9db8c6f6f3c4b4 100644 (file)
@@ -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())
        {