212return $"{Common.GetNameForDebugger(this)} Source = \"{(displaySource != null ? displaySource.Content : _source)}\", Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\""; 262return target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false) == DataflowMessageStatus.Accepted; 316return Common.CreateTaskFromCancellation<bool>(cancellationToken); 324switch (target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false)) 328return Common.CompletedTaskWithTrueResult; 332return Common.CompletedTaskWithFalseResult; 354Common.StoreDataflowMessageValueIntoExceptionData(exc, item); 355return Common.CreateTaskFromException<bool>(exc); 537CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 551CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 564SendAsyncSource<TOutput>? source = Common.UnwrapWeakReference<SendAsyncSource<TOutput>>(state!); 594Common.SingleMessageHeader, _messageValue, this, consumeToAccept: consumeToAccept)) 636Common.StoreDataflowMessageValueIntoExceptionData(exc, _messageValue); 658bool validMessage = (messageHeader.Id == Common.SINGLE_MESSAGE_ID); 697bool reservable = (messageHeader.Id == Common.SINGLE_MESSAGE_ID); 711if (messageHeader.Id != Common.SINGLE_MESSAGE_ID) 748return $"{Common.GetNameForDebugger(this)} Message = {_messageValue}, Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\""; 815return ReceiveAsync(source, Common.InfiniteTimeSpan, CancellationToken.None); 832return ReceiveAsync(source, Common.InfiniteTimeSpan, cancellationToken); 878if (!Common.IsValidTimeout(timeout)) throw new ArgumentOutOfRangeException(nameof(timeout), SR.ArgumentOutOfRange_NeedNonNegOrNegative1); 896return Receive(source, Common.InfiniteTimeSpan, CancellationToken.None); 914return Receive(source, Common.InfiniteTimeSpan, cancellationToken); 963if (!Common.IsValidTimeout(timeout)) throw new ArgumentOutOfRangeException(nameof(timeout), SR.ArgumentOutOfRange_NeedNonNegOrNegative1); 1012return Common.CreateTaskFromCancellation<TOutput>(cancellationToken); 1031return Common.CreateTaskFromException<TOutput>(exc); 1039return Common.CreateTaskFromException<TOutput>(ReceiveTarget<TOutput>.CreateExceptionForTimeout()); 1213Common.StoreDataflowMessageValueIntoExceptionData(exc, messageValue); 1260Common.ContractAssertMonitorStatus(IncomingLock, held: false); 1370return Common.InitializeStackTrace(new InvalidOperationException(SR.InvalidOperation_DataNotAvailableForReceive)); 1377return Common.InitializeStackTrace(new TimeoutException()); 1393private object DebuggerDisplayContent => $"{Common.GetNameForDebugger(this)} IsCompleted = {base.Task.IsCompleted}"; 1444return Common.CreateTaskFromCancellation<bool>(cancellationToken); 1578private object DebuggerDisplayContent => $"{Common.GetNameForDebugger(this)} IsCompleted = {base.Task.IsCompleted}"; 1708return $"{Common.GetNameForDebugger(this)} Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\", Source = \"{(displaySource != null ? displaySource.Content : _source)}\""; 1971return Common.CreateTaskFromCancellation<int>(dataflowBlockOptions.CancellationToken); 1988return Common.CreateTaskFromException<int>(exc); 2027CancellationToken.None, Common.GetCreationOptionsForTask(), scheduler); 2091Common.AddException(ref exceptions, task.Exception!, unwrapInnerExceptions: true); 2124}, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 2145return Common.CreateTaskFromCancellation<int>(cts.Token); 2159return Common.CreateTaskFromException<int>(exc); 2193}, CancellationToken.None, Common.GetContinuationOptions(), scheduler); 2228Common.WireCancellationToComplete(cancellationToken, base.Task, 2276private object DebuggerDisplayContent => $"{Common.GetNameForDebugger(this)} IsCompleted = {base.Task.IsCompleted}"; 2350Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(_source); 2366Common.ContractAssertMonitorStatus(_SubscriptionLock, held: false); 2368Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(_source); 2416Common.ContractAssertMonitorStatus(_SubscriptionLock, held: false); 2446Common.ContractAssertMonitorStatus(_SubscriptionLock, held: true); 2529Common.GetContinuationOptions(TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.ExecuteSynchronously), 2534Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(Observable._source); 2542Common.GetContinuationOptions(TaskContinuationOptions.NotOnFaulted | TaskContinuationOptions.ExecuteSynchronously), 2544}, this, Canceler.Token, Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default); 2551Common.ContractAssertMonitorStatus(Observable._SubscriptionLock, held: false); 2597return Common.CreateTaskFromException<VoidResult>(exc); 2602return Common.CompletedTaskWithTrueResult; 2613Common.ContractAssertMonitorStatus(Observable._SubscriptionLock, held: false); 2650Common.ThrowAsync(exc);

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); } }

75CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 86}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 89Common.WireCancellationToComplete( 179public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 183$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}"; 229public int Id { get { return Common.GetBlockId(_batchBlock); } } 492Common.ContractAssertMonitorStatus(IncomingLock, held: true); 503Common.ContractAssertMonitorStatus(IncomingLock, held: true); 534Common.ReleaseAllPostponedMessages(targetCore._owningBatch, 550}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 563Common.ContractAssertMonitorStatus(IncomingLock, held: true); 623Common.ContractAssertMonitorStatus(IncomingLock, held: true); 642Common.GetCreationOptionsForTask(isReplacementReplica)); 653Exception? exception = Common.StartTaskSafe(_nonGreedyState.TaskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 658exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 667Common.ContractAssertMonitorStatus(IncomingLock, held: false); 732Common.ContractAssertMonitorStatus(IncomingLock, held: true); 757Common.ContractAssertMonitorStatus(IncomingLock, held: false); 875Common.ContractAssertMonitorStatus(IncomingLock, held: false); 984Common.ContractAssertMonitorStatus(IncomingLock, held: false); 1035Common.ContractAssertMonitorStatus(IncomingLock, held: false); 1085Common.ContractAssertMonitorStatus(IncomingLock, held: false); 1118Common.ContractAssertMonitorStatus(IncomingLock, held: false);

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}";

96}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 99Common.WireCancellationToComplete( 225Common.ContractAssertMonitorStatus(IncomingLock, held: false); 249Common.ContractAssertMonitorStatus(IncomingLock, held: true); 261Common.GetCreationOptionsForTask(isReplacementReplica)); 272Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 277exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 289Common.ContractAssertMonitorStatus(IncomingLock, held: false); 335Common.ContractAssertMonitorStatus(IncomingLock, held: false); 377Common.ContractAssertMonitorStatus(IncomingLock, held: true); 397Common.ReleaseAllPostponedMessages(thisBroadcastBlock, 410}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 444public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 447private object DebuggerDisplayContent => $"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, HasValue = {HasValueForDebugger}, Value = {ValueForDebugger}"; 486public int Id { get { return Common.GetBlockId(_broadcastBlock); } } 656}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 675Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 676Common.ContractAssertMonitorStatus(ValueLock, held: false); 717Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 718Common.ContractAssertMonitorStatus(ValueLock, held: false); 790Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 791Common.ContractAssertMonitorStatus(ValueLock, held: false); 826Common.ContractAssertMonitorStatus(ValueLock, held: true); 838Common.GetCreationOptionsForTask(isReplacementReplica)); 848Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 870}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 921Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 922Common.ContractAssertMonitorStatus(ValueLock, held: true); 953this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 1028if (linkOptions.PropagateCompletion) Common.PropagateCompletionOnceCompleted(_completionTask.Task, target); 1039return Common.CreateUnlinker(OutgoingLock, _targetRegistry, target); 1166Common.AddException(ref _exceptions, exception); 1180Common.AddException(ref _exceptions, exception);

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); } }

89CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 100}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 103Common.WireCancellationToComplete( 190public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 194$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, OutputCount = {OutputCountForDebugger}"; 233public int Id { get { return Common.GetBlockId(_joinBlock); } } 314CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 325}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 328Common.WireCancellationToComplete( 420public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 424$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)} OutputCount = {OutputCountForDebugger}"; 463public int Id { get { return Common.GetBlockId(_joinBlock); } } 527Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: true); 548Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: true); 558Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: true); 576Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: true); 586Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: true); 597Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: true); 612Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: false); 652Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: false); 694Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: false); 740Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: true); 764Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: false); 779Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: false); 788Common.ContractAssertMonitorStatus(_sharedResources.IncomingLock, held: false); 806Common.ReleaseAllPostponedMessages(this, _nonGreedy.PostponedMessages, ref exceptions); 961return $"{Common.GetNameForDebugger(this)} InputCount = {InputCountForDebugger}, Join = \"{(displayJoin != null ? displayJoin.Content : _sharedResources._ownerJoin)}\""; 1102Common.ContractAssertMonitorStatus(IncomingLock, held: true); 1116Common.ContractAssertMonitorStatus(IncomingLock, held: true); 1171Common.ContractAssertMonitorStatus(IncomingLock, held: false); 1220Common.ContractAssertMonitorStatus(IncomingLock, held: false); 1238Common.ContractAssertMonitorStatus(IncomingLock, held: true); 1251Common.ContractAssertMonitorStatus(IncomingLock, held: true); 1263Common.ContractAssertMonitorStatus(IncomingLock, held: true); 1278Common.ContractAssertMonitorStatus(IncomingLock, held: true); 1283Common.GetCreationOptionsForTask(isReplacementReplica)); 1294Exception? exception = Common.StartTaskSafe(_taskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 1312Common.ContractAssertMonitorStatus(IncomingLock, held: true); 1350}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 1359Common.ContractAssertMonitorStatus(IncomingLock, held: false); 1425Common.ContractAssertMonitorStatus(IncomingLock, held: false);

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); } }

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); } }

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

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); } }

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);

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));

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);

140if (linkOptions.PropagateCompletion) Common.PropagateCompletion(_completionTask.Task, target, exceptionHandler: null); 152return Common.CreateUnlinker(OutgoingLock, _targetRegistry, target); 158if (linkOptions.PropagateCompletion) Common.PropagateCompletionOnceCompleted(_completionTask.Task, target); 466Common.AddException(ref _exceptions, exception); 480Common.AddException(ref _exceptions, exception); 493Common.AddException(ref _exceptions, aggregateException, unwrapInnerExceptions: true); 529}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 543Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 544Common.ContractAssertMonitorStatus(ValueLock, held: false); 674Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 675Common.ContractAssertMonitorStatus(ValueLock, held: false); 723Common.ContractAssertMonitorStatus(ValueLock, held: true); 740Common.ContractAssertMonitorStatus(ValueLock, held: true); 750Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 760Common.GetCreationOptionsForTask(isReplacementReplica)); 770Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 792}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 892Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 893Common.ContractAssertMonitorStatus(ValueLock, held: true); 915Common.ContractAssertMonitorStatus(OutgoingLock, held: true); 916Common.ContractAssertMonitorStatus(ValueLock, held: true); 926this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);

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

51private static readonly Common.KeepAlivePredicate<TargetCore<TInput>, KeyValuePair<TInput, long>> _keepAlivePredicate = 155Common.AddException(ref _exceptions, exception, unwrapInnerExceptions); 218Debug.Assert(messageId != Common.INVALID_REORDERING_ID, "The assigned message ID is invalid."); 298Common.ContractAssertMonitorStatus(IncomingLock, held: true); 314Common.ContractAssertMonitorStatus(IncomingLock, held: true); 340Common.ContractAssertMonitorStatus(IncomingLock, held: true); 355Common.ContractAssertMonitorStatus(IncomingLock, held: true); 373Common.GetCreationOptionsForTask(repeat)); 384Exception? exception = Common.StartTaskSafe(taskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 390exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 398Common.ContractAssertMonitorStatus(IncomingLock, held: false); 450if (numberOfMessagesProcessedSinceTheLastKeepAlive > Common.KEEP_ALIVE_NUMBER_OF_MESSAGES_THRESHOLD) break; 463if (!Common.TryKeepAliveUntil(_keepAlivePredicate, this, out messageWithId)) 467_keepAliveBanCounter = Common.KEEP_ALIVE_BAN_COUNT; 484Common.StoreDataflowMessageValueIntoExceptionData(exc, messageWithId.Key); 524Common.ContractAssertMonitorStatus(IncomingLock, held: false); 577Common.ContractAssertMonitorStatus(IncomingLock, held: false); 618Common.ContractAssertMonitorStatus(IncomingLock, held: false); 622long messageId = Common.INVALID_REORDERING_ID; 660Debug.Assert(messageId != Common.INVALID_REORDERING_ID, "The assigned message ID is invalid."); 715Common.ContractAssertMonitorStatus(IncomingLock, held: true); 731Common.ContractAssertMonitorStatus(IncomingLock, held: true); 746this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 765Common.ReleaseAllPostponedMessages(_owningTarget, _boundingState.PostponedMessages, ref _exceptions); 812Common.ContractAssertMonitorStatus(IncomingLock, held: false);

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)}\"";