| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/ |
| H A D | shard_cleaner.c | 250 ShardPlacement *shardPlacement = LoadShardPlacement(placement->shardId, in TryDropShard() local
252 ShardInterval *shardInterval = LoadShardInterval(shardPlacement->shardId); in TryDropShard()
256 shardPlacement->placementId, shardPlacement->shardId, in TryDropShard()
257 shardPlacement->nodeName, shardPlacement->nodePort))); in TryDropShard()
278 SendOptionalCommandListToWorkerOutsideTransaction(shardPlacement->nodeName, in TryDropShard()
279 shardPlacement->nodePort, in TryDropShard()
|
| H A D | delete_protocol.c | 364 ShardPlacement *shardPlacement = NULL; in DropShards() local
365 foreach_ptr(shardPlacement, task->taskPlacementList) in DropShards()
367 uint64 shardPlacementId = shardPlacement->placementId; in DropShards()
368 int32 shardPlacementGroupId = shardPlacement->groupId; in DropShards()
416 ExecuteDropShardPlacementCommandRemotely(shardPlacement, in DropShards()
503 Assert(shardPlacement != NULL); in ExecuteDropShardPlacementCommandRemotely()
509 shardPlacement, in ExecuteDropShardPlacementCommandRemotely()
522 uint64 placementId = shardPlacement->placementId; in ExecuteDropShardPlacementCommandRemotely()
524 char *workerName = shardPlacement->nodeName; in ExecuteDropShardPlacementCommandRemotely()
525 uint32 workerPort = shardPlacement->nodePort; in ExecuteDropShardPlacementCommandRemotely()
[all …]
|
| H A D | shard_rebalancer.c | 564 shardPlacement->nodeName, in citus_shard_cost_by_disk_size()
565 shardPlacement->nodePort); in citus_shard_cost_by_disk_size()
2631 ShardPlacement shardPlacement; in PlacementsHashFind() local
2632 memset(&shardPlacement, 0, sizeof(shardPlacement)); in PlacementsHashFind()
2634 shardPlacement.shardId = shardId; in PlacementsHashFind()
2652 ShardPlacement shardPlacement; in PlacementsHashEnter() local
2653 memset(&shardPlacement, 0, sizeof(shardPlacement)); in PlacementsHashEnter()
2655 shardPlacement.shardId = shardId; in PlacementsHashEnter()
2671 ShardPlacement shardPlacement; in PlacementsHashRemove() local
2672 memset(&shardPlacement, 0, sizeof(shardPlacement)); in PlacementsHashRemove()
[all …]
|
| H A D | stage_protocol.c | 307 ShardPlacement *shardPlacement = NULL; in master_append_table_to_shard() local
308 foreach_ptr(shardPlacement, shardPlacementList) in master_append_table_to_shard()
312 GetPlacementConnection(connectionFlags, shardPlacement, NULL); in master_append_table_to_shard()
548 ShardPlacement *shardPlacement = LoadShardPlacement(shardId, shardPlacementId); in InsertShardPlacementRows() local
549 insertedShardPlacements = lappend(insertedShardPlacements, shardPlacement); in InsertShardPlacementRows()
581 ShardPlacement *shardPlacement = NULL; in CreateShardsOnWorkers() local
582 foreach_ptr(shardPlacement, shardPlacements) in CreateShardsOnWorkers()
584 uint64 shardId = shardPlacement->shardId; in CreateShardsOnWorkers()
609 task->taskPlacementList = list_make1(shardPlacement); in CreateShardsOnWorkers()
|
| H A D | create_shards.c | 312 ShardPlacement *shardPlacement = LoadShardPlacement(newShardId, in CreateColocatedShards() local
314 insertedShardPlacements = lappend(insertedShardPlacements, shardPlacement); in CreateColocatedShards()
|
| H A D | repair_shards.c | 1163 ShardPlacement *shardPlacement = NULL; in SearchShardPlacementInList() local
1164 foreach_ptr(shardPlacement, shardPlacementList) in SearchShardPlacementInList()
1166 if (strncmp(nodeName, shardPlacement->nodeName, MAX_NODE_LENGTH) == 0 && in SearchShardPlacementInList()
1167 nodePort == shardPlacement->nodePort) in SearchShardPlacementInList()
1169 return shardPlacement; in SearchShardPlacementInList()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/ |
| H A D | metadata_utility.c | 1383 ShardPlacement *shardPlacement = NULL; in ActiveShardPlacementListOnGroup() local
1386 if (shardPlacement->groupId == groupId) in ActiveShardPlacementListOnGroup()
1389 shardPlacement); in ActiveShardPlacementListOnGroup()
1409 ShardPlacement *shardPlacement = NULL; in ActiveShardPlacementList() local
1434 ShardPlacement *shardPlacement = NULL; in ShardPlacementListWithoutOrphanedPlacements() local
1457 ShardPlacement *shardPlacement = NULL; in ActiveShardPlacement() local
1468 return shardPlacement; in ActiveShardPlacement()
1473 return shardPlacement; in ActiveShardPlacement()
1632 shardPlacement->shardId = DatumGetInt64( in TupleToGroupShardPlacement()
1638 shardPlacement->groupId = DatumGetInt32( in TupleToGroupShardPlacement()
[all …]
|
| H A D | metadata_cache.c | 632 *shardPlacement = placementArray[i]; in LoadGroupShardPlacement()
634 return shardPlacement; in LoadGroupShardPlacement()
733 CitusNode header = shardPlacement->type; in ResolveGroupShardPlacement()
735 (GroupShardPlacement *) shardPlacement; in ResolveGroupShardPlacement()
737 shardPlacement->type = header; in ResolveGroupShardPlacement()
739 SetPlacementNodeMetadata(shardPlacement, workerNode); in ResolveGroupShardPlacement()
743 shardPlacement->partitionMethod = tableEntry->partitionMethod; in ResolveGroupShardPlacement()
744 shardPlacement->colocationGroupId = tableEntry->colocationId; in ResolveGroupShardPlacement()
759 shardPlacement->representativeValue = 0; in ResolveGroupShardPlacement()
762 return shardPlacement; in ResolveGroupShardPlacement()
[all …]
|
| H A D | metadata_sync.c | 2633 ShardPlacement *shardPlacement = NULL; in citus_internal_delete_shard_metadata() local
2634 foreach_ptr(shardPlacement, shardPlacementList) in citus_internal_delete_shard_metadata()
2636 DeleteShardPlacementRow(shardPlacement->placementId); in citus_internal_delete_shard_metadata()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/connection/ |
| H A D | placement_connection.c | 1129 ShardPlacement *shardPlacement = LoadShardPlacement(shardId, placementId); in CheckShardPlacements() local
1135 if (shardPlacement->shardState == SHARD_STATE_ACTIVE) in CheckShardPlacements()
1137 MarkShardPlacementInactive(shardPlacement); in CheckShardPlacements()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/ |
| H A D | adaptive_executor.c | 572 ShardPlacement *shardPlacement; member
1810 placementExecution->shardPlacement = taskPlacement; in AssignTasksToConnectionsOrWorkerPool()
4066 ShardPlacement *taskPlacement = placementExecution->shardPlacement; in StartPlacementExecutionOnSession()
4708 placementExecution->shardPlacement->placementId, in PlacementExecutionDone()
4727 ShardPlacement *shardPlacement = placementExecution->shardPlacement; in PlacementExecutionDone() local
4733 if (shardPlacement->shardState == SHARD_STATE_ACTIVE) in PlacementExecutionDone()
4735 MarkShardPlacementInactive(shardPlacement); in PlacementExecutionDone()
|
| /dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
| H A D | metadata_utility.h | 242 extern void MarkShardPlacementInactive(ShardPlacement *shardPlacement);
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/ |
| H A D | multi_copy.c | 3189 ShardPlacement *shardPlacement = lfirst(shardPlacementCell); in CitusCopyTo() local
3195 shardPlacement, in CitusCopyTo()
|