DataflowMessageStatus

93 references to DataflowMessageStatus

System.Threading.Tasks.Dataflow (93)

Base\DataflowBlock.cs (30)

130DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 147else return DataflowMessageStatus.Declined; 241return target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false) == DataflowMessageStatus.Accepted; 303case DataflowMessageStatus.Accepted: 307case DataflowMessageStatus.DecliningPermanently: 311case DataflowMessageStatus.Postponed: 315case DataflowMessageStatus.NotAvailable: 573case DataflowMessageStatus.Accepted: 590case DataflowMessageStatus.Declined: 591case DataflowMessageStatus.DecliningPermanently: 595case DataflowMessageStatus.NotAvailable: 1146DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1152DataflowMessageStatus status = DataflowMessageStatus.NotAvailable; 1157if (Volatile.Read(ref _cleanupReserved)) return DataflowMessageStatus.DecliningPermanently; 1162if (_cleanupReserved) return DataflowMessageStatus.DecliningPermanently; 1171status = DataflowMessageStatus.Accepted; 1179status = DataflowMessageStatus.DecliningPermanently; 1187if (status == DataflowMessageStatus.Accepted) 1191else if (status == DataflowMessageStatus.DecliningPermanently) // should only be the case if an error occurred 1460DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 1467return DataflowMessageStatus.DecliningPermanently; 1547public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 2099public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 2108if (_completed.Value != null || base.Task.IsCompleted) return DataflowMessageStatus.DecliningPermanently; 2115if (!consumed) return DataflowMessageStatus.NotAvailable; 2121return DataflowMessageStatus.Accepted; 2607DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock<TInput>? source, bool consumeToAccept) 2619if (!messageConsumed) return DataflowMessageStatus.NotAvailable; 2623return DataflowMessageStatus.Accepted;

Base\ITargetBlock.cs (1)

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

Blocks\ActionBlock.cs (2)

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

Blocks\BatchBlock.cs (7)

149DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 349internal DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 361return DataflowMessageStatus.DecliningPermanently; 382if (!consumed) return DataflowMessageStatus.NotAvailable; 401return DataflowMessageStatus.Accepted; 414return DataflowMessageStatus.Postponed; 417return DataflowMessageStatus.Declined;

Blocks\BatchedJoinBlock.cs (4)

564public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 575return DataflowMessageStatus.DecliningPermanently; 584if (!consumed) return DataflowMessageStatus.NotAvailable; 591return DataflowMessageStatus.Accepted;

Blocks\BroadcastBlock.cs (13)

160DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 172return DataflowMessageStatus.DecliningPermanently; 192if (!consumed) return DataflowMessageStatus.NotAvailable; 198return DataflowMessageStatus.Accepted; 207return DataflowMessageStatus.Postponed; 210return DataflowMessageStatus.Declined; 687DataflowMessageStatus result = target.OfferMessage(new DataflowMessageHeader(_nextMessageId), currentMessage!, _owningSource, consumeToAccept: useCloning); 690if (result == DataflowMessageStatus.Accepted) 701else if (result == DataflowMessageStatus.DecliningPermanently) 705else Debug.Assert(result != DataflowMessageStatus.NotAvailable, "Messages from a Broadcast should never be missed."); 794case DataflowMessageStatus.Accepted: 804case DataflowMessageStatus.DecliningPermanently: 809case DataflowMessageStatus.NotAvailable:

Blocks\BufferBlock.cs (6)

88DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 100return DataflowMessageStatus.DecliningPermanently; 120if (!consumed) return DataflowMessageStatus.NotAvailable; 127return DataflowMessageStatus.Accepted; 136return DataflowMessageStatus.Postponed; 139return DataflowMessageStatus.Declined;

Blocks\JoinBlock.cs (6)

814DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 826return DataflowMessageStatus.DecliningPermanently; 847if (!consumed) return DataflowMessageStatus.NotAvailable; 862return DataflowMessageStatus.Accepted; 872return DataflowMessageStatus.Postponed; 875return DataflowMessageStatus.Declined;

Blocks\TransformBlock.cs (1)

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

Blocks\TransformManyBlock.cs (1)

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

Blocks\WriteOnceBlock.cs (4)

335DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept) 345if (_decliningPermanently) return DataflowMessageStatus.DecliningPermanently; 353if (!consumed) return DataflowMessageStatus.NotAvailable; 371return DataflowMessageStatus.Accepted;

Internal\SourceCore.cs (5)

671DataflowMessageStatus result = target.OfferMessage(header, message, _owningSource, consumeToAccept: false); 672Debug.Assert(result != DataflowMessageStatus.NotAvailable, "Messages are not being offered concurrently, so nothing should be missed."); 676if (result == DataflowMessageStatus.Accepted) 683else if (result == DataflowMessageStatus.DecliningPermanently) 690Debug.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)