1 write to ExternalCancellationToken
System.Core (1)
System\Linq\Parallel\Scheduling\CancellationState.cs (1)
55
ExternalCancellationToken
= externalCancellationToken;
44 references to ExternalCancellationToken
System.Core (44)
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
114
IEnumerable<TOutput> opSequential = m_op.AsSequentialQuery(m_settings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (2)
82
&& cancelEx.CancellationToken == SpecifiedQuerySettings.CancellationState.
ExternalCancellationToken
83
&& SpecifiedQuerySettings.CancellationState.
ExternalCancellationToken
.IsCancellationRequested)
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (2)
132
m_querySettings.CancellationState.
ExternalCancellationToken
);
165
CancellationState.ThrowWithStandardMessageIfCanceled(m_querySettings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\QueryOperator.cs (5)
135
IEnumerable<TOutput> opSequential = AsSequentialQuery(querySettings.CancellationState.
ExternalCancellationToken
);
154
if (querySettings.CancellationState.
ExternalCancellationToken
.IsCancellationRequested)
155
throw new OperationCanceledException(querySettings.CancellationState.
ExternalCancellationToken
);
210
IEnumerable<TOutput> opSequential = AsSequentialQuery(querySettings.CancellationState.
ExternalCancellationToken
);
211
IEnumerable<TOutput> opSequentialWithCancelChecks = CancellableEnumerable.Wrap(opSequential, querySettings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\QuerySettings.cs (7)
118
if (this.CancellationState.
ExternalCancellationToken
.CanBeCanceled && settings2.CancellationState.
ExternalCancellationToken
.CanBeCanceled)
135
CancellationToken externalCancellationToken = (this.CancellationState.
ExternalCancellationToken
.CanBeCanceled) ? this.CancellationState.
ExternalCancellationToken
: settings2.CancellationState.
ExternalCancellationToken
;
154
QuerySettings settings = new QuerySettings(TaskScheduler, DegreeOfParallelism, CancellationState.
ExternalCancellationToken
, ExecutionMode, MergeOptions);
161
CancellationTokenSource.CreateLinkedTokenSource(settings.CancellationState.InternalCancellationTokenSource.Token, settings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (4)
137
IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.
ExternalCancellationToken
);
138
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, cancelState.
ExternalCancellationToken
);
143
IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.
ExternalCancellationToken
);
144
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, cancelState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
120
IEnumerable<TOutput> opSequential = m_op.AsSequentialQuery(m_settings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\Scheduling\QueryTaskGroupState.cs (2)
128
oce.CancellationToken != m_cancellationState.
ExternalCancellationToken
)
159
CancellationState.ThrowWithStandardMessageIfCanceled(m_cancellationState.
ExternalCancellationToken
); // Case #2
System\Linq\Parallel\Utils\ExceptionAggregator.cs (4)
119
cancellationState.
ExternalCancellationToken
);
169
cancelEx.CancellationToken == cancellationState.
ExternalCancellationToken
170
&& cancellationState.
ExternalCancellationToken
.IsCancellationRequested)
179
&& cancellationState.
ExternalCancellationToken
.IsCancellationRequested)
System\Linq\ParallelEnumerable.cs (16)
5455
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5456
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5497
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5498
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5539
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5540
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5584
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5585
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5633
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5634
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5675
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5676
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5717
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5718
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5758
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5759
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);