1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Blocks\BufferBlock.cs (1)
61_boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity);
42 references to _boundingState
System.Threading.Tasks.Dataflow (42)
Blocks\BufferBlock.cs (42)
112if (_boundingState == null 114(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 128if (_boundingState != null) _boundingState.CurrentCount++; 135Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 138_boundingState.PostponedMessages.Push(source, messageHeader); 177Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 179_boundingState.TaskForInputProcessing = null; 231if (_boundingState != null) 236Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0, 238_boundingState.CurrentCount -= numItemsRemoved; 251Debug.Assert(_boundingState != null, "Must be in bounded mode."); 254_boundingState.TaskForInputProcessing == null && 255_boundingState.PostponedMessages.Count > 0 && 256_boundingState.CountIsLessThanBound) 260_boundingState.TaskForInputProcessing = 268this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 269_boundingState.PostponedMessages.Count); 273Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 287Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 289Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 311_boundingState.TaskForInputProcessing = null; 333Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 335Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 347if (!_boundingState.CountIsLessThanBound) return false; 348if (!_boundingState.PostponedMessages.TryPop(out sourceAndMessage)) return false; 352_boundingState.CurrentCount++; 371lock (IncomingLock) _boundingState.CurrentCount--; 383(_boundingState == null || _boundingState.TaskForInputProcessing == null)) 389if (_boundingState != null && _boundingState.PostponedMessages.Count > 0) 397if (thisBufferBlock._boundingState != null) 401thisBufferBlock._boundingState.PostponedMessages, 456get { return _bufferBlock._boundingState?.PostponedMessages; } 462public Task? TaskForInputProcessing { get { return _bufferBlock._boundingState?.TaskForInputProcessing; } }