Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit16bd4be

Browse files
author
Amit Kapila
committed
Remove unused argument in apply_handle_commit_internal().
Oversight in commit0926e96.Author: Masahiko SawadaReviewed-By: Amit KapilaBackpatch-through: 14, where it was introducedDiscussion:https://postgr.es/m/CAD21AoDeScrsHhLyEPYqN3sydg6PxAPVBboK=30xJfUVihNZDA@mail.gmail.com
1 parentce197e9 commit16bd4be

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

‎src/backend/replication/logical/worker.c

Lines changed: 4 additions & 5 deletions
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
staticvoidapply_dispatch(StringInfos);
311311

312-
staticvoidapply_handle_commit_internal(StringInfos,
313-
LogicalRepCommitData*commit_data);
312+
staticvoidapply_handle_commit_internal(LogicalRepCommitData*commit_data);
314313
staticvoidapply_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
staticvoid
1433-
apply_handle_commit_internal(StringInfos,LogicalRepCommitData*commit_data)
1432+
apply_handle_commit_internal(LogicalRepCommitData*commit_data)
14341433
{
14351434
if (IsTransactionState())
14361435
{

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp