| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/ |
| H A D | repair_shards.c | 727 shardInterval); in RepairShardPlacement()
941 ShardInterval *shardInterval = NULL; in CopyShardTablesViaBlockWrites() local
942 foreach_ptr(shardInterval, shardIntervalList) in CopyShardTablesViaBlockWrites()
988 foreach_ptr(shardInterval, shardIntervalList) in CopyShardTablesViaBlockWrites()
1001 if (PartitionTable(shardInterval->relationId)) in CopyShardTablesViaBlockWrites()
1234 int64 shardId = shardInterval->shardId; in RecreateShardDDLCommandList()
1235 Oid relationId = shardInterval->relationId; in RecreateShardDDLCommandList()
1273 int64 shardId = shardInterval->shardId; in PostLoadShardCreationCommandList()
1274 Oid relationId = shardInterval->relationId; in PostLoadShardCreationCommandList()
1314 Oid relationId = shardInterval->relationId; in CopyShardForeignConstraintCommandListGrouped()
[all …]
|
| H A D | stage_protocol.c | 254 ShardInterval *shardInterval = LoadShardInterval(shardId); in master_append_table_to_shard() local
255 Oid relationId = shardInterval->relationId; in master_append_table_to_shard()
261 char storageType = shardInterval->storageType; in master_append_table_to_shard()
591 shardIndex = ShardIndex(shardInterval); in CreateShardsOnWorkers()
648 Oid relationId = shardInterval->relationId; in RelationShardListForShardCreate()
662 relationShard->shardId = shardInterval->shardId; in RelationShardListForShardCreate()
668 shardIndex = ShardIndex(shardInterval); in RelationShardListForShardCreate()
833 ShardInterval *shardInterval = LoadShardInterval(shardId); in UpdateShardStatistics() local
834 Oid relationId = shardInterval->relationId; in UpdateShardStatistics()
972 Oid relationId = shardInterval->relationId; in ReceiveAndUpdateShardsSizeAndMinMax()
[all …]
|
| H A D | delete_protocol.c | 459 ShardInterval *shardInterval = NULL; in DropTaskList() local
460 foreach_ptr(shardInterval, deletableShardIntervalList) in DropTaskList()
462 Assert(shardInterval->relationId == relationId); in DropTaskList()
464 uint64 shardId = shardInterval->shardId; in DropTaskList()
465 char storageType = shardInterval->storageType; in DropTaskList()
693 ShardInterval *shardInterval = NULL; in ShardsMatchingDeleteCriteria() local
694 foreach_ptr(shardInterval, shardIntervalList) in ShardsMatchingDeleteCriteria()
696 if (shardInterval->minValueExists && shardInterval->maxValueExists) in ShardsMatchingDeleteCriteria()
701 UpdateConstraint(baseConstraint, shardInterval); in ShardsMatchingDeleteCriteria()
726 dropShardIntervalList = lappend(dropShardIntervalList, shardInterval); in ShardsMatchingDeleteCriteria()
[all …]
|
| H A D | shard_cleaner.c | 252 ShardInterval *shardInterval = LoadShardInterval(shardPlacement->shardId); in TryDropShard() local
261 char *qualifiedTableName = ConstructQualifiedShardName(shardInterval); in TryDropShard()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
| H A D | reference_table_utils.c | 130 uint64 shardId = shardInterval->shardId; in EnsureReferenceTablesExistOnAllNodesExtended()
340 uint64 shardId = shardInterval->shardId; in ReplicateShardToNode()
353 char *tableOwner = TableOwner(shardInterval->relationId); in ReplicateShardToNode()
364 get_rel_name(shardInterval->relationId), nodeName, in ReplicateShardToNode()
369 get_rel_name(shardInterval->relationId), nodeName, in ReplicateShardToNode()
381 if (ShouldSyncTableMetadata(shardInterval->relationId)) in ReplicateShardToNode()
549 shardInterval); in ReplicateAllReferenceTablesToNode()
557 ShardInterval *shardInterval = NULL; in ReplicateAllReferenceTablesToNode() local
558 foreach_ptr(shardInterval, referenceShardIntervalList) in ReplicateAllReferenceTablesToNode()
560 uint64 shardId = shardInterval->shardId; in ReplicateAllReferenceTablesToNode()
[all …]
|
| H A D | resource_lock.c | 256 ShardInterval *shardInterval = NULL; in LockShardListResourcesOnFirstWorker() local
259 int64 shardId = shardInterval->shardId; in LockShardListResourcesOnFirstWorker()
345 ShardInterval *shardInterval = NULL; in LockShardListMetadataOnWorkers() local
348 int64 shardId = shardInterval->shardId; in LockShardListMetadataOnWorkers()
458 shardInterval->shardIndex); in SetLocktagForShardDistributionMetadata()
516 ShardInterval *shardInterval = NULL; in LockReferencedReferenceShardDistributionMetadata() local
670 ShardInterval *shardInterval = NULL; in LockShardListMetadata() local
673 int64 shardId = shardInterval->shardId; in LockShardListMetadata()
752 ShardInterval *shardInterval = NULL; in LockShardListResources() local
755 int64 shardId = shardInterval->shardId; in LockShardListResources()
[all …]
|
| H A D | colocation_utils.c | 179 ShardInterval *shardInterval = LoadShardInterval(shardId); in get_colocated_shard_array() local
181 List *colocatedShardList = ColocatedShardIntervalList(shardInterval); in get_colocated_shard_array()
984 ColocatedShardIntervalList(ShardInterval *shardInterval) in ColocatedShardIntervalList() argument
986 Oid distributedTableId = shardInterval->relationId; in ColocatedShardIntervalList()
998 ShardInterval *copyShardInterval = CopyShardInterval(shardInterval); in ColocatedShardIntervalList()
1005 int shardIntervalIndex = ShardIndex(shardInterval); in ColocatedShardIntervalList()
1045 ColocatedNonPartitionShardIntervalList(ShardInterval *shardInterval) in ColocatedNonPartitionShardIntervalList() argument
1047 Oid distributedTableId = shardInterval->relationId; in ColocatedNonPartitionShardIntervalList()
1061 ShardInterval *copyShardInterval = CopyShardInterval(shardInterval); in ColocatedNonPartitionShardIntervalList()
1071 int shardIntervalIndex = ShardIndex(shardInterval); in ColocatedNonPartitionShardIntervalList()
|
| H A D | multi_partitioning_utils.c | 336 ShardInterval *shardInterval = NULL; in CreateFixPartitionConstraintsTaskList() local
337 foreach_ptr(shardInterval, shardIntervalList) in CreateFixPartitionConstraintsTaskList()
339 uint64 shardId = shardInterval->shardId; in CreateFixPartitionConstraintsTaskList()
1039 GenerateAttachShardPartitionCommand(ShardInterval *shardInterval) in GenerateAttachShardPartitionCommand() argument
1041 Oid schemaId = get_rel_namespace(shardInterval->relationId); in GenerateAttachShardPartitionCommand()
1045 char *command = GenerateAlterTableAttachPartitionCommand(shardInterval->relationId); in GenerateAttachShardPartitionCommand()
1047 int shardIndex = ShardIndex(shardInterval); in GenerateAttachShardPartitionCommand()
1052 Oid parentRelationId = PartitionParentOid(shardInterval->relationId); in GenerateAttachShardPartitionCommand()
1067 escapedParentSchemaName, shardInterval->shardId, in GenerateAttachShardPartitionCommand()
|
| H A D | shard_utils.c | 59 ShardInterval *shardInterval = LoadShardIntervalWithLongestShardName(citusTableOid); in GetLongestShardName() local
60 AppendShardIdToName(&longestShardName, shardInterval->shardId); in GetLongestShardName()
|
| H A D | shardinterval_utils.c | 213 ShardIndex(ShardInterval *shardInterval) in ShardIndex() argument
216 Oid distributedTableId = shardInterval->relationId; in ShardIndex()
217 Datum shardMinValue = shardInterval->minValue; in ShardIndex()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/test/ |
| H A D | distribution_metadata.c | 73 ShardInterval *shardInterval = NULL; in load_shard_id_array() local
74 foreach_ptr(shardInterval, shardList) in load_shard_id_array()
76 Datum shardIdDatum = Int64GetDatum(shardInterval->shardId); in load_shard_id_array()
100 ShardInterval *shardInterval = LoadShardInterval(shardId); in load_shard_interval_array() local
101 Datum shardIntervalArray[] = { shardInterval->minValue, shardInterval->maxValue }; in load_shard_interval_array()
103 Assert(expectedType == shardInterval->valueTypeId); in load_shard_interval_array()
106 shardInterval->valueTypeId); in load_shard_interval_array()
|
| H A D | colocation_utils.c | 116 ShardInterval *shardInterval = LoadShardInterval(shardId); in find_shard_interval_index() local
117 uint32 shardIndex = ShardIndex(shardInterval); in find_shard_interval_index()
|
| H A D | prune_shard_list.c | 220 ShardInterval *shardInterval = NULL; in PrunedShardIdsForTable() local
221 foreach_ptr(shardInterval, shardList) in PrunedShardIdsForTable()
223 Datum shardIdDatum = Int64GetDatum(shardInterval->shardId); in PrunedShardIdsForTable()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/ |
| H A D | metadata_utility.c | 99 shardInterval, char *shardName,
761 ShardInterval *shardInterval = NULL; in GenerateSizeQueryOnMultiplePlacements() local
762 foreach_ptr(shardInterval, shardIntervalList) in GenerateSizeQueryOnMultiplePlacements()
776 uint64 shardId = shardInterval->shardId; in GenerateSizeQueryOnMultiplePlacements()
941 ShardInterval *shardInterval = NULL; in GenerateShardStatisticsQueryForShardList() local
942 foreach_ptr(shardInterval, shardIntervalList) in GenerateShardStatisticsQueryForShardList()
944 uint64 shardId = shardInterval->shardId; in GenerateShardStatisticsQueryForShardList()
1101 ShardInterval *shardInterval = NULL; in TableShardReplicationFactor() local
1102 foreach_ptr(shardInterval, shardIntervalList) in TableShardReplicationFactor()
1104 uint64 shardId = shardInterval->shardId; in TableShardReplicationFactor()
[all …]
|
| H A D | metadata_cache.c | 576 return shardInterval; in LoadShardInterval()
3570 if (shardInterval->minValueExists) in ResetCitusTableCacheEntry()
3575 if (shardInterval->maxValueExists) in ResetCitusTableCacheEntry()
3582 pfree(shardInterval); in ResetCitusTableCacheEntry()
3633 ShardInterval *shardInterval = in RemoveStaleShardIdCacheEntries() local
4289 ShardInterval *shardInterval = in TupleToShardInterval() local
4293 return shardInterval; in TupleToShardInterval()
4355 shardInterval->minValue = minValue; in DeformedDistShardTupleToShardInterval()
4356 shardInterval->maxValue = maxValue; in DeformedDistShardTupleToShardInterval()
4357 shardInterval->shardId = shardId; in DeformedDistShardTupleToShardInterval()
[all …]
|
| H A D | metadata_sync.c | 925 ShardInterval *shardInterval = NULL; in ShardListInsertCommand() local
926 foreach_ptr(shardInterval, shardIntervalList) in ShardListInsertCommand()
928 uint64 shardId = shardInterval->shardId; in ShardListInsertCommand()
969 uint64 shardId = shardInterval->shardId; in ShardListInsertCommand()
976 if (shardInterval->minValueExists) in ShardListInsertCommand()
979 shardInterval->minValue)); in ShardListInsertCommand()
986 if (shardInterval->maxValueExists) in ShardListInsertCommand()
989 shardInterval->maxValue)); in ShardListInsertCommand()
1000 shardInterval->storageType, in ShardListInsertCommand()
2387 ShardInterval *shardInterval = in EnsureShardMetadataIsSane() local
[all …]
|
| /dports/biology/gatk/gatk-4.2.0.0/src/test/java/org/broadinstitute/hellbender/tools/walkers/haplotypecaller/ |
| H A D | HaplotypeCallerEngineUnitTest.java | 34 final SimpleInterval shardInterval = new SimpleInterval("20", 10000000, 10001000); in testIsActive() local
35 …addedShardInterval = new SimpleInterval(shardInterval.getContig(), shardInterval.getStart() - 100,… in testIsActive()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/ |
| H A D | function_call_delegation.c | 394 ShardInterval *shardInterval = FindShardInterval(partitionValueDatum, cacheEntry); in ShardPlacementForFunctionColocatedWithDistTable() local
395 if (shardInterval == NULL) in ShardPlacementForFunctionColocatedWithDistTable()
401 List *placementList = ActiveShardPlacementList(shardInterval->shardId); in ShardPlacementForFunctionColocatedWithDistTable()
424 const ShardInterval *shardInterval = cacheEntry->sortedShardIntervalArray[0]; in ShardPlacementForFunctionColocatedWithReferenceTable() local
425 const uint64 referenceTableShardId = shardInterval->shardId; in ShardPlacementForFunctionColocatedWithReferenceTable()
|
| H A D | multi_router_planner.c | 313 Oid relationId = shardInterval->relationId; in ShardIntervalOpExpressions()
336 if (shardInterval->minValueExists && shardInterval->maxValueExists) in ShardIntervalOpExpressions()
338 UpdateConstraint(baseConstraint, shardInterval); in ShardIntervalOpExpressions()
858 uint64 shardId = shardInterval->shardId; in IsLocallyAccessibleCitusLocalTable()
1734 task->shardInterval = NULL; in CreateTask()
2548 relationShard->shardId = shardInterval->shardId; in RelationShardListForShardIntervalList()
2588 referenceShardId = shardInterval->shardId; in GetAnchorShardId()
2592 return shardInterval->shardId; in GetAnchorShardId()
2859 uint64 shardId = shardInterval->shardId; in PlacementsForWorkersContainingAllShards()
2934 modifyRoute->shardId = shardInterval->shardId; in BuildRoutesForInsert()
[all …]
|
| H A D | multi_physical_planner.c | 2079 typeId = shardInterval->valueTypeId; in SplitPointObject()
2559 ShardInterval *shardInterval = NULL; in QueryPushdownTaskCreate() local
3201 ShardInterval *shardInterval = in RangeTableFragmentsList() local
3523 Assert(shardInterval != NULL); in UpdateConstraint()
3524 Assert(shardInterval->minValueExists); in UpdateConstraint()
3525 Assert(shardInterval->maxValueExists); in UpdateConstraint()
3535 shardInterval->valueByVal, in UpdateConstraint()
3536 shardInterval->valueTypeLen); in UpdateConstraint()
3538 shardInterval->valueByVal, in UpdateConstraint()
3539 shardInterval->valueTypeLen); in UpdateConstraint()
[all …]
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/ |
| H A D | index.c | 406 ShardInterval *shardInterval = LoadShardIntervalWithLongestShardName( in GenerateLongestShardPartitionIndexName() local
408 AppendShardIdToName(&longestPartitionShardName, shardInterval->shardId); in GenerateLongestShardPartitionIndexName()
853 ShardInterval *shardInterval = NULL; in CreateIndexTaskList() local
854 foreach_ptr(shardInterval, shardIntervalList) in CreateIndexTaskList()
856 uint64 shardId = shardInterval->shardId; in CreateIndexTaskList()
897 ShardInterval *shardInterval = NULL; in CreateReindexTaskList() local
898 foreach_ptr(shardInterval, shardIntervalList) in CreateReindexTaskList()
900 uint64 shardId = shardInterval->shardId; in CreateReindexTaskList()
1184 ShardInterval *shardInterval = NULL; in DropIndexTaskList() local
1185 foreach_ptr(shardInterval, shardIntervalList) in DropIndexTaskList()
[all …]
|
| H A D | utility_hook.c | 1018 ShardInterval *shardInterval = NULL; in CreateCustomDDLTaskList() local
1019 foreach_ptr(shardInterval, shardIntervalList) in CreateCustomDDLTaskList()
1021 uint64 shardId = shardInterval->shardId; in CreateCustomDDLTaskList()
1226 ShardInterval *shardInterval = NULL; in DDLTaskList() local
1227 foreach_ptr(shardInterval, shardIntervalList) in DDLTaskList()
1229 uint64 shardId = shardInterval->shardId; in DDLTaskList()
|
| /dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
| H A D | coordinator_protocol.h | 289 extern List * CopyShardCommandList(ShardInterval *shardInterval, const
292 extern List * CopyShardForeignConstraintCommandList(ShardInterval *shardInterval);
293 extern void CopyShardForeignConstraintCommandListGrouped(ShardInterval *shardInterval,
308 extern List * GetForeignConstraintCommandsToReferenceTable(ShardInterval *shardInterval);
|
| H A D | colocation_utils.h | 25 extern List * ColocatedShardIntervalList(ShardInterval *shardInterval);
26 extern List * ColocatedNonPartitionShardIntervalList(ShardInterval *shardInterval);
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/cloudflare/cfssl/cfssl-2001f384ec4f/vendor/github.com/google/certificate-transparency-go/client/ |
| H A D | multilog.go | 84 overall, err := shardInterval(cfg.Shard[0])
91 interval, err := shardInterval(cfg.Shard[i])
200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|