mirror of https://github.com/citusdata/citus.git
rename
parent
cd20ab76c0
commit
d9d9519300
|
@ -165,7 +165,7 @@ static NonMainDbDistributeObjectOps Role_SecLabel = {
|
||||||
const NonMainDbDistributeObjectOps * GetNonMainDbDistributeObjectOps(Node *parsetree);
|
const NonMainDbDistributeObjectOps * GetNonMainDbDistributeObjectOps(Node *parsetree);
|
||||||
static void MarkObjectDistributedGloballyOnMainDbs(
|
static void MarkObjectDistributedGloballyOnMainDbs(
|
||||||
MarkDistributedGloballyParams *markDistributedParams);
|
MarkDistributedGloballyParams *markDistributedParams);
|
||||||
static void UnmarkObjectDistributedOnLocalMainDb(List *unmarkDistributedList);
|
static void UnmarkObjectsDistributedOnLocalMainDb(List *unmarkDistributedList);
|
||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -221,7 +221,7 @@ RunPreprocessNonMainDBCommand(Node *parsetree)
|
||||||
if (ops->getUnmarkDistributedParams)
|
if (ops->getUnmarkDistributedParams)
|
||||||
{
|
{
|
||||||
List *unmarkDistributedParamsList = ops->getUnmarkDistributedParams(parsetree);
|
List *unmarkDistributedParamsList = ops->getUnmarkDistributedParams(parsetree);
|
||||||
UnmarkObjectDistributedOnLocalMainDb(unmarkDistributedParamsList);
|
UnmarkObjectsDistributedOnLocalMainDb(unmarkDistributedParamsList);
|
||||||
}
|
}
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
|
@ -377,11 +377,11 @@ MarkObjectDistributedGloballyOnMainDbs(
|
||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* UnmarkObjectDistributedOnLocalMainDb unmarks a list of objects as
|
* UnmarkObjectsDistributedOnLocalMainDb unmarks a list of objects as
|
||||||
* distributed on the local main database.
|
* distributed on the local main database.
|
||||||
*/
|
*/
|
||||||
static void
|
static void
|
||||||
UnmarkObjectDistributedOnLocalMainDb(List *unmarkDistributedParamsList)
|
UnmarkObjectsDistributedOnLocalMainDb(List *unmarkDistributedParamsList)
|
||||||
{
|
{
|
||||||
int subObjectId = 0;
|
int subObjectId = 0;
|
||||||
char *checkObjectExistence = "false";
|
char *checkObjectExistence = "false";
|
||||||
|
|
Loading…
Reference in New Issue