From 458f820755781d84c43ca8852210a726b6fbcf80 Mon Sep 17 00:00:00 2001
From: gindibay <gindibay@microsoft.com>
Date: Mon, 4 Sep 2023 10:50:40 +0300
Subject: [PATCH] Fixes indentation problems

---
 .../commands/distribute_object_ops.c          |  2 +-
 .../deparser/citus_deparse_set_utils.c        |  7 ++---
 .../deparser/deparse_database_stmts.c         | 31 ++++++++++++-------
 3 files changed, 24 insertions(+), 16 deletions(-)

diff --git a/src/backend/distributed/commands/distribute_object_ops.c b/src/backend/distributed/commands/distribute_object_ops.c
index b3428634b..d36794a94 100644
--- a/src/backend/distributed/commands/distribute_object_ops.c
+++ b/src/backend/distributed/commands/distribute_object_ops.c
@@ -469,7 +469,7 @@ static DistributeObjectOps Database_Rename = {
 static DistributeObjectOps Database_RefreshColl = {
 	.deparse = DeparseAlterDatabaseRefreshCollStmt,
 	.qualify = NULL,
-	.preprocess = NULL,//TODO: Add PostprocessAfter adding addresses
+	.preprocess = NULL,/*TODO: Add PostprocessAfter adding addresses */
 	.postprocess = NULL,
 	.objectType = OBJECT_DATABASE,
 	.operationType = DIST_OPS_ALTER,
diff --git a/src/backend/distributed/deparser/citus_deparse_set_utils.c b/src/backend/distributed/deparser/citus_deparse_set_utils.c
index 7f9119c0f..9d14d7a43 100644
--- a/src/backend/distributed/deparser/citus_deparse_set_utils.c
+++ b/src/backend/distributed/deparser/citus_deparse_set_utils.c
@@ -7,10 +7,8 @@
 #include "utils/guc.h"
 
 
-static void
-AppendVarSetValue2(StringInfo buf, VariableSetStmt *setStmt);
-static void
-AppendVariableSet2(StringInfo buf, VariableSetStmt *setStmt);
+static void AppendVarSetValue2(StringInfo buf, VariableSetStmt *setStmt);
+static void AppendVariableSet2(StringInfo buf, VariableSetStmt *setStmt);
 
 
 static void
@@ -115,6 +113,7 @@ AppendVarSetValue2(StringInfo buf, VariableSetStmt *setStmt)
 	}
 }
 
+
 /*
  * AppendVariableSet appends a string representing the VariableSetStmt to a buffer
  */
diff --git a/src/backend/distributed/deparser/deparse_database_stmts.c b/src/backend/distributed/deparser/deparse_database_stmts.c
index 861b9a74a..10098cf34 100644
--- a/src/backend/distributed/deparser/deparse_database_stmts.c
+++ b/src/backend/distributed/deparser/deparse_database_stmts.c
@@ -32,7 +32,7 @@ char *
 DeparseAlterDatabaseOwnerStmt(Node *node)
 {
 	AlterOwnerStmt *stmt = castNode(AlterOwnerStmt, node);
-	StringInfoData str = {0};
+	StringInfoData str = { 0 };
 	initStringInfo(&str);
 
 	Assert(stmt->objectType == OBJECT_DATABASE);
@@ -42,6 +42,7 @@ DeparseAlterDatabaseOwnerStmt(Node *node)
 	return str.data;
 }
 
+
 static void
 AppendAlterDatabaseOwnerStmt(StringInfo buf, AlterOwnerStmt *stmt)
 {
@@ -49,17 +50,18 @@ AppendAlterDatabaseOwnerStmt(StringInfo buf, AlterOwnerStmt *stmt)
 
 	appendStringInfo(buf,
 					 "ALTER DATABASE %s OWNER TO %s;",
-					 quote_identifier(strVal((String *)stmt->object)),
+					 quote_identifier(strVal((String *) stmt->object)),
 					 RoleSpecString(stmt->newowner, true));
 }
 
+
 static void
 AppendGrantDatabases(StringInfo buf, GrantStmt *stmt)
 {
 	ListCell *cell = NULL;
 	appendStringInfo(buf, " ON DATABASE ");
 
-	foreach (cell, stmt->objects)
+	foreach(cell, stmt->objects)
 	{
 		char *database = strVal(lfirst(cell));
 		appendStringInfoString(buf, quote_identifier(database));
@@ -70,6 +72,7 @@ AppendGrantDatabases(StringInfo buf, GrantStmt *stmt)
 	}
 }
 
+
 static void
 AppendGrantOnDatabaseStmt(StringInfo buf, GrantStmt *stmt)
 {
@@ -223,9 +226,10 @@ AppendAlterDatabaseSetStmt(StringInfo buf, AlterDatabaseSetStmt *stmt)
 static void
 AppendDefElemConnLimit(StringInfo buf, DefElem *def)
 {
-	appendStringInfo(buf, " CONNECTION LIMIT %ld",(long int) defGetNumeric(def));
+	appendStringInfo(buf, " CONNECTION LIMIT %ld", (long int) defGetNumeric(def));
 }
 
+
 static void
 AppendAlterDatabaseStmt(StringInfo buf, AlterDatabaseStmt *stmt)
 {
@@ -253,7 +257,8 @@ AppendAlterDatabaseStmt(StringInfo buf, AlterDatabaseStmt *stmt)
 				ereport(ERROR,
 						errmsg("ALLOW_CONNECTIONS is not supported"));
 			}
-			else{
+			else
+			{
 				ereport(ERROR,
 						errmsg("unrecognized AlterDatabaseStmt option: %s",
 							   def->defname));
@@ -308,7 +313,7 @@ DeparseGrantOnDatabaseStmt(Node *node)
 	GrantStmt *stmt = castNode(GrantStmt, node);
 	Assert(stmt->objtype == OBJECT_DATABASE);
 
-	StringInfoData str = {0};
+	StringInfoData str = { 0 };
 	initStringInfo(&str);
 
 	AppendGrantOnDatabaseStmt(&str, stmt);
@@ -316,12 +321,13 @@ DeparseGrantOnDatabaseStmt(Node *node)
 	return str.data;
 }
 
+
 char *
 DeparseAlterDatabaseStmt(Node *node)
 {
 	AlterDatabaseStmt *stmt = castNode(AlterDatabaseStmt, node);
 
-	StringInfoData str = {0};
+	StringInfoData str = { 0 };
 	initStringInfo(&str);
 
 	AppendAlterDatabaseStmt(&str, stmt);
@@ -333,25 +339,28 @@ DeparseAlterDatabaseStmt(Node *node)
 char *
 DeparseAlterDatabaseRenameStmt(Node *node)
 {
-	RenameStmt *stmt = (RenameStmt *)node;
+	RenameStmt *stmt = (RenameStmt *) node;
 
 	StringInfoData str;
 	initStringInfo(&str);
 
-	appendStringInfo(&str, "ALTER DATABASE %s RENAME TO %s;", quote_identifier(stmt->subname), quote_identifier(stmt->newname));
+	appendStringInfo(&str, "ALTER DATABASE %s RENAME TO %s;", quote_identifier(
+						 stmt->subname), quote_identifier(stmt->newname));
 
 	return str.data;
 }
 
+
 char *
 DeparseAlterDatabaseRefreshCollStmt(Node *node)
 {
-	AlterDatabaseRefreshCollStmt *stmt = (AlterDatabaseRefreshCollStmt *)node;
+	AlterDatabaseRefreshCollStmt *stmt = (AlterDatabaseRefreshCollStmt *) node;
 
 	StringInfoData str;
 	initStringInfo(&str);
 
-	appendStringInfo(&str, "ALTER DATABASE %s REFRESH COLLATION;", quote_identifier(stmt->dbname));
+	appendStringInfo(&str, "ALTER DATABASE %s REFRESH COLLATION;", quote_identifier(
+						 stmt->dbname));
 
 	return str.data;
 }