Skip to content

Commit 16bd4be

Browse files
author
Amit Kapila
committed
Remove unused argument in apply_handle_commit_internal().
Oversight in commit 0926e96. Author: Masahiko Sawada Reviewed-By: Amit Kapila Backpatch-through: 14, where it was introduced Discussion: https://postgr.es/m/CAD21AoDeScrsHhLyEPYqN3sydg6PxAPVBboK=30xJfUVihNZDA@mail.gmail.com
1 parent ce197e9 commit 16bd4be

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

src/backend/replication/logical/worker.c

+4-5
Original file line numberDiff line numberDiff line change
@@ -309,8 +309,7 @@ static void maybe_reread_subscription(void);
309309
/* prototype needed because of stream_commit */
310310
static void apply_dispatch(StringInfo s);
311311

312-
static void apply_handle_commit_internal(StringInfo s,
313-
LogicalRepCommitData *commit_data);
312+
static void apply_handle_commit_internal(LogicalRepCommitData *commit_data);
314313
static void apply_handle_insert_internal(ApplyExecutionData *edata,
315314
ResultRelInfo *relinfo,
316315
TupleTableSlot *remoteslot);
@@ -855,7 +854,7 @@ apply_handle_commit(StringInfo s)
855854
LSN_FORMAT_ARGS(commit_data.commit_lsn),
856855
LSN_FORMAT_ARGS(remote_final_lsn))));
857856

858-
apply_handle_commit_internal(s, &commit_data);
857+
apply_handle_commit_internal(&commit_data);
859858

860859
/* Process any tables that are being synchronized in parallel. */
861860
process_syncing_tables(commit_data.end_lsn);
@@ -1415,7 +1414,7 @@ apply_handle_stream_commit(StringInfo s)
14151414

14161415
apply_spooled_messages(xid, commit_data.commit_lsn);
14171416

1418-
apply_handle_commit_internal(s, &commit_data);
1417+
apply_handle_commit_internal(&commit_data);
14191418

14201419
/* unlink the files with serialized changes and subxact info */
14211420
stream_cleanup_files(MyLogicalRepWorker->subid, xid);
@@ -1430,7 +1429,7 @@ apply_handle_stream_commit(StringInfo s)
14301429
* Helper function for apply_handle_commit and apply_handle_stream_commit.
14311430
*/
14321431
static void
1433-
apply_handle_commit_internal(StringInfo s, LogicalRepCommitData *commit_data)
1432+
apply_handle_commit_internal(LogicalRepCommitData *commit_data)
14341433
{
14351434
if (IsTransactionState())
14361435
{

0 commit comments

Comments
 (0)