1 write to ExternalCancellationToken
System.Linq.Parallel (1)
System\Linq\Parallel\Scheduling\CancellationState.cs (1)
48
ExternalCancellationToken
= externalCancellationToken;
44 references to ExternalCancellationToken
System.Linq.Parallel (44)
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
112
IEnumerable<TOutput> opSequential = _op.AsSequentialQuery(_settings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (2)
72
&& cancelEx.CancellationToken == SpecifiedQuerySettings.CancellationState.
ExternalCancellationToken
73
&& SpecifiedQuerySettings.CancellationState.
ExternalCancellationToken
.IsCancellationRequested)
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (2)
125
_querySettings.CancellationState.
ExternalCancellationToken
);
158
CancellationState.ThrowWithStandardMessageIfCanceled(_querySettings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\QueryOperator.cs (5)
131
IEnumerable<TOutput> opSequential = AsSequentialQuery(querySettings.CancellationState.
ExternalCancellationToken
);
146
querySettings.CancellationState.
ExternalCancellationToken
.ThrowIfCancellationRequested();
203
IEnumerable<TOutput> opSequential = AsSequentialQuery(querySettings.CancellationState.
ExternalCancellationToken
);
204
IEnumerable<TOutput> opSequentialWithCancelChecks = CancellableEnumerable.Wrap(opSequential, querySettings.CancellationState.
ExternalCancellationToken
);
216
querySettings.CancellationState.
ExternalCancellationToken
.ThrowIfCancellationRequested();
System\Linq\Parallel\QueryOperators\QuerySettings.cs (7)
111
if (this.CancellationState.
ExternalCancellationToken
.CanBeCanceled && settings2.CancellationState.
ExternalCancellationToken
.CanBeCanceled)
128
CancellationToken externalCancellationToken = (this.CancellationState.
ExternalCancellationToken
.CanBeCanceled) ? this.CancellationState.
ExternalCancellationToken
: settings2.CancellationState.
ExternalCancellationToken
;
147
QuerySettings settings = new QuerySettings(TaskScheduler, DegreeOfParallelism, CancellationState.
ExternalCancellationToken
, ExecutionMode, MergeOptions);
154
CancellationTokenSource.CreateLinkedTokenSource(settings.CancellationState.InternalCancellationTokenSource.Token, settings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (4)
134
IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.
ExternalCancellationToken
);
135
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, cancelState.
ExternalCancellationToken
);
140
IEnumerable<TSource> childAsSequential = Child.AsSequentialQuery(cancelState.
ExternalCancellationToken
);
141
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, cancelState.
ExternalCancellationToken
);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
116
IEnumerable<TOutput> opSequential = _op.AsSequentialQuery(_settings.CancellationState.
ExternalCancellationToken
);
System\Linq\Parallel\Scheduling\QueryTaskGroupState.cs (2)
121
oce.CancellationToken != _cancellationState.
ExternalCancellationToken
)
153
CancellationState.ThrowWithStandardMessageIfCanceled(_cancellationState.
ExternalCancellationToken
); // Case #2
System\Linq\Parallel\Utils\ExceptionAggregator.cs (4)
103
cancellationState.
ExternalCancellationToken
);
148
if (cancelEx.CancellationToken == cancellationState.
ExternalCancellationToken
149
&& cancellationState.
ExternalCancellationToken
.IsCancellationRequested)
157
&& cancellationState.
ExternalCancellationToken
.IsCancellationRequested)
System\Linq\ParallelEnumerable.cs (16)
5411
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5412
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5453
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5454
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5494
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5495
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
);
5588
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5589
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5630
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5631
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5672
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5673
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);
5713
IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.
ExternalCancellationToken
);
5714
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.
ExternalCancellationToken
);