1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
315_dataflowBlockOptions = dataflowBlockOptions;
21 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (21)
Blocks\BatchBlock.cs (21)
319if (!_dataflowBlockOptions.Greedy || boundingEnabled) _nonGreedyState = new NonGreedyState(batchSize); 332if (!_decliningPermanently && !_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 370if (_dataflowBlockOptions.Greedy && 392(_batchesCompleted + (_messages.Count / _batchSize)) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 412if (!_dataflowBlockOptions.Greedy) ProcessAsyncIfNecessary(); 480return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _owningBatch._source.HasExceptions; 492_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount : 505bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 565bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 592if (_dataflowBlockOptions.Greedy) 650Exception? exception = Common.StartTaskSafe(_nonGreedyState.TaskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 667int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 681if (!_dataflowBlockOptions.Greedy) RetrievePostponedItemsNonGreedy(allowFewerThanBatchSize: triggered); 741if (_batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups) _decliningPermanently = true; 752Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 837(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 869Debug.Assert(_dataflowBlockOptions.Greedy, "This method may only be used in greedy mode."); 949(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 978Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 1028Debug.Assert(_dataflowBlockOptions.Greedy, "This method may only be used in greedy mode."); 1185public GroupingDataflowBlockOptions DataflowBlockOptions { get { return _target._dataflowBlockOptions; } }