DataflowMessageStatus

93 references to DataflowMessageStatus

System.Threading.Tasks.Dataflow (93)

Base\DataflowBlock.cs (30)

148DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 165else return DataflowMessageStatus.Declined; 262return target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false) == DataflowMessageStatus.Accepted; 327case DataflowMessageStatus.Accepted: 331case DataflowMessageStatus.DecliningPermanently: 335case DataflowMessageStatus.Postponed: 339case DataflowMessageStatus.NotAvailable: 597case DataflowMessageStatus.Accepted: 614case DataflowMessageStatus.Declined: 615case DataflowMessageStatus.DecliningPermanently: 619case DataflowMessageStatus.NotAvailable: 1179DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1185DataflowMessageStatus status = DataflowMessageStatus.NotAvailable; 1190if (Volatile.Read(ref _cleanupReserved)) return DataflowMessageStatus.DecliningPermanently; 1195if (_cleanupReserved) return DataflowMessageStatus.DecliningPermanently; 1204status = DataflowMessageStatus.Accepted; 1212status = DataflowMessageStatus.DecliningPermanently; 1220if (status == DataflowMessageStatus.Accepted) 1224else if (status == DataflowMessageStatus.DecliningPermanently) // should only be the case if an error occurred 1548DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1554return DataflowMessageStatus.DecliningPermanently; 1649public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 2237public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 2246if (_completed.Value != null || base.Task.IsCompleted) return DataflowMessageStatus.DecliningPermanently; 2253if (!consumed) return DataflowMessageStatus.NotAvailable; 2259return DataflowMessageStatus.Accepted; 2754DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 2766if (!messageConsumed) return DataflowMessageStatus.NotAvailable; 2770return DataflowMessageStatus.Accepted;

Base\ITargetBlock.cs (1)

22DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept);

Blocks\ActionBlock.cs (2)

285_defaultTarget.OfferMessage(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatus.Accepted : 290DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)

Blocks\BatchBlock.cs (7)

152DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 352internal DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 364return DataflowMessageStatus.DecliningPermanently; 385if (!consumed) return DataflowMessageStatus.NotAvailable; 404return DataflowMessageStatus.Accepted; 417return DataflowMessageStatus.Postponed; 420return DataflowMessageStatus.Declined;

Blocks\BatchedJoinBlock.cs (4)

570public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 581return DataflowMessageStatus.DecliningPermanently; 590if (!consumed) return DataflowMessageStatus.NotAvailable; 597return DataflowMessageStatus.Accepted;

Blocks\BroadcastBlock.cs (13)

166DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 178return DataflowMessageStatus.DecliningPermanently; 198if (!consumed) return DataflowMessageStatus.NotAvailable; 204return DataflowMessageStatus.Accepted; 213return DataflowMessageStatus.Postponed; 216return DataflowMessageStatus.Declined; 693DataflowMessageStatus result = target.OfferMessage(new DataflowMessageHeader(_nextMessageId), currentMessage!, _owningSource, consumeToAccept: useCloning); 696if (result == DataflowMessageStatus.Accepted) 707else if (result == DataflowMessageStatus.DecliningPermanently) 711else Debug.Assert(result != DataflowMessageStatus.NotAvailable, "Messages from a Broadcast should never be missed."); 800case DataflowMessageStatus.Accepted: 810case DataflowMessageStatus.DecliningPermanently: 815case DataflowMessageStatus.NotAvailable:

Blocks\BufferBlock.cs (6)

91DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 103return DataflowMessageStatus.DecliningPermanently; 123if (!consumed) return DataflowMessageStatus.NotAvailable; 130return DataflowMessageStatus.Accepted; 139return DataflowMessageStatus.Postponed; 142return DataflowMessageStatus.Declined;

Blocks\JoinBlock.cs (6)

826DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 838return DataflowMessageStatus.DecliningPermanently; 859if (!consumed) return DataflowMessageStatus.NotAvailable; 874return DataflowMessageStatus.Accepted; 884return DataflowMessageStatus.Postponed; 887return DataflowMessageStatus.Declined;

Blocks\TransformBlock.cs (1)

371DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)

Blocks\TransformManyBlock.cs (1)

577DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept)

Blocks\WriteOnceBlock.cs (4)

347DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 357if (_decliningPermanently) return DataflowMessageStatus.DecliningPermanently; 365if (!consumed) return DataflowMessageStatus.NotAvailable; 383return DataflowMessageStatus.Accepted;

Internal\SourceCore.cs (5)

677DataflowMessageStatus result = target.OfferMessage(header, message, _owningSource, consumeToAccept: false); 678Debug.Assert(result != DataflowMessageStatus.NotAvailable, "Messages are not being offered concurrently, so nothing should be missed."); 682if (result == DataflowMessageStatus.Accepted) 689else if (result == DataflowMessageStatus.DecliningPermanently) 696Debug.Assert(result == DataflowMessageStatus.Postponed,

Internal\SpscTargetCore.cs (6)

111internal DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 115DataflowMessageStatus.Accepted : 125private DataflowMessageStatus OfferMessage_Slow(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 130return DataflowMessageStatus.DecliningPermanently; 145if (!consumed) return DataflowMessageStatus.NotAvailable; 155return DataflowMessageStatus.Accepted;

Internal\TargetCore.cs (6)

181internal DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 193return DataflowMessageStatus.DecliningPermanently; 212if (!consumed) return DataflowMessageStatus.NotAvailable; 222return DataflowMessageStatus.Accepted; 233return DataflowMessageStatus.Postponed; 236return DataflowMessageStatus.Declined;

Internal\TargetRegistry.cs (1)

321DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)