1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
1057if (dataflowBlockOptions.BoundedCapacity > 0) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity);
15 references to _boundingState
System.Threading.Tasks.Dataflow (15)
Blocks\JoinBlock.cs (15)
696Debug.Assert(_sharedResources._boundingState != null, "This is only used in bounding mode"); 710bool boundingCapacityAvailable = _sharedResources._boundingState.CountIsLessThanBound || !hasTheHighestNumberOfMessagesAvailable; 724if (hasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 848(_sharedResources._boundingState == null 850((_sharedResources._boundingState.CountIsLessThanBound || !HasTheHighestNumberOfMessagesAvailable) && 861if (_sharedResources._boundingState != null && HasTheHighestNumberOfMessagesAvailable) _sharedResources._boundingState.CurrentCount += 1; // track this new item against our bound 1118if (_boundingState == null) 1131bool boundingCapacityAvailable = _boundingState.CountIsLessThanBound; 1358Debug.Assert(!_dataflowBlockOptions.Greedy || _boundingState != null, "This only makes sense in non-greedy or bounding mode"); 1385if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1; 1430if (_boundingState != null) 1435Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0, 1437_boundingState.CurrentCount -= numItemsRemoved;