/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/ |
H A D | repair_shards.c | 156 ShardInterval *shardInterval = LoadShardInterval(shardId); in citus_copy_shard_placement() local 313 ShardInterval *shardInterval = LoadShardInterval(shardId); in citus_move_shard_placement() local 659 ShardInterval *shardInterval = LoadShardInterval(shardId); in RepairShardPlacement() local 777 ShardInterval *shardInterval = LoadShardInterval(shardId); in ReplicateColocatedShardPlacement() local 941 ShardInterval *shardInterval = NULL; in CopyShardTablesViaBlockWrites() local 1208 CopyShardCommandList(ShardInterval *shardInterval, const char *sourceNodeName, in CopyShardCommandList() 1231 RecreateShardDDLCommandList(ShardInterval *shardInterval, const char *sourceNodeName, in RecreateShardDDLCommandList() 1287 CopyShardForeignConstraintCommandList(ShardInterval *shardInterval) in CopyShardForeignConstraintCommandList() 1309 CopyShardForeignConstraintCommandListGrouped(ShardInterval *shardInterval, in CopyShardForeignConstraintCommandListGrouped() 1426 ConstructQualifiedShardName(ShardInterval *shardInterval) in ConstructQualifiedShardName() [all …]
|
H A D | stage_protocol.c | 254 ShardInterval *shardInterval = LoadShardInterval(shardId); in master_append_table_to_shard() local 585 ShardInterval *shardInterval = LoadShardInterval(shardId); in CreateShardsOnWorkers() local 646 RelationShardListForShardCreate(ShardInterval *shardInterval) in RelationShardListForShardCreate() 816 ShardInterval *shardInterval = LoadShardInterval(shardId); in WorkerCreateShardCommandList() local 833 ShardInterval *shardInterval = LoadShardInterval(shardId); in UpdateShardStatistics() local 971 ShardInterval *shardInterval = LoadShardInterval(shardId); in ReceiveAndUpdateShardsSizeAndMinMax() local 1020 UpdateShardSizeAndMinMax(uint64 shardId, ShardInterval *shardInterval, Oid relationId, in UpdateShardSizeAndMinMax()
|
H A D | shard_cleaner.c | 252 ShardInterval *shardInterval = LoadShardInterval(shardPlacement->shardId); in TryDropShard() local
|
H A D | delete_protocol.c | 459 ShardInterval *shardInterval = NULL; in DropTaskList() local 693 ShardInterval *shardInterval = NULL; in ShardsMatchingDeleteCriteria() local
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
H A D | reference_table_utils.c | 129 ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList); in EnsureReferenceTablesExistOnAllNodesExtended() local 338 ReplicateShardToNode(ShardInterval *shardInterval, char *nodeName, int nodePort) in ReplicateShardToNode() 546 ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList); in ReplicateAllReferenceTablesToNode() local 557 ShardInterval *shardInterval = NULL; in ReplicateAllReferenceTablesToNode() local
|
H A D | resource_lock.c | 256 ShardInterval *shardInterval = NULL; in LockShardListResourcesOnFirstWorker() local 345 ShardInterval *shardInterval = NULL; in LockShardListMetadataOnWorkers() local 445 ShardInterval *shardInterval = LoadShardInterval(shardId); in SetLocktagForShardDistributionMetadata() local 516 ShardInterval *shardInterval = NULL; in LockReferencedReferenceShardDistributionMetadata() local 670 ShardInterval *shardInterval = NULL; in LockShardListMetadata() local 752 ShardInterval *shardInterval = NULL; in LockShardListResources() local 793 ShardInterval *shardInterval = LoadShardInterval(shardId); in LockParentShardResourceIfPartition() local
|
H A D | shard_utils.c | 59 ShardInterval *shardInterval = LoadShardIntervalWithLongestShardName(citusTableOid); in GetLongestShardName() local
|
/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 424 const ShardInterval *shardInterval = cacheEntry->sortedShardIntervalArray[0]; in ShardPlacementForFunctionColocatedWithReferenceTable() local
|
H A D | multi_router_planner.c | 311 ShardIntervalOpExpressions(ShardInterval *shardInterval, Index rteIndex) in ShardIntervalOpExpressions() 857 ShardInterval *shardInterval = linitial(shardIntervalList); in IsLocallyAccessibleCitusLocalTable() local 2544 ShardInterval *shardInterval = (ShardInterval *) lfirst(shardIntervalCell); in RelationShardListForShardIntervalList() local 2584 ShardInterval *shardInterval = linitial(prunedShardIntervalList); in GetAnchorShardId() local 2652 ShardInterval *shardInterval = CopyShardInterval(cachedShardInterval); in TargetShardIntervalForFastPathQuery() local 2858 ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList); in PlacementsForWorkersContainingAllShards() local 2931 ShardInterval *shardInterval = linitial(shardIntervalList); in BuildRoutesForInsert() local 3025 ShardInterval *shardInterval = FindShardInterval(partitionValue, cacheEntry); in BuildRoutesForInsert() local
|
/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
|
/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 100 ShardInterval *shardInterval = LoadShardInterval(shardId); in load_shard_interval_array() local
|
H A D | colocation_utils.c | 116 ShardInterval *shardInterval = LoadShardInterval(shardId); in find_shard_interval_index() local
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/ |
H A D | index.c | 406 ShardInterval *shardInterval = LoadShardIntervalWithLongestShardName( in GenerateLongestShardPartitionIndexName() local 853 ShardInterval *shardInterval = NULL; in CreateIndexTaskList() local 897 ShardInterval *shardInterval = NULL; in CreateReindexTaskList() local 1184 ShardInterval *shardInterval = NULL; in DropIndexTaskList() local
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/ |
H A D | distributed_execution_locks.c | 348 ShardInterval *shardInterval = LoadShardInterval(shardId); in AcquireExecutorShardLockForRowModify() local
|
/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 | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/google/certificate-transparency-go/client/ |
H A D | multilog.go | 200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/ |
H A D | metadata_utility.c | 731 ShardInterval *shardInterval = CopyShardInterval(cachedShardInterval); in ShardIntervalsOnWorkerGroup() local 761 ShardInterval *shardInterval = NULL; in GenerateSizeQueryOnMultiplePlacements() local 941 ShardInterval *shardInterval = NULL; in GenerateShardStatisticsQueryForShardList() local 975 ShardInterval *shardInterval, char *shardName, in AppendShardSizeMinMaxQuery() 1009 AppendShardSizeQuery(StringInfo selectQuery, ShardInterval *shardInterval, in AppendShardSizeQuery() 1101 ShardInterval *shardInterval = NULL; in TableShardReplicationFactor() local 2009 ShardInterval *shardInterval = LoadShardInterval(shardPlacement->shardId); in MarkShardPlacementInactive() local
|