diff options
Diffstat (limited to 'src/backend/replication')
| -rw-r--r-- | src/backend/replication/logical/snapbuild.c | 2 | ||||
| -rw-r--r-- | src/backend/replication/pgoutput/pgoutput.c | 5 |
2 files changed, 4 insertions, 3 deletions
diff --git a/src/backend/replication/logical/snapbuild.c b/src/backend/replication/logical/snapbuild.c index c2e3c85914e..428d7aa55eb 100644 --- a/src/backend/replication/logical/snapbuild.c +++ b/src/backend/replication/logical/snapbuild.c @@ -176,7 +176,7 @@ struct SnapBuild */ TransactionId initial_xmin_horizon; - /* Indicates if we are building full snapshot or just catalog one .*/ + /* Indicates if we are building full snapshot or just catalog one. */ bool building_full_snapshot; /* diff --git a/src/backend/replication/pgoutput/pgoutput.c b/src/backend/replication/pgoutput/pgoutput.c index 4ddfbf7a98b..694f351dd8e 100644 --- a/src/backend/replication/pgoutput/pgoutput.c +++ b/src/backend/replication/pgoutput/pgoutput.c @@ -221,14 +221,15 @@ pgoutput_begin_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn) OutputPluginWrite(ctx, false); OutputPluginPrepareWrite(ctx, true); - /* - * XXX: which behaviour we want here? + /*---------- + * XXX: which behaviour do we want here? * * Alternatives: * - don't send origin message if origin name not found * (that's what we do now) * - throw error - that will break replication, not good * - send some special "unknown" origin + *---------- */ if (replorigin_by_oid(txn->origin_id, true, &origin)) logicalrep_write_origin(ctx->out, origin, txn->origin_lsn); |