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

different example use

feature/foreach_index
Nils Dijk 2021-11-03 16:41:21 +01:00
parent 0a704da5fe
commit 88e2c1f8da
No known key found for this signature in database
GPG Key ID: CA1177EF9434F241
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -754,7 +754,6 @@ NodeListInsertCommand(List *workerNodeList)
{ {
StringInfo nodeListInsertCommand = makeStringInfo(); StringInfo nodeListInsertCommand = makeStringInfo();
int workerCount = list_length(workerNodeList); int workerCount = list_length(workerNodeList);
int processedWorkerNodeCount = 0;
Oid primaryRole = PrimaryNodeRoleId(); Oid primaryRole = PrimaryNodeRoleId();
/* if there are no workers, return NULL */ /* if there are no workers, return NULL */
@ -790,6 +789,11 @@ NodeListInsertCommand(List *workerNodeList)
Datum nodeRoleStringDatum = DirectFunctionCall1(enum_out, nodeRoleOidDatum); Datum nodeRoleStringDatum = DirectFunctionCall1(enum_out, nodeRoleOidDatum);
char *nodeRoleString = DatumGetCString(nodeRoleStringDatum); char *nodeRoleString = DatumGetCString(nodeRoleStringDatum);
if (!foreach_first(workerNode))
{
appendStringInfo(nodeListInsertCommand, ",");
}
appendStringInfo(nodeListInsertCommand, appendStringInfo(nodeListInsertCommand,
"(%d, %d, %s, %d, %s, %s, %s, %s, '%s'::noderole, %s, %s)", "(%d, %d, %s, %d, %s, %s, %s, %s, '%s'::noderole, %s, %s)",
workerNode->nodeId, workerNode->nodeId,
@ -803,12 +807,6 @@ NodeListInsertCommand(List *workerNodeList)
nodeRoleString, nodeRoleString,
quote_literal_cstr(workerNode->nodeCluster), quote_literal_cstr(workerNode->nodeCluster),
shouldHaveShards); shouldHaveShards);
processedWorkerNodeCount++;
if (processedWorkerNodeCount != workerCount)
{
appendStringInfo(nodeListInsertCommand, ",");
}
} }
return nodeListInsertCommand->data; return nodeListInsertCommand->data;