3 writes to _linksWithRemainingMessages
System.Threading.Tasks.Dataflow (3)
Internal\TargetRegistry.cs (3)
98
if (node.RemainingMessages > 0)
_linksWithRemainingMessages
++;
158
if (node.RemainingMessages == 0)
_linksWithRemainingMessages
--;
185
_linksWithRemainingMessages
= 0;
7 references to _linksWithRemainingMessages
System.Threading.Tasks.Dataflow (7)
Internal\TargetRegistry.cs (7)
97
Debug.Assert(
_linksWithRemainingMessages
>= 0, "_linksWithRemainingMessages must be non-negative at any time.");
124
Debug.Assert(
_linksWithRemainingMessages
>= 0, "_linksWithRemainingMessages must be non-negative at any time.");
125
if (onlyIfReachedMaxMessages &&
_linksWithRemainingMessages
== 0) return;
141
Debug.Assert(
_linksWithRemainingMessages
>= 0, "_linksWithRemainingMessages must be non-negative at any time.");
142
Debug.Assert(!onlyIfReachedMaxMessages ||
_linksWithRemainingMessages
> 0, "We shouldn't have ended on the slow path.");
159
Debug.Assert(
_linksWithRemainingMessages
>= 0, "_linksWithRemainingMessages must be non-negative at any time.");
184
Debug.Assert(
_linksWithRemainingMessages
>= 0, "_linksWithRemainingMessages must be non-negative at any time.");