@@ -309,8 +309,7 @@ static void maybe_reread_subscription(void);
309
309
/* prototype needed because of stream_commit */
310
310
static void apply_dispatch (StringInfo s );
311
311
312
- static void apply_handle_commit_internal (StringInfo s ,
313
- LogicalRepCommitData * commit_data );
312
+ static void apply_handle_commit_internal (LogicalRepCommitData * commit_data );
314
313
static void apply_handle_insert_internal (ApplyExecutionData * edata ,
315
314
ResultRelInfo * relinfo ,
316
315
TupleTableSlot * remoteslot );
@@ -855,7 +854,7 @@ apply_handle_commit(StringInfo s)
855
854
LSN_FORMAT_ARGS (commit_data .commit_lsn ),
856
855
LSN_FORMAT_ARGS (remote_final_lsn ))));
857
856
858
- apply_handle_commit_internal (s , & commit_data );
857
+ apply_handle_commit_internal (& commit_data );
859
858
860
859
/* Process any tables that are being synchronized in parallel. */
861
860
process_syncing_tables (commit_data .end_lsn );
@@ -1415,7 +1414,7 @@ apply_handle_stream_commit(StringInfo s)
1415
1414
1416
1415
apply_spooled_messages (xid , commit_data .commit_lsn );
1417
1416
1418
- apply_handle_commit_internal (s , & commit_data );
1417
+ apply_handle_commit_internal (& commit_data );
1419
1418
1420
1419
/* unlink the files with serialized changes and subxact info */
1421
1420
stream_cleanup_files (MyLogicalRepWorker -> subid , xid );
@@ -1430,7 +1429,7 @@ apply_handle_stream_commit(StringInfo s)
1430
1429
* Helper function for apply_handle_commit and apply_handle_stream_commit.
1431
1430
*/
1432
1431
static void
1433
- apply_handle_commit_internal (StringInfo s , LogicalRepCommitData * commit_data )
1432
+ apply_handle_commit_internal (LogicalRepCommitData * commit_data )
1434
1433
{
1435
1434
if (IsTransactionState ())
1436
1435
{
0 commit comments