CompleteBlock()

void System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.CompleteBlock ( IList< Exception > exceptions )

inlineprivate

Definition at line 156 of file WriteOnceBlock.cs.

    {
        TargetRegistry<T>.LinkedTargetInfo firstTarget = _targetRegistry.ClearEntryPoints();
        if (exceptions != null && exceptions.Count > 0)
        {
            CompletionTaskSource.TrySetException(exceptions);
        }
        else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested)
        {
            CompletionTaskSource.TrySetCanceled();
        }
        else if (Interlocked.CompareExchange(ref _lazyCompletionTaskSource, Common.CompletedVoidResultTaskCompletionSource, null) != null)
        {
            _lazyCompletionTaskSource.TrySetResult(default(VoidResult));
        }
        _targetRegistry.PropagateCompletion(firstTarget);
        DataflowEtwProvider log = DataflowEtwProvider.Log;
        if (log.IsEnabled())
        {
            log.DataflowBlockCompleted(this);
        }
    }

References System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._dataflowBlockOptions, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._lazyCompletionTaskSource, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >._targetRegistry, System.Threading.Tasks.Dataflow.DataflowBlockOptions.CancellationToken, System.Threading.Interlocked.CompareExchange(), System.Threading.Tasks.Dataflow.Internal.Common.CompletedVoidResultTaskCompletionSource, System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.CompletionTaskSource, System.exceptions, System.Threading.CancellationToken.IsCancellationRequested, and System.Threading.Tasks.Dataflow.Internal.DataflowEtwProvider.Log.

Referenced by System.Threading.Tasks.Dataflow.WriteOnceBlock< T >.OfferToTargetsAndCompleteBlock().