1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
1054_dataflowBlockOptions = dataflowBlockOptions;
19 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (19)
Blocks\JoinBlock.cs (19)
517GroupingDataflowBlockOptions dbo = sharedResources._dataflowBlockOptions; 528if (_sharedResources._dataflowBlockOptions.Greedy) 559if (_sharedResources._dataflowBlockOptions.Greedy) 587return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 596Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only valid in greedy mode"); 613Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 653Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 695Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only used in greedy mode"); 741int messageCount = _sharedResources._dataflowBlockOptions.Greedy ? 744if ((_sharedResources._joinsCreated + messageCount) >= _sharedResources._dataflowBlockOptions.ActualMaxNumberOfGroups) 847if (_sharedResources._dataflowBlockOptions.Greedy && 897bool greedy = _sharedResources._dataflowBlockOptions.Greedy; 1148if (_dataflowBlockOptions.Greedy && targetCanConsumePostponedMessages && (boundingCapacityAvailable || !target.HasTheHighestNumberOfMessagesAvailable)) return true; 1239return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _hasExceptions; 1294Exception? exception = Common.StartTaskSafe(_taskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 1358Debug.Assert(!_dataflowBlockOptions.Greedy || _boundingState != null, "This only makes sense in non-greedy or bounding mode"); 1363int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 1370madeProgress = !_dataflowBlockOptions.Greedy ? 1385if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1;