6 writes to _decliningPermanently
System.Threading.Tasks.Dataflow (6)
Blocks\BatchBlock.cs (6)
397_decliningPermanently = true; 467_decliningPermanently = true; 517_decliningPermanently = true; 744if (_batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups) _decliningPermanently = true; 847_decliningPermanently = true; 959_decliningPermanently = true;
13 references to _decliningPermanently
System.Threading.Tasks.Dataflow (13)
Blocks\BatchBlock.cs (13)
335if (!_decliningPermanently && !_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 361if (_decliningPermanently) 394if (!_decliningPermanently && 435if (exception != null && (!_decliningPermanently || releaseReservedMessages)) 509bool noMoreMessages = _decliningPermanently && _messages.Count < _batchSize; 588if (_decliningPermanently) 777if (_decliningPermanently || 839if (!_decliningPermanently && 846shouldProceedToConsume = !_decliningPermanently; 894if (_decliningPermanently || 951if (!_decliningPermanently && 958shouldProceedToConsume = !_decliningPermanently; 1186public bool IsDecliningPermanently { get { return _target._decliningPermanently; } }