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

Rename function ShouldMarkRelationDistributedOnUpgrade

velioglu/prop_dep_view_review
Ahmet Gedemenli 2022-05-23 12:27:05 +03:00
parent c322f4d1aa
commit a4bd0536ea
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/distributed/commands/extension.c
View File

@ -512,7 +512,7 @@ MarkExistingObjectDependenciesDistributedIfSupported()
Oid citusTableId = InvalidOid; Oid citusTableId = InvalidOid;
foreach_oid(citusTableId, citusTableIdList) foreach_oid(citusTableId, citusTableIdList)
{ {
if (!ShouldMarkRelationDistributedOnUpgrade(citusTableId)) if (!ShouldMarkRelationDistributed(citusTableId))
{ {
continue; continue;
} }
@ -556,7 +556,7 @@ MarkExistingObjectDependenciesDistributedIfSupported()
Oid viewOid = InvalidOid; Oid viewOid = InvalidOid;
foreach_oid(viewOid, viewList) foreach_oid(viewOid, viewList)
{ {
if (!ShouldMarkRelationDistributedOnUpgrade(viewOid)) if (!ShouldMarkRelationDistributed(viewOid))
{ {
continue; continue;
} }
@ -654,12 +654,12 @@ GetAllViews(void)
/* /*
* ShouldMarkRelationDistributedOnUpgrade is a helper function that * ShouldMarkRelationDistributed is a helper function that
* decides whether the input relation should be marked as distributed * decides whether the input relation should be marked as distributed
* during the upgrade. * during the upgrade.
*/ */
bool bool
ShouldMarkRelationDistributedOnUpgrade(Oid relationId) ShouldMarkRelationDistributed(Oid relationId)
{ {
if (!EnableMetadataSync) if (!EnableMetadataSync)
{ {

2
src/backend/distributed/metadata/metadata_sync.c
View File

@ -337,7 +337,7 @@ CreateDependentViewsOnWorkers(Oid relationId)
Oid viewOid = InvalidOid; Oid viewOid = InvalidOid;
foreach_oid(viewOid, views) foreach_oid(viewOid, views)
{ {
if (!ShouldMarkRelationDistributedOnUpgrade(viewOid)) if (!ShouldMarkRelationDistributed(viewOid))
{ {
continue; continue;
} }

2
src/include/distributed/commands.h
View File

@ -181,7 +181,7 @@ extern Oid get_constraint_typid(Oid conoid);
/* extension.c - forward declarations */ /* extension.c - forward declarations */
extern bool IsDropCitusExtensionStmt(Node *parsetree); extern bool IsDropCitusExtensionStmt(Node *parsetree);
extern bool IsCreateAlterExtensionUpdateCitusStmt(Node *parsetree); extern bool IsCreateAlterExtensionUpdateCitusStmt(Node *parsetree);
extern bool ShouldMarkRelationDistributedOnUpgrade(Oid relationId); extern bool ShouldMarkRelationDistributed(Oid relationId);
extern void ErrorIfUnstableCreateOrAlterExtensionStmt(Node *parsetree); extern void ErrorIfUnstableCreateOrAlterExtensionStmt(Node *parsetree);
extern List * PostprocessCreateExtensionStmt(Node *stmt, const char *queryString); extern List * PostprocessCreateExtensionStmt(Node *stmt, const char *queryString);
extern List * PreprocessDropExtensionStmt(Node *stmt, const char *queryString, extern List * PreprocessDropExtensionStmt(Node *stmt, const char *queryString,