2 writes to _decliningPermanently
System.Threading.Tasks.Dataflow (2)
Blocks\JoinBlock.cs (2)
757if (allAreDecliningPermanently) _sharedResources._decliningPermanently = true; 1343_decliningPermanently = true;
11 references to _decliningPermanently
System.Threading.Tasks.Dataflow (11)
Blocks\JoinBlock.cs (11)
156if (!_sharedResources._decliningPermanently) _sharedResources._exceptionAction(exception); 229public bool IsDecliningPermanently { get { return _joinBlock._sharedResources._decliningPermanently; } } 383if (!_sharedResources._decliningPermanently) _sharedResources._exceptionAction(exception); 459public bool IsDecliningPermanently { get { return _joinBlock._sharedResources._decliningPermanently; } } 711if (_decliningPermanently || _sharedResources._decliningPermanently || 835if (_decliningPermanently || _sharedResources._decliningPermanently) 902if (exception != null && ((!_decliningPermanently && !_sharedResources._decliningPermanently) || releaseReservedMessages)) 984public bool IsDecliningPermanently { get { return _joinBlockTarget._decliningPermanently || _joinBlockTarget._sharedResources._decliningPermanently; } } 1123(_decliningPermanently || target.IsDecliningPermanently || !target.HasAtLeastOnePostponedMessage)) 1145bool targetCanConsumePostponedMessages = !_decliningPermanently && !target.IsDecliningPermanently && target.HasAtLeastOnePostponedMessage; 1318bool impossibleToCompleteAnotherJoin = _decliningPermanently && !AllTargetsHaveAtLeastOneMessage;