Lines Matching refs:workerPort

562 										   newWorkerNode->workerPort);  in SetUpDistributedTableDependencies()
577 											  newWorkerNode->workerPort);  in SetUpDistributedTableDependencies()
624 												  newWorkerNode->workerPort,  in PropagateNodeWideObjects()
666 	ActivateNode(workerNode->workerName, workerNode->workerPort);  in citus_activate_node()
1171 	searchedNode->workerPort = nodePort;  in FindWorkerNode()
1487 								 coordinator->workerPort)));  in AddNodeMetadata()
1603 			worker->workerName, worker->workerPort,  in SetWorkerColumnOptional()
1613 									 workerNode->workerName, workerNode->workerPort,  in SetWorkerColumnOptional()
1614 									 worker->workerName, worker->workerPort,  in SetWorkerColumnOptional()
1615 									 worker->workerName, worker->workerPort)));  in SetWorkerColumnOptional()
1630 	return FindWorkerNode(workerNode->workerName, workerNode->workerPort);  in SetWorkerColumnOptional()
1644 	HeapTuple heapTuple = GetNodeTuple(workerNode->workerName, workerNode->workerPort);  in SetWorkerColumnLocalOnly()
1653 							   workerNode->workerName, workerNode->workerPort)));  in SetWorkerColumnLocalOnly()
1723 								   workerNode->workerName, workerNode->workerPort)));  in GetMetadataSyncCommandToSetNodeColumn()
2105 	workerNode->workerPort = DatumGetUInt32(datumArray[Anum_pg_dist_node_nodeport - 1]);  in TupleToWorkerNode()