diff options
| author | Amit Kapila <akapila@postgresql.org> | 2020-11-26 09:21:14 +0530 |
|---|---|---|
| committer | Amit Kapila <akapila@postgresql.org> | 2020-11-26 09:21:14 +0530 |
| commit | f3a8f73ec274bf8cc6066ea315f1a5a022214b02 (patch) | |
| tree | 68114b10df7dde8f3f4ee2a5c60ec42d2b178d6b | |
| parent | c98763bf51bf610b3ee7e209fc76c3ff9a6b3163 (diff) | |
| download | postgresql-f3a8f73ec274bf8cc6066ea315f1a5a022214b02.tar.gz postgresql-f3a8f73ec274bf8cc6066ea315f1a5a022214b02.zip | |
Use Enums for logical replication message types at more places.
Commit 644f0d7cc9 added logical replication message type enums to use
instead of character literals but some char substitutions were overlooked.
Author: Peter Smith
Reviewed-by: Amit Kapila
Discussion: https://postgr.es/m/CAHut+PsTG=Vrv8hgrvOnAvCNR21jhqMdPk2n0a1uJPoW0p+UfQ@mail.gmail.com
| -rw-r--r-- | src/backend/replication/logical/worker.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index 04684912dea..4e8e2965b82 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -304,7 +304,7 @@ ensure_transaction(void) * Returns true for streamed transactions, false otherwise (regular mode). */ static bool -handle_streamed_transaction(const char action, StringInfo s) +handle_streamed_transaction(LogicalRepMsgType action, StringInfo s) { TransactionId xid; @@ -1090,7 +1090,7 @@ apply_handle_relation(StringInfo s) { LogicalRepRelation *rel; - if (handle_streamed_transaction('R', s)) + if (handle_streamed_transaction(LOGICAL_REP_MSG_RELATION, s)) return; rel = logicalrep_read_rel(s); @@ -1108,7 +1108,7 @@ apply_handle_type(StringInfo s) { LogicalRepTyp typ; - if (handle_streamed_transaction('Y', s)) + if (handle_streamed_transaction(LOGICAL_REP_MSG_TYPE, s)) return; logicalrep_read_typ(s, &typ); @@ -1148,7 +1148,7 @@ apply_handle_insert(StringInfo s) TupleTableSlot *remoteslot; MemoryContext oldctx; - if (handle_streamed_transaction('I', s)) + if (handle_streamed_transaction(LOGICAL_REP_MSG_INSERT, s)) return; ensure_transaction(); @@ -1269,7 +1269,7 @@ apply_handle_update(StringInfo s) RangeTblEntry *target_rte; MemoryContext oldctx; - if (handle_streamed_transaction('U', s)) + if (handle_streamed_transaction(LOGICAL_REP_MSG_UPDATE, s)) return; ensure_transaction(); @@ -1426,7 +1426,7 @@ apply_handle_delete(StringInfo s) TupleTableSlot *remoteslot; MemoryContext oldctx; - if (handle_streamed_transaction('D', s)) + if (handle_streamed_transaction(LOGICAL_REP_MSG_DELETE, s)) return; ensure_transaction(); @@ -1795,7 +1795,7 @@ apply_handle_truncate(StringInfo s) List *relids_logged = NIL; ListCell *lc; - if (handle_streamed_transaction('T', s)) + if (handle_streamed_transaction(LOGICAL_REP_MSG_TRUNCATE, s)) return; ensure_transaction(); |