20 writes to CurrentCount
System.Threading.Tasks.Dataflow (20)
Blocks\BatchBlock.cs (4)
390if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 1016if (_boundingState != null) _boundingState.CurrentCount += reserved.Count; 1065if (_boundingState != null) _boundingState.CurrentCount += consumedCount; 1130_boundingState.CurrentCount -= numItemsRemoved;
Blocks\BroadcastBlock.cs (4)
203if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 237_boundingState.CurrentCount -= numItemsRemoved; 349_boundingState.CurrentCount++; 368lock (IncomingLock) _boundingState.CurrentCount--;
Blocks\BufferBlock.cs (4)
128if (_boundingState != null) _boundingState.CurrentCount++; 238_boundingState.CurrentCount -= numItemsRemoved; 352_boundingState.CurrentCount++; 371lock (IncomingLock) _boundingState.CurrentCount--;
Blocks\JoinBlock.cs (4)
724if (hasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 861if (_sharedResources._boundingState != null && HasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 1385if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1; 1437_boundingState.CurrentCount -= numItemsRemoved;
Internal\TargetCore.cs (4)
219if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 267_boundingState.CurrentCount += boundingCountChange; 661_boundingState.CurrentCount += 1; // optimistically take bounding space 819_boundingState.CurrentCount += count;
8 references to CurrentCount
System.Threading.Tasks.Dataflow (8)
Blocks\BatchBlock.cs (2)
495_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount : 1128Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0,
Blocks\BroadcastBlock.cs (1)
235Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0,
Blocks\BufferBlock.cs (1)
236Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0,
Blocks\JoinBlock.cs (1)
1435Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0,
Internal\Common.cs (1)
633internal bool CountIsLessThanBound { get { return CurrentCount < BoundedCapacity; } }
Internal\TargetCore.cs (2)
265Debug.Assert(boundingCountChange <= 0 && _boundingState.CurrentCount + boundingCountChange >= 0, 817Debug.Assert(count > 0 || (count < 0 && _boundingState.CurrentCount + count >= 0),