26 references to PostponedMessages
System.Threading.Tasks.Dataflow (26)
Blocks\BroadcastBlock.cs (8)
183(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 203Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 206_boundingState.PostponedMessages.Push(source, messageHeader); 248_boundingState.PostponedMessages.Count > 0 && 262_boundingState.PostponedMessages.Count); 339if (!_boundingState.PostponedMessages.TryPop(out sourceAndMessage)) return false; 380if (_boundingState != null && _boundingState.PostponedMessages.Count > 0) 392thisBroadcastBlock._boundingState.PostponedMessages,
Blocks\BufferBlock.cs (9)
111(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 132Debug.Assert(_boundingState != null && _boundingState.PostponedMessages != null, 135_boundingState.PostponedMessages.Push(source, messageHeader); 249_boundingState.PostponedMessages.Count > 0 && 263_boundingState.PostponedMessages.Count); 342if (!_boundingState.PostponedMessages.TryPop(out sourceAndMessage)) return false; 383if (_boundingState != null && _boundingState.PostponedMessages.Count > 0) 395thisBufferBlock._boundingState.PostponedMessages, 450get { 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; }