1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
320if (boundingEnabled) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity);
15 references to _boundingState
System.Threading.Tasks.Dataflow (15)
Blocks\BatchBlock.cs (15)
371(_boundingState == null 373(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 387if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 491return _boundingState != null ? 492_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount : 871Debug.Assert(_boundingState != null, "Bounding state is required when in bounded mode."); 1013if (_boundingState != null) _boundingState.CurrentCount += reserved.Count; 1031Debug.Assert(_boundingState != null, "Bounded state is required for bounded mode."); 1062if (_boundingState != null) _boundingState.CurrentCount += consumedCount; 1120if (_boundingState != null) 1125Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0, 1127_boundingState.CurrentCount -= numItemsRemoved;