external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reorder ifdefs

pull/7229/head
EmelSimsek 2023-10-09 15:01:05 +03:00 committed by Emel Şimşek
parent c69b45f058
commit 081fb94269
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/shardsplit/shardsplit_decoder.c
View File

@ -98,7 +98,7 @@ replication_origin_filter_cb(LogicalDecodingContext *ctx, RepOriginId origin_id)
* reordering phase which is above change_cb. So we do not need to send keepalive in * reordering phase which is above change_cb. So we do not need to send keepalive in
* change_cb. * change_cb.
*/ */
#if (PG_VERSION_NUM <= PG_VERSION_15) #if (PG_VERSION_NUM < PG_VERSION_16)
static void static void
update_replication_progress(LogicalDecodingContext *ctx, bool skipped_xact) update_replication_progress(LogicalDecodingContext *ctx, bool skipped_xact)
{ {
@ -118,7 +118,7 @@ update_replication_progress(LogicalDecodingContext *ctx, bool skipped_xact)
*/ */
if (ctx->end_xact || ++changes_count >= CHANGES_THRESHOLD) if (ctx->end_xact || ++changes_count >= CHANGES_THRESHOLD)
{ {
#if (PG_VERSION_NUM == PG_VERSION_15) #if (PG_VERSION_NUM >= PG_VERSION_15)
OutputPluginUpdateProgress(ctx, skipped_xact); OutputPluginUpdateProgress(ctx, skipped_xact);
#else #else
OutputPluginUpdateProgress(ctx); OutputPluginUpdateProgress(ctx);
@ -148,7 +148,7 @@ shard_split_change_cb(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
return; return;
} }
#if (PG_VERSION_NUM <= PG_VERSION_15) #if (PG_VERSION_NUM < PG_VERSION_16)
/* Send replication keepalive. */ /* Send replication keepalive. */
update_replication_progress(ctx, false); update_replication_progress(ctx, false);