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

Fixes code style

grant_database_2pc_onur_1
gurkanindibay 2024-01-23 16:42:49 +03:00
parent 2da1fb1ff8
commit 42105686a3
1 changed files with 20 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/backend/distributed/commands/utility_hook.c
View File

@ -154,7 +154,8 @@ static void RunPreprocessMainDBCommand(Node *parsetree, const char *queryString)
static void RunPostprocessMainDBCommand(Node *parsetree); static void RunPostprocessMainDBCommand(Node *parsetree);
static bool IsStatementSupportedIn2PC(Node *parsetree); static bool IsStatementSupportedIn2PC(Node *parsetree);
static bool DoesStatementRequireMarkDistributedFor2PC(Node *parsetree); static bool DoesStatementRequireMarkDistributedFor2PC(Node *parsetree);
static bool IsObjectTypeSupported(Node *parsetree, TwoPcStatementInfo twoPcSupportedStatement); static bool IsObjectTypeSupported(Node *parsetree, TwoPcStatementInfo
twoPcSupportedStatement);
/* /*
* ProcessUtilityParseTree is a convenience method to create a PlannedStmt out of * ProcessUtilityParseTree is a convenience method to create a PlannedStmt out of
@ -1711,26 +1712,29 @@ IsStatementSupportedIn2PC(Node *parsetree)
return false; return false;
} }
/* /*
* IsObjectTypeSupported returns true if the object type is supported in 2pc * IsObjectTypeSupported returns true if the object type is supported in 2pc
*/ */
bool IsObjectTypeSupported(Node *parsetree, TwoPcStatementInfo twoPcSupportedStatement) bool
IsObjectTypeSupported(Node *parsetree, TwoPcStatementInfo twoPcSupportedStatement)
{ {
NodeTag type = nodeTag(parsetree); NodeTag type = nodeTag(parsetree);
if (type == T_GrantStmt) if (type == T_GrantStmt)
{ {
GrantStmt *stmt = castNode(GrantStmt, parsetree); GrantStmt *stmt = castNode(GrantStmt, parsetree);
/* check if stmt->objtype is in supportedObjectTypes */
for (int j = 0; j < twoPcSupportedStatement.supportedObjectTypesSize; j++) /* check if stmt->objtype is in supportedObjectTypes */
{ for (int j = 0; j < twoPcSupportedStatement.supportedObjectTypesSize; j++)
if (stmt->objtype == twoPcSupportedStatement.supportedObjectTypes[j]) {
{ if (stmt->objtype == twoPcSupportedStatement.supportedObjectTypes[j])
return true; {
} return true;
} }
return false; }
} return false;
return false; }
return false;
} }