diff --git a/doc/src/sgml/ref/pg_createsubscriber.sgml b/doc/src/sgml/ref/pg_createsubscriber.sgml index 0fcd30d..d2bbef3 100644 --- a/doc/src/sgml/ref/pg_createsubscriber.sgml +++ b/doc/src/sgml/ref/pg_createsubscriber.sgml @@ -166,13 +166,8 @@ PostgreSQL documentation - Enables two-phase commit for the subscription. When the option is - provided, it is explicitly enabled. By default, two-phase commit is - off. - Two-phase commit ensures atomicity in logical replication for prepared - transactions. See the - two_phase - documentation for more details. + Enables two_phase + commit for the subscription. The default is false. diff --git a/src/bin/pg_basebackup/pg_createsubscriber.c b/src/bin/pg_basebackup/pg_createsubscriber.c index ce11ab7..799e49b 100644 --- a/src/bin/pg_basebackup/pg_createsubscriber.c +++ b/src/bin/pg_basebackup/pg_createsubscriber.c @@ -229,7 +229,7 @@ usage(void) printf(_(" -P, --publisher-server=CONNSTR publisher connection string\n")); printf(_(" -s, --socketdir=DIR socket directory to use (default current dir.)\n")); printf(_(" -t, --recovery-timeout=SECS seconds to wait for recovery to end\n")); - printf(_(" -T, --enable-two-phase enable two-phase commit for the subscription\n")); + printf(_(" -T, --enable-two-phase enable two-phase commit for the subscription\n")); printf(_(" -U, --subscriber-username=NAME user name for subscriber connection\n")); printf(_(" -v, --verbose output verbose messages\n")); printf(_(" --config-file=FILENAME use specified main server configuration\n" @@ -459,7 +459,7 @@ store_pub_sub_info(const struct CreateSubscriberOptions *opt, conninfo = concat_conninfo_dbname(pub_base_conninfo, cell->val); dbinfo[i].pubconninfo = conninfo; dbinfo[i].dbname = cell->val; - dbinfo[i].two_phase = opt->two_phase; /* Set two-phase option */ + dbinfo[i].two_phase = opt->two_phase; if (num_pubs > 0) dbinfo[i].pubname = pubcell->val; else @@ -484,7 +484,7 @@ store_pub_sub_info(const struct CreateSubscriberOptions *opt, dbinfo[i].pubname ? dbinfo[i].pubname : "(auto)", dbinfo[i].replslotname ? dbinfo[i].replslotname : "(auto)", dbinfo[i].pubconninfo); - pg_log_debug("subscriber(%d): subscription: %s ; connection string: %s, --enable-two-phase: %s", i, + pg_log_debug("subscriber(%d): subscription: %s ; connection string: %s, two_phase: %s", i, dbinfo[i].subname ? dbinfo[i].subname : "(auto)", dbinfo[i].subconninfo, dbinfo[i].two_phase ? "true" : "false");