Home
last modified time | relevance | path

Searched refs:ReferenceTableShardId (Results 1 – 6 of 6) sorted by relevance

/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/
H A Dmetadata_cache.h153 extern bool ReferenceTableShardId(uint64 shardId);
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/
H A Dresource_lock.c723 if (ReferenceTableShardId(firstShardId)) in SerializeNonCommutativeWrites()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/connection/
H A Dplacement_connection.c1114 (successes == 0 || ReferenceTableShardId(shardEntry->key.shardId))) in CheckShardPlacements()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/
H A Dadaptive_executor.c1436 if (task->anchorShardId != INVALID_SHARD_ID && ReferenceTableShardId( in DistributedExecutionRequiresRollback()
1483 if (anchorShardId != INVALID_SHARD_ID && ReferenceTableShardId(anchorShardId)) in TaskListRequires2PC()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/
H A Dmulti_router_planner.c2586 if (ReferenceTableShardId(shardInterval->shardId)) in GetAnchorShardId()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/
H A Dmetadata_cache.c597 ReferenceTableShardId(uint64 shardId) in ReferenceTableShardId() function