1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
318_dataflowBlockOptions = dataflowBlockOptions;
21 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (21)
Blocks\BatchBlock.cs (21)
322if (!_dataflowBlockOptions.Greedy || boundingEnabled) _nonGreedyState = new NonGreedyState(batchSize); 335if (!_decliningPermanently && !_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 373if (_dataflowBlockOptions.Greedy && 395(_batchesCompleted + (_messages.Count / _batchSize)) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 415if (!_dataflowBlockOptions.Greedy) ProcessAsyncIfNecessary(); 483return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _owningBatch._source.HasExceptions; 495_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount : 508bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 568bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 595if (_dataflowBlockOptions.Greedy) 653Exception? exception = Common.StartTaskSafe(_nonGreedyState.TaskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 670int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 684if (!_dataflowBlockOptions.Greedy) RetrievePostponedItemsNonGreedy(allowFewerThanBatchSize: triggered); 744if (_batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups) _decliningPermanently = true; 755Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 840(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 872Debug.Assert(_dataflowBlockOptions.Greedy, "This method may only be used in greedy mode."); 952(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 981Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 1031Debug.Assert(_dataflowBlockOptions.Greedy, "This method may only be used in greedy mode."); 1188public GroupingDataflowBlockOptions DataflowBlockOptions { get { return _target._dataflowBlockOptions; } }