1 instantiation of LinkedTargetInfo
System.Threading.Tasks.Dataflow (1)
Internal\TargetRegistry.cs (1)
92
var node = new
LinkedTargetInfo
(target, linkOptions);
27 references to LinkedTargetInfo
System.Threading.Tasks.Dataflow (27)
Blocks\BroadcastBlock.cs (3)
765
TargetRegistry<TOutput>.
LinkedTargetInfo
? cur = _targetRegistry.FirstTargetNode;
772
TargetRegistry<TOutput>.
LinkedTargetInfo
? next = cur.Next;
962
TargetRegistry<TOutput>.
LinkedTargetInfo
? linkedTargets;
Blocks\WriteOnceBlock.cs (3)
176
TargetRegistry<T>.
LinkedTargetInfo
? linkedTargets = _targetRegistry.ClearEntryPoints();
463
TargetRegistry<T>.
LinkedTargetInfo
? cur = _targetRegistry.FirstTargetNode;
466
TargetRegistry<T>.
LinkedTargetInfo
? next = cur.Next;
Internal\SourceCore.cs (3)
595
TargetRegistry<TOutput>.
LinkedTargetInfo
? cur = _targetRegistry.FirstTargetNode;
598
TargetRegistry<TOutput>.
LinkedTargetInfo
? next = cur.Next;
936
TargetRegistry<TOutput>.
LinkedTargetInfo
? linkedTargets;
Internal\TargetRegistry.cs (18)
54
internal
LinkedTargetInfo
? Previous;
56
internal
LinkedTargetInfo
? Next;
62
private readonly Dictionary<ITargetBlock<T>,
LinkedTargetInfo
> _targetInformation;
64
private
LinkedTargetInfo
? _firstTarget;
66
private
LinkedTargetInfo
? _lastTarget;
77
_targetInformation = new Dictionary<ITargetBlock<T>,
LinkedTargetInfo
>();
92
var
node = new LinkedTargetInfo(target, linkOptions);
145
LinkedTargetInfo
? node;
176
internal
LinkedTargetInfo
? ClearEntryPoints()
179
LinkedTargetInfo
? firstTarget = _firstTarget;
192
internal void PropagateCompletion(
LinkedTargetInfo
? firstTarget)
200
for (
LinkedTargetInfo
? node = firstTarget; node != null; node = node.Next)
207
internal
LinkedTargetInfo
? FirstTargetNode { get { return _firstTarget; } }
212
internal void AddToList(
LinkedTargetInfo
node, bool append)
248
internal void RemoveFromList(
LinkedTargetInfo
node)
253
LinkedTargetInfo
? previous = node.Previous;
254
LinkedTargetInfo
? next = node.Next;
286
for (
LinkedTargetInfo
? node = _firstTarget; node != null; node = node.Next)