From c375b583352500c2af5f08ac4484e220388c2c06 Mon Sep 17 00:00:00 2001 From: Onur Tirtir Date: Fri, 14 Mar 2025 18:19:50 +0300 Subject: [PATCH] style --- src/backend/distributed/metadata/node_metadata.c | 7 ++++--- .../distributed/sql/downgrades/citus--12.2-1--12.1-1.sql | 2 +- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index 25c2ff276..d9728f9f8 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -1665,6 +1665,7 @@ citus_is_coordinator(PG_FUNCTION_ARGS) PG_RETURN_BOOL(isCoordinator); } + /* * citus_is_primary_node returns whether the current node is a primary for * a given group_id. We consider the node a primary if it has @@ -1675,14 +1676,13 @@ citus_is_primary_node(PG_FUNCTION_ARGS) { CheckCitusVersion(ERROR); - bool isPrimary = false; int32 groupId = GetLocalGroupId(); WorkerNode *workerNode = PrimaryNodeForGroup(groupId, NULL); if (workerNode == NULL) { ereport(WARNING, (errmsg("could not find the current node in pg_dist_node"), errdetail("If this is the coordinator node, consider adding it " - "into the metadata by using citus_set_coordinator_host() " + "into the metadata by using citus_set_coordinator_host() " "UDF. Otherwise, if you're going to use this node as a " "worker node for a new cluster, make sure to add this " "node into the metadata from the coordinator by using " @@ -1690,11 +1690,12 @@ citus_is_primary_node(PG_FUNCTION_ARGS) PG_RETURN_NULL(); } - isPrimary = workerNode->nodeId == GetLocalNodeId(); + bool isPrimary = workerNode->nodeId == GetLocalNodeId(); PG_RETURN_BOOL(isPrimary); } + /* * EnsureParentSessionHasExclusiveLockOnPgDistNode ensures given session id * holds Exclusive lock on pg_dist_node. diff --git a/src/backend/distributed/sql/downgrades/citus--12.2-1--12.1-1.sql b/src/backend/distributed/sql/downgrades/citus--12.2-1--12.1-1.sql index 5b0d2c371..a3b1caf6a 100644 --- a/src/backend/distributed/sql/downgrades/citus--12.2-1--12.1-1.sql +++ b/src/backend/distributed/sql/downgrades/citus--12.2-1--12.1-1.sql @@ -39,5 +39,5 @@ DROP FUNCTION citus_internal.update_placement_metadata(bigint, integer, integer) DROP FUNCTION citus_internal.update_relation_colocation(oid, int); DROP FUNCTION citus_internal.start_replication_origin_tracking(); DROP FUNCTION citus_internal.stop_replication_origin_tracking(); -DROP FUNCTION citus_internal.is_replication_origin_tracking_active(); +DROP FUNCTION citus_internal.is_replication_origin_tracking_active(); #include "../udfs/citus_finish_pg_upgrade/12.1-1.sql"