20 writes to CurrentCount
System.Threading.Tasks.Dataflow (20)
Blocks\BatchBlock.cs (4)
387if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 1013if (_boundingState != null) _boundingState.CurrentCount += reserved.Count; 1062if (_boundingState != null) _boundingState.CurrentCount += consumedCount; 1127_boundingState.CurrentCount -= numItemsRemoved;
Blocks\BroadcastBlock.cs (4)
197if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 231_boundingState.CurrentCount -= numItemsRemoved; 343_boundingState.CurrentCount++; 362lock (IncomingLock) _boundingState.CurrentCount--;
Blocks\BufferBlock.cs (4)
125if (_boundingState != null) _boundingState.CurrentCount++; 232_boundingState.CurrentCount -= numItemsRemoved; 346_boundingState.CurrentCount++; 365lock (IncomingLock) _boundingState.CurrentCount--;
Blocks\JoinBlock.cs (4)
712if (hasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 849if (_sharedResources._boundingState != null && HasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 1370if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1; 1422_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)
492_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount : 1125Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0,
Blocks\BroadcastBlock.cs (1)
229Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0,
Blocks\BufferBlock.cs (1)
230Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0,
Blocks\JoinBlock.cs (1)
1420Debug.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),