Home
last modified time | relevance | path

Searched defs:localGroupId (Results 1 – 14 of 14) sorted by relevance

/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/transaction/
H A Dbackend_data.c242 int32 localGroupId = GetLocalGroupId(); in get_global_active_transactions() local
746 int32 localGroupId = GetLocalGroupId(); in AssignDistributedTransactionId() local
778 int32 localGroupId = GetLocalGroupId(); in MarkCitusInitiatedCoordinatorBackend() local
H A Dcitus_dist_stat_activity.c332 int32 localGroupId = GetLocalGroupId(); in CitusStatActivity() local
437 int32 localGroupId = GetLocalGroupId(); in GetLocalNodeCitusDistStat() local
H A Ddistributed_deadlock_detection.c108 int32 localGroupId = GetLocalGroupId(); in CheckForDistributedDeadlocks() local
H A Dlock_graph.c96 int32 localGroupId = GetLocalGroupId(); in BuildGlobalWaitGraph() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/
H A Dlocal_plan_cache.c244 int32 localGroupId = GetLocalGroupId(); in GetCachedLocalPlan() local
H A Dfunction_call_delegation.c114 int32 localGroupId = GetLocalGroupId(); in TryToDelegateFunctionCall() local
H A Dintermediate_result_pruning.c373 int32 localGroupId = GetLocalGroupId(); in RemoveLocalNodeFromWorkerList() local
H A Dmulti_physical_planner.c1902 uint64 localGroupId = 0; in UniqueJobId() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/
H A Dlocal_executor.c600 int32 localGroupId = GetLocalGroupId(); in SplitLocalAndRemotePlacements() local
897 int32 localGroupId = GetLocalGroupId(); in TaskAccessesLocalNode() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/
H A Dtruncate.c435 int32 localGroupId = GetLocalGroupId(); in AcquireDistributedLockOnRelations() local
H A Dmulti_copy.c2218 int32 localGroupId = GetLocalGroupId(); in ShardIntervalListHasLocalPlacements() local
2689 int32 localGroupId = GetLocalGroupId(); in ContainsLocalPlacement() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/
H A Ddelete_protocol.c341 int32 localGroupId = GetLocalGroupId(); in DropShards() local
/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/
H A Dmulti_physical_planner.h131 uint32 localGroupId; member
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/
H A Dnode_metadata.c1915 int32 localGroupId = GetLocalGroupId(); in EnsureCoordinator() local