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

Second commit to change APIs

metadata_sync_imp
Onder Kalaci 2022-11-28 09:50:22 +01:00
parent db9cebf295
commit 3f72a6c1d2
3 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/backend/distributed/commands/dependencies.c
View File

@ -531,11 +531,12 @@ GetAllDependencyCreateDDLCommands(const List *dependencies)
* previously marked objects to a worker node. The function also sets
* clusterHasDistributedFunction if there are any distributed functions.
*/
List *
ReplicateAllObjectsToNodeCommandList(const char *nodeName, int nodePort)
void
ReplicateAllObjectsToNodeCommandList(const char *nodeName, int nodePort,
List **ddlCommands)
{
/* since we are executing ddl commands disable propagation first, primarily for mx */
List *ddlCommands = list_make1(DISABLE_DDL_PROPAGATION);
*ddlCommands = list_make1(DISABLE_DDL_PROPAGATION);
/*
* collect all dependencies in creation order and get their ddl commands
@ -578,13 +579,11 @@ ReplicateAllObjectsToNodeCommandList(const char *nodeName, int nodePort)
continue;
}
ddlCommands = list_concat(ddlCommands,
GetDependencyCreateDDLCommands(dependency));
*ddlCommands = list_concat(*ddlCommands,
GetDependencyCreateDDLCommands(dependency));
}
ddlCommands = lappend(ddlCommands, ENABLE_DDL_PROPAGATION);
return ddlCommands;
*ddlCommands = lappend(*ddlCommands, ENABLE_DDL_PROPAGATION);
}

6
src/backend/distributed/metadata/node_metadata.c
View File

@ -827,8 +827,10 @@ SyncDistributedObjectsCommandList(WorkerNode *workerNode, List **commandList)
/*
* Replicate all objects of the pg_dist_object to the remote node.
*/
*commandList = list_concat(*commandList, ReplicateAllObjectsToNodeCommandList(
workerNode->workerName, workerNode->workerPort));
List *replicateAllObjectsToNodeCommandList = NIL;
ReplicateAllObjectsToNodeCommandList(workerNode->workerName, workerNode->workerPort,
&replicateAllObjectsToNodeCommandList);
*commandList = list_concat(*commandList, replicateAllObjectsToNodeCommandList);
/*
* After creating each table, handle the inter table relationship between

3
src/include/distributed/metadata_utility.h
View File

@ -343,7 +343,8 @@ extern List * GetAllDependencyCreateDDLCommands(const List *dependencies);
extern bool ShouldPropagate(void);
extern bool ShouldPropagateCreateInCoordinatedTransction(void);
extern bool ShouldPropagateAnyObject(List *addresses);
extern List * ReplicateAllObjectsToNodeCommandList(const char *nodeName, int nodePort);
extern void ReplicateAllObjectsToNodeCommandList(const char *nodeName, int nodePort,
List **ddlCommands);
/* Remaining metadata utility functions */
extern Oid TableOwnerOid(Oid relationId);