Common

Base\DataflowBlock.cs (58)

Blocks\ActionBlock.cs (9)

119Common.WireCancellationToComplete( 144if (!Common.IsCooperativeCancellation(exc)) throw; 176if (caughtException != null && !Common.IsCooperativeCancellation(caughtException)) 178Common.StoreDataflowMessageValueIntoExceptionData(caughtException, messageWithId.Key); 196}, this, CancellationToken.None, Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default); 285_defaultTarget.OfferMessage(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatus.Accepted : 312return Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions); 317$"{(Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions))}, InputCount = {InputCountForDebugger}"; 381public 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( 209public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 213$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}"; 257public int Id { get { return Common.GetBlockId(_batchedJoinBlock); } } 356}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 359Common.WireCancellationToComplete( 467public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 471$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}"; 517public int Id { get { return Common.GetBlockId(_batchedJoinBlock); } } 562Common.ContractAssertMonitorStatus(_sharedResources._incomingLock, held: true); 637$"{Common.GetNameForDebugger(this)} InputCount = {_messages.Count}";

Blocks\BroadcastBlock.cs (33)

Blocks\BufferBlock.cs (15)

78}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 81Common.WireCancellationToComplete( 226Common.ContractAssertMonitorStatus(IncomingLock, held: false); 250Common.ContractAssertMonitorStatus(IncomingLock, held: true); 262Common.GetCreationOptionsForTask(isReplacementReplica)); 273Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 278exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 291Common.ContractAssertMonitorStatus(IncomingLock, held: false); 337Common.ContractAssertMonitorStatus(IncomingLock, held: false); 380Common.ContractAssertMonitorStatus(IncomingLock, held: true); 400Common.ReleaseAllPostponedMessages(thisBufferBlock, 413}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 427public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 431$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, Count = {CountForDebugger}"; 474public int Id { get { return Common.GetBlockId(_bufferBlock); } }

Blocks\JoinBlock.cs (41)

Blocks\TransformBlock.cs (11)

148}, _source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 159}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 162Common.WireCancellationToComplete( 187if (!Common.IsCooperativeCancellation(exc)) throw; 244if (caughtException != null && !Common.IsCooperativeCancellation(caughtException)) 246Common.StoreDataflowMessageValueIntoExceptionData(caughtException, messageWithId.Key); 265Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default); 291Common.StoreDataflowMessageValueIntoExceptionData(aggregate, messageWithId.Key, targetInnerExceptions: true); 400public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 404$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 448public 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."); 606public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 610$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 654public int Id { get { return Common.GetBlockId(_transformManyBlock); } }

Blocks\TransformManyBlock.IAsyncEnumerable.cs (3)

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

Blocks\WriteOnceBlock.cs (15)

97Common.WireCancellationToComplete( 116Common.ContractAssertMonitorStatus(ValueLock, held: false); 124Common.GetCreationOptionsForTask()); 134Exception? exception = Common.StartTaskSafe(taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 145Tuple.Create(this, exceptions), CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 193if (Interlocked.CompareExchange(ref _lazyCompletionTaskSource, Common.CompletedVoidResultTaskCompletionSource, null) != null) 325return Common.CreateUnlinker(ValueLock, _targetRegistry, target); 338if (linkOptions.PropagateCompletion) Common.PropagateCompletionOnceCompleted(Completion, target); 369_header = Common.SingleMessageHeader; 455Common.ContractAssertMonitorStatus(ValueLock, held: false); 482Common.StoreDataflowMessageValueIntoExceptionData(exc, _value!); 483Common.AddException(ref exceptions, exc); 515public override string ToString() { return Common.GetNameForDebugger(this, _dataflowBlockOptions); } 519$"{Common.GetNameForDebugger(this, _dataflowBlockOptions)}, HasValue = {HasValue}, Value = {Value}"; 541public 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)}\"";