postgres.git / summary / log / commit / refs

commit    4cd7a189687171374ff302ad71c99d39ff6d2bab
Author:   Amit Kapila <akapila@postgresql.org>
Date:     Thu Aug 19 04:04:26 2021 +0000
First released in: 15.0

    Rename LOGICAL_REP_MSG_STREAM_END to LOGICAL_REP_MSG_STREAM_STOP.
    
    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


 src/backend/replication/logical/proto.c  | 2 +-
 src/backend/replication/logical/worker.c | 2 +-
 src/include/replication/logicalproto.h   | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/backend/replication/logical/proto.c b/src/backend/replication/logical/proto.c
index 52b65e95721..9732982d936 100644
--- a/src/backend/replication/logical/proto.c
+++ b/src/backend/replication/logical/proto.c
@@ -1074,7 +1074,7 @@ logicalrep_read_stream_start(StringInfo in, bool *first_segment)
 void
 logicalrep_write_stream_stop(StringInfo out)
 {
-	pq_sendbyte(out, LOGICAL_REP_MSG_STREAM_END);
+	pq_sendbyte(out, LOGICAL_REP_MSG_STREAM_STOP);
 }
 
 /*
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c
index ecaed157f29..38b493e4f5a 100644
--- a/src/backend/replication/logical/worker.c
+++ b/src/backend/replication/logical/worker.c
@@ -2380,7 +2380,7 @@ apply_dispatch(StringInfo s)
 			apply_handle_stream_start(s);
 			return;
 
-		case LOGICAL_REP_MSG_STREAM_END:
+		case LOGICAL_REP_MSG_STREAM_STOP:
 			apply_handle_stream_stop(s);
 			return;
 
diff --git a/src/include/replication/logicalproto.h b/src/include/replication/logicalproto.h
index 2e295131512..95c1561ca0a 100644
--- a/src/include/replication/logicalproto.h
+++ b/src/include/replication/logicalproto.h
@@ -65,7 +65,7 @@ typedef enum LogicalRepMsgType
 	LOGICAL_REP_MSG_COMMIT_PREPARED = 'K',
 	LOGICAL_REP_MSG_ROLLBACK_PREPARED = 'r',
 	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_ABORT = 'A',
 	LOGICAL_REP_MSG_STREAM_PREPARE = 'p'


[parent: 0ac1aee0d7d8]