1 write to _targetRegistry
System.Threading.Tasks.Dataflow (1)
Internal\SourceCore.cs (1)
120_targetRegistry = new TargetRegistry<TOutput>(_owningSource);
11 references to _targetRegistry
System.Threading.Tasks.Dataflow (11)
Internal\SourceCore.cs (11)
55private object ValueLock { get { return _targetRegistry; } } 150_targetRegistry.Add(ref target, linkOptions); 152return Common.CreateUnlinker(OutgoingLock, _targetRegistry, target); 198_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 595TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 684_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 691_targetRegistry.Remove(target); 751targetsAvailable = _targetRegistry.FirstTargetNode != null; 944linkedTargets = _targetRegistry.ClearEntryPoints(); 974_targetRegistry.PropagateCompletion(linkedTargets); 1020internal TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } }