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

Commitf4b939f

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 parentf951f6f commitf4b939f

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
@@ -235,8 +235,7 @@ static void maybe_reread_subscription(void);
235235
/* prototype needed because of stream_commit */
236236
staticvoidapply_dispatch(StringInfos);
237237

238-
staticvoidapply_handle_commit_internal(StringInfos,
239-
LogicalRepCommitData*commit_data);
238+
staticvoidapply_handle_commit_internal(LogicalRepCommitData*commit_data);
240239
staticvoidapply_handle_insert_internal(ApplyExecutionData*edata,
241240
ResultRelInfo*relinfo,
242241
TupleTableSlot*remoteslot);
@@ -775,7 +774,7 @@ apply_handle_commit(StringInfo s)
775774
LSN_FORMAT_ARGS(commit_data.commit_lsn),
776775
LSN_FORMAT_ARGS(remote_final_lsn))));
777776

778-
apply_handle_commit_internal(s,&commit_data);
777+
apply_handle_commit_internal(&commit_data);
779778

780779
/* Process any tables that are being synchronized in parallel. */
781780
process_syncing_tables(commit_data.end_lsn);
@@ -1133,7 +1132,7 @@ apply_handle_stream_commit(StringInfo s)
11331132
elog(DEBUG1,"replayed %d (all) changes from file \"%s\"",
11341133
nchanges,path);
11351134

1136-
apply_handle_commit_internal(s,&commit_data);
1135+
apply_handle_commit_internal(&commit_data);
11371136

11381137
/* unlink the files with serialized changes and subxact info */
11391138
stream_cleanup_files(MyLogicalRepWorker->subid,xid);
@@ -1148,7 +1147,7 @@ apply_handle_stream_commit(StringInfo s)
11481147
* Helper function for apply_handle_commit and apply_handle_stream_commit.
11491148
*/
11501149
staticvoid
1151-
apply_handle_commit_internal(StringInfos,LogicalRepCommitData*commit_data)
1150+
apply_handle_commit_internal(LogicalRepCommitData*commit_data)
11521151
{
11531152
if (IsTransactionState())
11541153
{

0 commit comments

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