From 27ecd449901c0b81fe9738b9fb1421c9b0d20d05 Mon Sep 17 00:00:00 2001 From: Peter Smith Date: Thu, 10 Dec 2020 16:38:05 +1100 Subject: [PATCH v7] 2PC - change tablesync slot to use same two_phase mode as apply slot --- src/backend/replication/logical/worker.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index e14fe62..9271f87 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -2759,7 +2759,7 @@ maybe_reread_subscription(void) strcmp(newsub->slotname, MySubscription->slotname) != 0 || newsub->binary != MySubscription->binary || newsub->stream != MySubscription->stream || - (!am_tablesync_worker() && newsub->twophase != MySubscription->twophase) || + newsub->twophase != MySubscription->twophase || !equal(newsub->publications, MySubscription->publications)) { ereport(LOG, @@ -3406,7 +3406,7 @@ ApplyWorkerMain(Datum main_arg) options.proto.logical.publication_names = MySubscription->publications; options.proto.logical.binary = MySubscription->binary; options.proto.logical.streaming = MySubscription->stream; - options.proto.logical.twophase = MySubscription->twophase && !am_tablesync_worker(); + options.proto.logical.twophase = MySubscription->twophase; /* Start normal logical streaming replication. */ walrcv_startstreaming(wrconn, &options); -- 1.8.3.1