2 writes to _decliningPermanently
System.Threading.Tasks.Dataflow (2)
Blocks\JoinBlock.cs (2)
745if (allAreDecliningPermanently) _sharedResources._decliningPermanently = true; 1328_decliningPermanently = true;
11 references to _decliningPermanently
System.Threading.Tasks.Dataflow (11)
Blocks\JoinBlock.cs (11)
150if (!_sharedResources._decliningPermanently) _sharedResources._exceptionAction(exception); 223public bool IsDecliningPermanently { get { return _joinBlock._sharedResources._decliningPermanently; } } 371if (!_sharedResources._decliningPermanently) _sharedResources._exceptionAction(exception); 447public bool IsDecliningPermanently { get { return _joinBlock._sharedResources._decliningPermanently; } } 699if (_decliningPermanently || _sharedResources._decliningPermanently || 823if (_decliningPermanently || _sharedResources._decliningPermanently) 890if (exception != null && ((!_decliningPermanently && !_sharedResources._decliningPermanently) || releaseReservedMessages)) 969public bool IsDecliningPermanently { get { return _joinBlockTarget._decliningPermanently || _joinBlockTarget._sharedResources._decliningPermanently; } } 1108(_decliningPermanently || target.IsDecliningPermanently || !target.HasAtLeastOnePostponedMessage)) 1130bool targetCanConsumePostponedMessages = !_decliningPermanently && !target.IsDecliningPermanently && target.HasAtLeastOnePostponedMessage; 1303bool impossibleToCompleteAnotherJoin = _decliningPermanently && !AllTargetsHaveAtLeastOneMessage;