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; } } 144_targetRegistry.Add(ref target, linkOptions); 146return Common.CreateUnlinker(OutgoingLock, _targetRegistry, target); 192_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 589TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 678_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 685_targetRegistry.Remove(target); 745targetsAvailable = _targetRegistry.FirstTargetNode != null; 938linkedTargets = _targetRegistry.ClearEntryPoints(); 968_targetRegistry.PropagateCompletion(linkedTargets); 1014internal TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } }