1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
1042if (dataflowBlockOptions.BoundedCapacity > 0) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity);
15 references to _boundingState
System.Threading.Tasks.Dataflow (15)
Blocks\JoinBlock.cs (15)
684Debug.Assert(_sharedResources._boundingState != null, "This is only used in bounding mode"); 698bool boundingCapacityAvailable = _sharedResources._boundingState.CountIsLessThanBound || !hasTheHighestNumberOfMessagesAvailable; 712if (hasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 836(_sharedResources._boundingState == null 838((_sharedResources._boundingState.CountIsLessThanBound || !HasTheHighestNumberOfMessagesAvailable) && 849if (_sharedResources._boundingState != null && HasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 1103if (_boundingState == null) 1116bool boundingCapacityAvailable = _boundingState.CountIsLessThanBound; 1343Debug.Assert(!_dataflowBlockOptions.Greedy || _boundingState != null, "This only makes sense in non-greedy or bounding mode"); 1370if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1; 1415if (_boundingState != null) 1420Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0, 1422_boundingState.CurrentCount -= numItemsRemoved;