OfferMessage() [1/2]

DataflowMessageStatus ITargetBlock< T >. System.Threading.Tasks.Dataflow.BroadcastBlock< T >.OfferMessage ( DataflowMessageHeader messageHeader, T messageValue, ISourceBlock< T > source, bool consumeToAccept )

inlineprivate

Definition at line 701 of file BroadcastBlock.cs.

    {
        if (!messageHeader.IsValid)
        {
            throw new ArgumentException(System.SR.Argument_InvalidMessageHeader, "messageHeader");
        }
        if (source == null && consumeToAccept)
        {
            throw new ArgumentException(System.SR.Argument_CantConsumeFromANullSource, "consumeToAccept");
        }
        lock (IncomingLock)
        {
            if (_decliningPermanently)
            {
                CompleteTargetIfPossible();
                return DataflowMessageStatus.DecliningPermanently;
            }
            if (_boundingState == null || (_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null))
            {
                if (consumeToAccept)
                {
                    messageValue = source.ConsumeMessage(messageHeader, this, out var messageConsumed);
                    if (!messageConsumed)
                    {
                        return DataflowMessageStatus.NotAvailable;
                    }
                }
                _source.AddMessage(messageValue);
                if (_boundingState != null)
                {
                    _boundingState.CurrentCount++;
                }
                return DataflowMessageStatus.Accepted;
            }
            if (source != null)
            {
                _boundingState.PostponedMessages.Push(source, messageHeader);
                return DataflowMessageStatus.Postponed;
            }
            return DataflowMessageStatus.Declined;
        }
    }

References System.Threading.Tasks.Dataflow.BroadcastBlock< T >._boundingState, System.Threading.Tasks.Dataflow.BroadcastBlock< T >._decliningPermanently, System.Threading.Tasks.Dataflow.BroadcastBlock< T >._source, System.Threading.Tasks.Dataflow.BroadcastBlock< T >.BroadcastingSourceCore< TOutput >.AddMessage(), System.SR.Argument_CantConsumeFromANullSource, System.SR.Argument_InvalidMessageHeader, System.Threading.Tasks.Dataflow.BroadcastBlock< T >.CompleteTargetIfPossible(), System.Threading.Tasks.Dataflow.BroadcastBlock< T >.IncomingLock, System.source, and System.Threading.Tasks.Dataflow.Internal.BoundingStateWithPostponedAndTask< TInput >.TaskForInputProcessing.