1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
78_boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity);
40 references to _boundingState
System.Threading.Tasks.Dataflow (40)
Blocks\BroadcastBlock.cs (40)
136Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 138_boundingState.TaskForInputProcessing = null; 181if (_boundingState == null 183(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 197if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 203Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 206_boundingState.PostponedMessages.Push(source, messageHeader); 224if (_boundingState != null) 229Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0, 231_boundingState.CurrentCount -= numItemsRemoved; 244Debug.Assert(_boundingState != null, "Must be in bounded mode."); 247_boundingState.TaskForInputProcessing == null && 248_boundingState.PostponedMessages.Count > 0 && 249_boundingState.CountIsLessThanBound) 253_boundingState.TaskForInputProcessing = 261this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 262_boundingState.PostponedMessages.Count); 266Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 279Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 281Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 303_boundingState.TaskForInputProcessing = null; 325Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 327Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 338if (!_boundingState.CountIsLessThanBound) return false; 339if (!_boundingState.PostponedMessages.TryPop(out sourceAndMessage)) return false; 343_boundingState.CurrentCount++; 362lock (IncomingLock) _boundingState.CurrentCount--; 374(_boundingState == null || _boundingState.TaskForInputProcessing == null)) 380if (_boundingState != null && _boundingState.PostponedMessages.Count > 0) 388if (thisBroadcastBlock._boundingState != null) 392thisBroadcastBlock._boundingState.PostponedMessages,