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

Commit4cd7a18

Browse files
author
Amit Kapila
committed
Rename LOGICAL_REP_MSG_STREAM_END to LOGICAL_REP_MSG_STREAM_STOP.
In the code, most places used the term "Stream Stop" for the logicalstream message. This commit improves consistency by renaming LogicalRepMsgType"LOGICAL_REP_MSG_STREAM_END" to "LOGICAL_REP_MSG_STREAM_STOP".Author: Masahiko SawadaReviewed-by: Hou Zhijie, Amit KapilaDiscussion:https://postgr.es/m/CAD21AoDeScrsHhLyEPYqN3sydg6PxAPVBboK=30xJfUVihNZDA@mail.gmail.com
1 parent0ac1aee commit4cd7a18

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1074,7 +1074,7 @@ logicalrep_read_stream_start(StringInfo in, bool *first_segment)
10741074
void
10751075
logicalrep_write_stream_stop(StringInfoout)
10761076
{
1077-
pq_sendbyte(out,LOGICAL_REP_MSG_STREAM_END);
1077+
pq_sendbyte(out,LOGICAL_REP_MSG_STREAM_STOP);
10781078
}
10791079

10801080
/*

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2380,7 +2380,7 @@ apply_dispatch(StringInfo s)
23802380
apply_handle_stream_start(s);
23812381
return;
23822382

2383-
caseLOGICAL_REP_MSG_STREAM_END:
2383+
caseLOGICAL_REP_MSG_STREAM_STOP:
23842384
apply_handle_stream_stop(s);
23852385
return;
23862386

‎src/include/replication/logicalproto.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ typedef enum LogicalRepMsgType
6565
LOGICAL_REP_MSG_COMMIT_PREPARED='K',
6666
LOGICAL_REP_MSG_ROLLBACK_PREPARED='r',
6767
LOGICAL_REP_MSG_STREAM_START='S',
68-
LOGICAL_REP_MSG_STREAM_END='E',
68+
LOGICAL_REP_MSG_STREAM_STOP='E',
6969
LOGICAL_REP_MSG_STREAM_COMMIT='c',
7070
LOGICAL_REP_MSG_STREAM_ABORT='A',
7171
LOGICAL_REP_MSG_STREAM_PREPARE='p'

0 commit comments

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