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

Make citus_indent happy

pull/2258/head
velioglu 2018-07-06 13:57:42 +03:00
parent 8723a89b03
commit c7213dd377
3 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/distributed/planner/multi_explain.c
View File

@ -492,27 +492,27 @@ BuildRemoteExplainQuery(char *queryString, ExplainState *es)
case EXPLAIN_FORMAT_XML:
{
formatStr = "XML";
}
break;
}
case EXPLAIN_FORMAT_JSON:
{
formatStr = "JSON";
}
break;
}
case EXPLAIN_FORMAT_YAML:
{
formatStr = "YAML";
}
break;
}
default:
{
formatStr = "TEXT";
}
break;
}
}
appendStringInfo(explainQuery,
"EXPLAIN (ANALYZE %s, VERBOSE %s, "

12
src/backend/distributed/planner/shard_pruning.c
View File

@ -632,8 +632,8 @@ AddPartitionKeyRestrictionToInstance(ClauseWalkerContext *context, OpExpr *opCla
prune->lessConsts = constantClause;
}
matchedOp = true;
}
break;
}
case BTLessEqualStrategyNumber:
{
@ -645,8 +645,8 @@ AddPartitionKeyRestrictionToInstance(ClauseWalkerContext *context, OpExpr *opCla
prune->lessEqualConsts = constantClause;
}
matchedOp = true;
}
break;
}
case BTEqualStrategyNumber:
{
@ -662,8 +662,8 @@ AddPartitionKeyRestrictionToInstance(ClauseWalkerContext *context, OpExpr *opCla
prune->evaluatesToFalse = true;
}
matchedOp = true;
}
break;
}
case BTGreaterEqualStrategyNumber:
{
@ -676,8 +676,8 @@ AddPartitionKeyRestrictionToInstance(ClauseWalkerContext *context, OpExpr *opCla
prune->greaterEqualConsts = constantClause;
}
matchedOp = true;
}
break;
}
case BTGreaterStrategyNumber:
{
@ -689,15 +689,15 @@ AddPartitionKeyRestrictionToInstance(ClauseWalkerContext *context, OpExpr *opCla
prune->greaterConsts = constantClause;
}
matchedOp = true;
}
break;
}
case ROWCOMPARE_NE:
{
/* TODO: could add support for this, if we feel like it */
matchedOp = false;
}
break;
}
default:
Assert(false);

8
src/backend/distributed/transaction/transaction_management.c
View File

@ -168,8 +168,8 @@ CoordinatedTransactionCallback(XactEvent event, void *arg)
XactModificationLevel = XACT_MODIFICATION_NONE;
dlist_init(&InProgressTransactions);
CoordinatedTransactionUses2PC = false;
}
break;
}
case XACT_EVENT_ABORT:
{
@ -204,8 +204,8 @@ CoordinatedTransactionCallback(XactEvent event, void *arg)
dlist_init(&InProgressTransactions);
CoordinatedTransactionUses2PC = false;
subXactAbortAttempted = false;
}
break;
}
case XACT_EVENT_PARALLEL_COMMIT:
case XACT_EVENT_PARALLEL_ABORT:
@ -270,8 +270,8 @@ CoordinatedTransactionCallback(XactEvent event, void *arg)
* committed. This handles failure at COMMIT/PREPARE time.
*/
PostCommitMarkFailedShardPlacements(CoordinatedTransactionUses2PC);
}
break;
}
case XACT_EVENT_PARALLEL_PRE_COMMIT:
case XACT_EVENT_PRE_PREPARE:
@ -282,10 +282,10 @@ CoordinatedTransactionCallback(XactEvent event, void *arg)
errmsg("cannot use 2PC in transactions involving "
"multiple servers")));
}
}
break;
}
}
}
/*