1 write to _boundingState
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
81_boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity);
40 references to _boundingState
System.Threading.Tasks.Dataflow (40)
Blocks\BroadcastBlock.cs (40)
142Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 144_boundingState.TaskForInputProcessing = null; 187if (_boundingState == null 189(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 203if (_boundingState != null) _boundingState.CurrentCount += 1; // track this new item against our bound 209Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 212_boundingState.PostponedMessages.Push(source, messageHeader); 230if (_boundingState != null) 235Debug.Assert(_boundingState.CurrentCount - numItemsRemoved >= 0, 237_boundingState.CurrentCount -= numItemsRemoved; 250Debug.Assert(_boundingState != null, "Must be in bounded mode."); 253_boundingState.TaskForInputProcessing == null && 254_boundingState.PostponedMessages.Count > 0 && 255_boundingState.CountIsLessThanBound) 259_boundingState.TaskForInputProcessing = 267this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 268_boundingState.PostponedMessages.Count); 272Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 285Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 287Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 309_boundingState.TaskForInputProcessing = null; 331Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 333Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 344if (!_boundingState.CountIsLessThanBound) return false; 345if (!_boundingState.PostponedMessages.TryPop(out sourceAndMessage)) return false; 349_boundingState.CurrentCount++; 368lock (IncomingLock) _boundingState.CurrentCount--; 380(_boundingState == null || _boundingState.TaskForInputProcessing == null)) 386if (_boundingState != null && _boundingState.PostponedMessages.Count > 0) 394if (thisBroadcastBlock._boundingState != null) 398thisBroadcastBlock._boundingState.PostponedMessages,