1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Internal\TargetCore.cs (1)
130_boundingState = new BoundingStateWithPostponed<TInput>(_dataflowBlockOptions.BoundedCapacity);
36 references to _boundingState
System.Threading.Tasks.Dataflow (36)
Internal\TargetCore.cs (36)
202if (_boundingState == null || 203(_boundingState.OutstandingTransfers == 0 && _boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0)) 219if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 227Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 231_boundingState.PostponedMessages.Push(source, messageHeader); 263if (_boundingState != null && boundingCountChange != 0) 265Debug.Assert(boundingCountChange <= 0 && _boundingState.CurrentCount + boundingCountChange >= 0, 267_boundingState.CurrentCount += boundingCountChange; 360(!_decliningPermanently && _boundingState != null && _boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count > 0); 380_messages.Count + (_boundingState != null ? _boundingState.PostponedMessages.Count : 0)); 404bool shouldAttemptPostponedTransfer = _boundingState != null && _boundingState.BoundedCapacity > 1; 425_boundingState!.OutstandingTransfers > 0 426&& _boundingState.OutstandingTransfers <= _dataflowBlockOptions.ActualMaxDegreeOfParallelism, 428_boundingState.OutstandingTransfers--; // was incremented in TryConsumePostponedMessage 589else if (_boundingState != null && TryConsumePostponedMessage(forPostponementTransfer: false, result: out messageWithId)) 651if (!_boundingState!.CountIsLessThanBound || !_boundingState.PostponedMessages.TryPop(out element)) 661_boundingState.CurrentCount += 1; // optimistically take bounding space 664Debug.Assert(_boundingState.OutstandingTransfers >= 0, "Expected TryConsumePostponedMessage to not be negative."); 665_boundingState.OutstandingTransfers++; // temporarily force postponement until we've successfully consumed the element 691_boundingState!.OutstandingTransfers--; 762if (_boundingState != null) 765Common.ReleaseAllPostponedMessages(_owningTarget, _boundingState.PostponedMessages, ref _exceptions); 805internal bool IsBounded { get { return _boundingState != null; } } 813if (_boundingState != null) 817Debug.Assert(count > 0 || (count < 0 && _boundingState.CurrentCount + count >= 0), 819_boundingState.CurrentCount += count; 861get { return _target._boundingState?.PostponedMessages; }