PostponedMessages

26 references to PostponedMessages

System.Threading.Tasks.Dataflow (26)

Blocks\BroadcastBlock.cs (8)

189(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 209Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 212_boundingState.PostponedMessages.Push(source, messageHeader); 254_boundingState.PostponedMessages.Count > 0 && 268_boundingState.PostponedMessages.Count); 345if (!_boundingState.PostponedMessages.TryPop(out sourceAndMessage)) return false; 386if (_boundingState != null && _boundingState.PostponedMessages.Count > 0) 398thisBroadcastBlock._boundingState.PostponedMessages,

Blocks\BufferBlock.cs (9)

114(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 135Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 138_boundingState.PostponedMessages.Push(source, messageHeader); 255_boundingState.PostponedMessages.Count > 0 && 269_boundingState.PostponedMessages.Count); 348if (!_boundingState.PostponedMessages.TryPop(out sourceAndMessage)) return false; 389if (_boundingState != null && _boundingState.PostponedMessages.Count > 0) 401thisBufferBlock._boundingState.PostponedMessages, 456get { return _bufferBlock._boundingState?.PostponedMessages; }

Internal\Common.cs (1)

667private int PostponedMessagesCountForDebugger { get { return PostponedMessages.Count; } }

Internal\TargetCore.cs (8)

203(_boundingState.OutstandingTransfers == 0 && _boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0)) 227Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 231_boundingState.PostponedMessages.Push(source, messageHeader); 360(!_decliningPermanently && _boundingState != null && _boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count > 0); 380_messages.Count + (_boundingState != null ? _boundingState.PostponedMessages.Count : 0)); 651if (!_boundingState!.CountIsLessThanBound || !_boundingState.PostponedMessages.TryPop(out element)) 765Common.ReleaseAllPostponedMessages(_owningTarget, _boundingState.PostponedMessages, ref _exceptions); 861get { return _target._boundingState?.PostponedMessages; }