CancellationState

System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)

46TaskScheduler taskScheduler, CancellationState cancellationState, int queryId)

System\Linq\Parallel\Merging\MergeExecutor.cs (1)

51CancellationState cancellationState, int queryId)

System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)

39CancellationState cancellationState, int queryId)

System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)

117CancellationState cancellationState,

System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (1)

211if ((loopCount++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (1)

218if ((loopCount++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)

301if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (4)

188if ((i++ & CancellationState.POLL_INTERVAL) == 0) 202if ((_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 277if ((i++ & CancellationState.POLL_INTERVAL) == 0) 291if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (2)

122if ((mutables._outputLoopCount++ & CancellationState.POLL_INTERVAL) == 0) 253if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (4)

175if ((i++ & CancellationState.POLL_INTERVAL) == 0) 189if ((_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 276if ((i++ & CancellationState.POLL_INTERVAL) == 0) 300if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (4)

236if ((i++ & CancellationState.POLL_INTERVAL) == 0) 264if ((_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 350if ((i++ & CancellationState.POLL_INTERVAL) == 0) 367if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (1)

111if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (1)

120if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (2)

139if ((i++ & CancellationState.POLL_INTERVAL) == 0) 153if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (1)

105if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (1)

121if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (2)

146if ((i++ & CancellationState.POLL_INTERVAL) == 0) 160if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (1)

105if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (1)

121if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (2)

144if ((i++ & CancellationState.POLL_INTERVAL) == 0) 157if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (1)

106if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (1)

120if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (2)

139if ((i++ & CancellationState.POLL_INTERVAL) == 0) 153if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (1)

109if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (1)

120if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (1)

109if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (2)

140if ((i++ & CancellationState.POLL_INTERVAL) == 0) 154if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (1)

108if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (1)

116if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (2)

138if ((i++ & CancellationState.POLL_INTERVAL) == 0) 152if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (1)

105if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (1)

118if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (2)

146if ((i++ & CancellationState.POLL_INTERVAL) == 0) 161if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (1)

105if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (1)

117if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (2)

146if ((i++ & CancellationState.POLL_INTERVAL) == 0) 161if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (1)

105if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (1)

117if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (2)

138if ((i++ & CancellationState.POLL_INTERVAL) == 0) 152if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (1)

108if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (1)

118if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (2)

139if ((i++ & CancellationState.POLL_INTERVAL) == 0) 153if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (1)

109if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (2)

27private readonly CancellationState _cancellationState; 45CancellationState cancellationState, int queryId)

System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (3)

122if ((_moveNextIteration & CancellationState.POLL_INTERVAL) == 0) 124CancellationState.ThrowWithStandardMessageIfCanceled( 158CancellationState.ThrowWithStandardMessageIfCanceled(_querySettings.CancellationState.ExternalCancellationToken);

System\Linq\Parallel\QueryOperators\QuerySettings.cs (2)

29private CancellationState _cancellationState; 34internal CancellationState CancellationState

System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)

206if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)

183if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)

157if ((_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 237if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (2)

131CancellationState cancelState = SpecifiedQuerySettings.CancellationState; 203if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)

180if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)

163if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (4)

330if ((i++ & CancellationState.POLL_INTERVAL) == 0) 392if ((i++ & CancellationState.POLL_INTERVAL) == 0) 559if ((i++ & CancellationState.POLL_INTERVAL) == 0) 634if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)

174if ((_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)

177if ((loopCount & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)

140if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)

283if ((_mutables._lhsCount++ & CancellationState.POLL_INTERVAL) == 0) 412if ((_mutables._lhsCount++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)

210if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)

273if ((i++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)

139if ((_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\Scheduling\QueryTaskGroupState.cs (4)

26private readonly CancellationState _cancellationState; // The cancellation state. 34internal QueryTaskGroupState(CancellationState cancellationState, int queryId) 53internal CancellationState CancellationState 153CancellationState.ThrowWithStandardMessageIfCanceled(_cancellationState.ExternalCancellationToken); // Case #2

System\Linq\Parallel\Utils\CancellableEnumerable.cs (1)

31if ((count++ & CancellationState.POLL_INTERVAL) == 0)

System\Linq\Parallel\Utils\ExceptionAggregator.cs (6)

28internal static IEnumerable<TElement> WrapEnumerable<TElement>(IEnumerable<TElement> source, CancellationState cancellationState) 59CancellationState cancellationState) 98internal static void ThrowOCEorAggregateException(Exception ex, CancellationState cancellationState) 102CancellationState.ThrowWithStandardMessageIfCanceled( 120internal static Func<T, U> WrapFunc<T, U>(Func<T, U> f, CancellationState cancellationState) 139private static bool ThrowAnOCE(Exception ex, CancellationState cancellationState)

System\Linq\Parallel\Utils\Sorting.cs (4)

239if ((i++ & CancellationState.POLL_INTERVAL) == 0) 438if ((i & CancellationState.POLL_INTERVAL) == 0) 515if ((i & CancellationState.POLL_INTERVAL) == 0) 593if (right - left > CancellationState.POLL_INTERVAL)

System\Linq\ParallelEnumerable.cs (1)

4423private static void DisposeEnumerator<TSource>(IEnumerator<TSource> e, CancellationState cancelState)