Searched defs:localGroupId (Results 1 – 14 of 14) sorted by relevance
242 int32 localGroupId = GetLocalGroupId(); in get_global_active_transactions() local746 int32 localGroupId = GetLocalGroupId(); in AssignDistributedTransactionId() local778 int32 localGroupId = GetLocalGroupId(); in MarkCitusInitiatedCoordinatorBackend() local
332 int32 localGroupId = GetLocalGroupId(); in CitusStatActivity() local437 int32 localGroupId = GetLocalGroupId(); in GetLocalNodeCitusDistStat() local
108 int32 localGroupId = GetLocalGroupId(); in CheckForDistributedDeadlocks() local
96 int32 localGroupId = GetLocalGroupId(); in BuildGlobalWaitGraph() local
244 int32 localGroupId = GetLocalGroupId(); in GetCachedLocalPlan() local
114 int32 localGroupId = GetLocalGroupId(); in TryToDelegateFunctionCall() local
373 int32 localGroupId = GetLocalGroupId(); in RemoveLocalNodeFromWorkerList() local
1902 uint64 localGroupId = 0; in UniqueJobId() local
600 int32 localGroupId = GetLocalGroupId(); in SplitLocalAndRemotePlacements() local897 int32 localGroupId = GetLocalGroupId(); in TaskAccessesLocalNode() local
435 int32 localGroupId = GetLocalGroupId(); in AcquireDistributedLockOnRelations() local
2218 int32 localGroupId = GetLocalGroupId(); in ShardIntervalListHasLocalPlacements() local2689 int32 localGroupId = GetLocalGroupId(); in ContainsLocalPlacement() local
341 int32 localGroupId = GetLocalGroupId(); in DropShards() local
131 uint32 localGroupId; member
1915 int32 localGroupId = GetLocalGroupId(); in EnsureCoordinator() local