database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-05-06 19:59:18 +03:00
Code

Rename LOGICAL_REP_MSG_STREAM_END to LOGICAL_REP_MSG_STREAM_STOP.

Browse Source 
In the code, most places used the term "Stream Stop" for the logical
stream message. This commit improves consistency by renaming LogicalRepMsgType
"LOGICAL_REP_MSG_STREAM_END" to "LOGICAL_REP_MSG_STREAM_STOP".

Author: Masahiko Sawada
Reviewed-by: Hou Zhijie, Amit Kapila
Discussion: https://postgr.es/m/CAD21AoDeScrsHhLyEPYqN3sydg6PxAPVBboK=30xJfUVihNZDA@mail.gmail.com
This commit is contained in:
Amit Kapila 2021-08-19 09:34:26 +05:30
parent 0ac1aee0d7
commit 4cd7a18968
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/replication/logical/proto.c
View File

@ -1074,7 +1074,7 @@ logicalrep_read_stream_start(StringInfo in, bool *first_segment)
void void
logicalrep_write_stream_stop(StringInfo out) logicalrep_write_stream_stop(StringInfo out)
{ {
pq_sendbyte(out, LOGICAL_REP_MSG_STREAM_END); pq_sendbyte(out, LOGICAL_REP_MSG_STREAM_STOP);
} }
/* /*

2
src/backend/replication/logical/worker.c
View File

@ -2380,7 +2380,7 @@ apply_dispatch(StringInfo s)
apply_handle_stream_start(s); apply_handle_stream_start(s);
return; return;
case LOGICAL_REP_MSG_STREAM_END: case LOGICAL_REP_MSG_STREAM_STOP:
apply_handle_stream_stop(s); apply_handle_stream_stop(s);
return; return;

2
src/include/replication/logicalproto.h
View File

@ -65,7 +65,7 @@ typedef enum LogicalRepMsgType
LOGICAL_REP_MSG_COMMIT_PREPARED = 'K', LOGICAL_REP_MSG_COMMIT_PREPARED = 'K',
LOGICAL_REP_MSG_ROLLBACK_PREPARED = 'r', LOGICAL_REP_MSG_ROLLBACK_PREPARED = 'r',
LOGICAL_REP_MSG_STREAM_START = 'S', LOGICAL_REP_MSG_STREAM_START = 'S',
LOGICAL_REP_MSG_STREAM_END = 'E', LOGICAL_REP_MSG_STREAM_STOP = 'E',
LOGICAL_REP_MSG_STREAM_COMMIT = 'c', LOGICAL_REP_MSG_STREAM_COMMIT = 'c',
LOGICAL_REP_MSG_STREAM_ABORT = 'A', LOGICAL_REP_MSG_STREAM_ABORT = 'A',
LOGICAL_REP_MSG_STREAM_PREPARE = 'p' LOGICAL_REP_MSG_STREAM_PREPARE = 'p'