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

remove useless checks

metadata_sync_final
Onder Kalaci 2022-12-01 15:05:27 +01:00
parent e577cb0b2e
commit 6c3f58afaa
1 changed files with 3 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -829,26 +829,7 @@ SyncDistributedObjectsCommandList(WorkerNode *workerNode)
static void static void
SyncDistributedObjectsToNodeList(List *workerNodeList) SyncDistributedObjectsToNodeList(List *workerNodeList)
{ {
List *workerNodesToSync = NIL; if (workerNodeList == NIL)
WorkerNode *workerNode = NULL;
foreach_ptr(workerNode, workerNodeList)
{
if (NodeIsCoordinator(workerNode))
{
/* coordinator has all the objects */
continue;
}
if (!NodeIsPrimary(workerNode))
{
/* secondary nodes gets the objects from their primaries via replication */
continue;
}
workerNodesToSync = lappend(workerNodesToSync, workerNode);
}
if (workerNodesToSync == NIL)
{ {
return; return;
} }
@ -857,12 +838,12 @@ SyncDistributedObjectsToNodeList(List *workerNodeList)
Assert(ShouldPropagate()); Assert(ShouldPropagate());
List *commandList = SyncDistributedObjectsCommandList(workerNode); List *commandList = SyncDistributedObjectsCommandList(linitial(workerNodeList));
/* send commands to new workers, the current user should be a superuser */ /* send commands to new workers, the current user should be a superuser */
Assert(superuser()); Assert(superuser());
SendMetadataCommandListToWorkerListInCoordinatedTransaction( SendMetadataCommandListToWorkerListInCoordinatedTransaction(
workerNodesToSync, workerNodeList,
CurrentUserName(), CurrentUserName(),
commandList); commandList);
} }