Common

Base\DataflowBlock.cs (58)

Blocks\ActionBlock.cs (9)

113Common.WireCancellationToComplete( 138if (!Common.IsCooperativeCancellation(exc)) throw; 170if (caughtException != null && !Common.IsCooperativeCancellation(caughtException)) 172Common.StoreDataflowMessageValueIntoExceptionData(caughtException, messageWithId.Key); 190}, this, CancellationToken.None, Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default); 276_defaultTarget.OfferMessage(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatus.Accepted : 303return Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions); 308$"{(Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions))}, InputCount = {InputCountForDebugger}"; 372public int Id { get { return Common.GetBlockId(_actionBlock); } }

Blocks\BatchBlock.cs (23)

Blocks\BatchedJoinBlock.cs (12)

104}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 107Common.WireCancellationToComplete( 206public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 210$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}"; 254public int Id { get { return Common.GetBlockId(_batchedJoinBlock); } } 353}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 356Common.WireCancellationToComplete( 461public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 465$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}"; 511public int Id { get { return Common.GetBlockId(_batchedJoinBlock); } } 556Common.ContractAssertMonitorStatus(_sharedResources._incomingLock, held: true); 628$"{Common.GetNameForDebugger(this)} InputCount = {_messages.Count}";

Blocks\BroadcastBlock.cs (33)

Blocks\BufferBlock.cs (15)

75}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 78Common.WireCancellationToComplete( 220Common.ContractAssertMonitorStatus(IncomingLock, held: false); 244Common.ContractAssertMonitorStatus(IncomingLock, held: true); 256Common.GetCreationOptionsForTask(isReplacementReplica)); 267Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 272exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 285Common.ContractAssertMonitorStatus(IncomingLock, held: false); 331Common.ContractAssertMonitorStatus(IncomingLock, held: false); 374Common.ContractAssertMonitorStatus(IncomingLock, held: true); 394Common.ReleaseAllPostponedMessages(thisBufferBlock, 407}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 421public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 425$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, Count = {CountForDebugger}"; 468public int Id { get { return Common.GetBlockId(_bufferBlock); } }

Blocks\JoinBlock.cs (41)

Blocks\TransformBlock.cs (11)

145}, _source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 156}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 159Common.WireCancellationToComplete( 184if (!Common.IsCooperativeCancellation(exc)) throw; 241if (caughtException != null && !Common.IsCooperativeCancellation(caughtException)) 243Common.StoreDataflowMessageValueIntoExceptionData(caughtException, messageWithId.Key); 262Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default); 288Common.StoreDataflowMessageValueIntoExceptionData(aggregate, messageWithId.Key, targetInnerExceptions: true); 394public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 398$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 442public int Id { get { return Common.GetBlockId(_transformBlock); } }

Blocks\TransformManyBlock.cs (14)

144}, source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 155}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 158Common.WireCancellationToComplete( 180catch (Exception exc) when (Common.IsCooperativeCancellation(exc)) 211if (caughtException != null && !Common.IsCooperativeCancellation(caughtException)) 213Common.StoreDataflowMessageValueIntoExceptionData(caughtException, messageWithId.Key); 246Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), 272if (!Common.IsCooperativeCancellation(exc)) 277Common.StoreDataflowMessageValueIntoExceptionData(exc, messageWithId.Key); 287Common.StoreDataflowMessageValueIntoExceptionData(aggregate, messageWithId.Key, targetInnerExceptions: true); 351Debug.Assert(id != Common.INVALID_REORDERING_ID, "This ID should never have been handed out."); 603public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 607$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 651public int Id { get { return Common.GetBlockId(_transformManyBlock); } }

Blocks\TransformManyBlock.IAsyncEnumerable.cs (3)

66if (!Common.IsCooperativeCancellation(exc)) 71Common.StoreDataflowMessageValueIntoExceptionData(exc, messageWithId.Key); 120Debug.Assert(id != Common.INVALID_REORDERING_ID, "This ID should never have been handed out.");

Blocks\WriteOnceBlock.cs (15)

94Common.WireCancellationToComplete( 113Common.ContractAssertMonitorStatus(ValueLock, held: false); 121Common.GetCreationOptionsForTask()); 131Exception? exception = Common.StartTaskSafe(taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 142Tuple.Create(this, exceptions), CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 190if (Interlocked.CompareExchange(ref _lazyCompletionTaskSource, Common.CompletedVoidResultTaskCompletionSource, null) != null) 313return Common.CreateUnlinker(ValueLock, _targetRegistry, target); 326if (linkOptions.PropagateCompletion) Common.PropagateCompletionOnceCompleted(Completion, target); 357_header = Common.SingleMessageHeader; 443Common.ContractAssertMonitorStatus(ValueLock, held: false); 470Common.StoreDataflowMessageValueIntoExceptionData(exc, _value!); 471Common.AddException(ref exceptions, exc); 503public override string ToString() { return Common.GetNameForDebugger(this, _dataflowBlockOptions); } 507$"{Common.GetNameForDebugger(this, _dataflowBlockOptions)}, HasValue = {HasValue}, Value = {Value}"; 529public int Id { get { return Common.GetBlockId(_writeOnceBlock); } }

Internal\Common.cs (8)

106Task? t = Common.GetPotentiallyNotSupportedCompletionTask(block); 205reg, cancellationToken, Common.GetContinuationOptions(), TaskScheduler.Default); 245StoreStringIntoExceptionData(exc, Common.EXCEPTIONDATAKEY_DATAFLOWMESSAGEVALUE, strValue); 256StoreStringIntoExceptionData(innerException, Common.EXCEPTIONDATAKEY_DATAFLOWMESSAGEVALUE, strValue); 262StoreStringIntoExceptionData(exc.InnerException, Common.EXCEPTIONDATAKEY_DATAFLOWMESSAGEVALUE, strValue); 527Common.AddException(ref exceptions, exc); 573sourceCompletionTask.ContinueWith(static (task, state) => Common.PropagateCompletion(task, (IDataflowBlock)state!, AsyncExceptionHandler), 574target, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default);

Internal\DataflowEtwProvider.cs (9)

72Common.GetNameForDebugger(block, dataflowBlockOptions), 73Common.GetBlockId(block)); 100TaskLaunchedForMessageHandling(Common.GetBlockId(block), reason, availableMessages, task.Id); 133Task? completionTask = Common.GetPotentiallyNotSupportedCompletionTask(block); 147DataflowBlockCompleted(Common.GetBlockId(block), reason, exceptionData); 185DataflowBlockLinking(Common.GetBlockId(source), Common.GetBlockId(target)); 208DataflowBlockUnlinking(Common.GetBlockId(source), Common.GetBlockId(target));

Internal\ReorderingBuffer.cs (7)

71Debug.Assert(id != Common.INVALID_REORDERING_ID, "This ID should never have been handed out."); 72Common.ContractAssertMonitorStatus(ValueLock, held: false); 97Debug.Assert(id != Common.INVALID_REORDERING_ID, "This ID should never have been handed out."); 98Common.ContractAssertMonitorStatus(ValueLock, held: false); 123Debug.Assert(id != Common.INVALID_REORDERING_ID, "This ID should never have been handed out."); 124Common.ContractAssertMonitorStatus(ValueLock, held: false); 157Common.ContractAssertMonitorStatus(ValueLock, held: true);

Internal\SourceCore.cs (22)

Internal\SpscTargetCore.cs (3)

168this, CancellationToken.None, Common.GetCreationOptionsForTask(isReplica)); 223if (!Common.IsCooperativeCancellation(exc)) 226Common.StoreDataflowMessageValueIntoExceptionData<TInput>(exc, nextMessage!, false);

Internal\TargetCore.cs (25)

Internal\TargetRegistry.cs (3)

202if (node.PropagateCompletion) Common.PropagateCompletion(owningSourceCompletion, node.Target, Common.AsyncExceptionHandler); 362return $"{Common.GetNameForDebugger(this)} Source = \"{(displaySource != null ? displaySource.Content : _owningSource)}\", Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\"";