1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
323if (boundingEnabled) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity);
15 references to _boundingState
System.Threading.Tasks.Dataflow (15)
Blocks\BatchBlock.cs (15)
374(_boundingState == null 376(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 390if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 494return _boundingState != null ? 495_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount : 874Debug.Assert(_boundingState != null, "Bounding state is required when in bounded mode."); 1016if (_boundingState != null) _boundingState.CurrentCount += reserved.Count; 1034Debug.Assert(_boundingState != null, "Bounded state is required for bounded mode."); 1065if (_boundingState != null) _boundingState.CurrentCount += consumedCount; 1123if (_boundingState != null) 1128Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0, 1130_boundingState.CurrentCount -= numItemsRemoved;