| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/ |
| H A D | intermediate_result_pruning.c | 275 List *workerNodeList = ActiveReadableNodeList(); in AppendAllWorkerNodes() local
349 List *workerNodeList = NIL; in FindAllRemoteWorkerNodesUsingSubplan() local
371 RemoveLocalNodeFromWorkerList(List *workerNodeList) in RemoveLocalNodeFromWorkerList()
403 List *workerNodeList) in LogIntermediateResultMulticastSummary()
|
| H A D | multi_router_planner.c | 2494 List *workerNodeList = ActiveReadableNonCoordinatorNodeList(); in CreateDummyPlacement() local
|
| H A D | multi_physical_planner.c | 5243 List *workerNodeList = ActiveReadableNodeList(); in GreedyAssignTaskList() local
5690 List *workerNodeList = ActiveReadableNodeList(); in AssignDualHashTaskList() local
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/transaction/ |
| H A D | worker_transaction.c | 74 List *workerNodeList = TargetWorkerSetNodeList(targetWorkerSet, ShareLock); in SendCommandToWorkersAsUser() local
133 List *workerNodeList = NIL; in TargetWorkerSetNodeList() local
170 List *workerNodeList = TargetWorkerSetNodeList(targetWorkerSet, ShareLock); in SendBareCommandListToMetadataWorkers() local
210 List *workerNodeList = TargetWorkerSetNodeList(NON_COORDINATOR_METADATA_NODES, in SendCommandToMetadataWorkersParams() local
290 List *workerNodeList = TargetWorkerSetNodeList(targetWorkerSet, ShareLock); in OpenConnectionsToWorkersInParallel() local
359 List *workerNodeList = TargetWorkerSetNodeList(targetWorkerSet, ShareLock); in SendCommandToWorkersParamsInternal() local
|
| H A D | citus_dist_stat_activity.c | 314 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(NoLock); in CitusStatActivity() local
440 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(NoLock); in GetLocalNodeCitusDistStat() local
|
| H A D | distributed_deadlock_detection.c | 109 List *workerNodeList = ActiveReadableNodeList(); in CheckForDistributedDeadlocks() local
|
| H A D | lock_graph.c | 93 List *workerNodeList = ActiveReadableNodeList(); in BuildGlobalWaitGraph() local
|
| H A D | backend_data.c | 231 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(NoLock); in get_global_active_transactions() local
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/ |
| H A D | worker_node_manager.c | 139 WorkerGetRoundRobinCandidateNode(List *workerNodeList, uint64 shardId, in WorkerGetRoundRobinCandidateNode()
303 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(NoLock); in ActivePrimaryNonCoordinatorNodeCount() local
340 List *workerNodeList = NIL; in FilterActiveNodeListFunc() local
553 List *workerNodeList = NIL; in PrimaryNodesNotInList() local
688 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(NoLock); in GetFirstPrimaryWorkerNode() local
|
| H A D | citus_create_restore_point.c | 120 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(lockMode); in OpenConnectionsToAllWorkerNodes() local
|
| H A D | stage_protocol.c | 178 List *workerNodeList = DistributedTablePlacementNodeList(NoLock); in master_create_empty_shard() local
451 List *workerNodeList, int replicationFactor) in CreateAppendDistributedShardPlacements()
530 InsertShardPlacementRows(Oid relationId, int64 shardId, List *workerNodeList, in InsertShardPlacementRows()
|
| H A D | create_shards.c | 175 List *workerNodeList = DistributedTablePlacementNodeList(NoLock); in CreateShardsWithRoundRobinPolicy() local
|
| H A D | node_protocol.c | 470 List *workerNodeList = ActiveReadableNonCoordinatorNodeList(); in citus_get_active_worker_nodes() local
497 List *workerNodeList = functionContext->user_fctx; in citus_get_active_worker_nodes() local
|
| H A D | shard_rebalancer.c | 1744 RebalancePlacementUpdates(List *workerNodeList, List *shardPlacementListList, in RebalancePlacementUpdates()
1853 InitRebalanceState(List *workerNodeList, List *shardPlacementList, in InitRebalanceState()
2419 ReplicationPlacementUpdates(List *workerNodeList, List *shardPlacementList, in ReplicationPlacementUpdates()
2748 WorkerNodeListContains(List *workerNodeList, const char *workerName, uint32 workerPort) in WorkerNodeListContains()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/ |
| H A D | dependencies.c | 89 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(RowShareLock); in EnsureDependenciesExistOnAllNodes() local
|
| H A D | truncate.c | 423 List *workerNodeList = ActivePrimaryNodeList(NoLock); in AcquireDistributedLockOnRelations() local
|
| H A D | create_distributed_table.c | 301 List *workerNodeList = ActivePrimaryNodeList(ShareLock); in create_reference_table() local
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/test/ |
| H A D | shard_rebalancer.c | 107 List *workerNodeList = NIL; in shard_placement_rebalance_array() local
259 List *workerNodeList = NIL; in shard_placement_replication_array() local
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
| H A D | reference_table_utils.c | 265 List *workerNodeList = ReferenceTablePlacementNodeList(lockMode); in WorkersWithoutReferenceTablePlacement() local
|
| H A D | resource_lock.c | 306 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(NoLock); in IsFirstWorkerNode() local
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/ |
| H A D | metadata_utility.c | 367 List *workerNodeList = ActivePrimaryNodeList(NoLock); in SendShardStatisticsQueriesInParallel() local
415 OpenConnectionToNodes(List *workerNodeList) in OpenConnectionToNodes()
440 GenerateShardStatisticsQueryList(List *workerNodeList, List *citusTableIds, bool in GenerateShardStatisticsQueryList()
558 List *workerNodeList = ActiveReadableNodeList(); in DistributedTableSize() local
|
| H A D | node_metadata.c | 1242 List *workerNodeList = NIL; in ReadDistNode() local
1550 List *workerNodeList = list_make1(workerNode); in AddNodeMetadata() local
1595 List *workerNodeList = TargetWorkerSetNodeList(NON_COORDINATOR_METADATA_NODES, in SetWorkerColumnOptional() local
|
| H A D | metadata_sync.c | 499 List *workerNodeList = ReadDistNode(includeNodesFromOtherClusters); in MetadataCreateCommands() local
755 NodeListInsertCommand(List *workerNodeList) in NodeListInsertCommand()
1655 List *workerNodeList = ActivePrimaryNonCoordinatorNodeList(NoLock); in HasMetadataWorkers() local
|
| H A D | metadata_cache.c | 3317 List *workerNodeList = ReadDistNode(includeNodesFromOtherClusters); in InitializeWorkerNodeCache() local
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/connection/ |
| H A D | connection_management.c | 1165 List *workerNodeList = ActivePrimaryNodeList(AccessShareLock); in WarmUpConnParamsHash() local
|