1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
1039_dataflowBlockOptions = dataflowBlockOptions;
19 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (19)
Blocks\JoinBlock.cs (19)
505GroupingDataflowBlockOptions dbo = sharedResources._dataflowBlockOptions; 516if (_sharedResources._dataflowBlockOptions.Greedy) 547if (_sharedResources._dataflowBlockOptions.Greedy) 575return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 584Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only valid in greedy mode"); 601Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 641Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 683Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only used in greedy mode"); 729int messageCount = _sharedResources._dataflowBlockOptions.Greedy ? 732if ((_sharedResources._joinsCreated + messageCount) >= _sharedResources._dataflowBlockOptions.ActualMaxNumberOfGroups) 835if (_sharedResources._dataflowBlockOptions.Greedy && 885bool greedy = _sharedResources._dataflowBlockOptions.Greedy; 1133if (_dataflowBlockOptions.Greedy && targetCanConsumePostponedMessages && (boundingCapacityAvailable || !target.HasTheHighestNumberOfMessagesAvailable)) return true; 1224return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _hasExceptions; 1279Exception? exception = Common.StartTaskSafe(_taskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 1343Debug.Assert(!_dataflowBlockOptions.Greedy || _boundingState != null, "This only makes sense in non-greedy or bounding mode"); 1348int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 1355madeProgress = !_dataflowBlockOptions.Greedy ? 1370if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1;