From 4cd7a189687171374ff302ad71c99d39ff6d2bab Mon Sep 17 00:00:00 2001 From: Amit Kapila Date: Thu, 19 Aug 2021 09:34:26 +0530 Subject: 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 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'src/backend/replication') 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; -- cgit v1.2.3