1 write to _targets
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
1051
_targets
= targets;
17 references to _targets
System.Threading.Tasks.Dataflow (17)
Blocks\JoinBlock.cs (17)
601
foreach (JoinBlockTargetBase target in _sharedResources.
_targets
)
749
foreach (JoinBlockTargetBase target in _sharedResources.
_targets
)
920
foreach (JoinBlockTargetBase target in _sharedResources.
_targets
)
1086
internal object IncomingLock { get { return
_targets
; } }
1091
foreach (JoinBlockTargetBase target in
_targets
)
1103
foreach (JoinBlockTargetBase target in
_targets
)
1120
foreach (JoinBlockTargetBase target in
_targets
)
1143
foreach (JoinBlockTargetBase target in
_targets
)
1181
foreach (JoinBlockTargetBase target in
_targets
)
1193
foreach (JoinBlockTargetBase target in
_targets
)
1207
foreach (JoinBlockTargetBase target in
_targets
)
1224
foreach (JoinBlockTargetBase target in
_targets
)
1290
_targets
.Max(static t => t.NumberOfMessagesAvailableOrPostponed));
1322
foreach (JoinBlockTargetBase target in
_targets
)
1349
foreach (JoinBlockTargetBase target in sharedResources.
_targets
) target.CompleteOncePossible();
1397
Debug.Assert(
_targets
.Length > 0, "A join must have targets.");
1398
_targets
[0].CompleteCore(exception, dropPendingMessages: true, releaseReservedMessages: true);