2 instantiations of CancellationState
System.Core (2)
System\Linq\Parallel\QueryOperators\QuerySettings.cs (1)
95m_cancellationState = new CancellationState(externalCancellationToken);
System\Linq\ParallelEnumerable.cs (1)
385settings.CancellationState = new CancellationState(cancellationToken);
189 references to CancellationState
System.Core (189)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
50TaskScheduler taskScheduler, CancellationState cancellationState, int queryId)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
56CancellationState cancellationState, int queryId)
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
43CancellationState cancellationState, int queryId)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
117CancellationState cancellationState,
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (2)
211if ((loopCount++ & CancellationState.POLL_INTERVAL) == 0) 212CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (2)
221if ((loopCount++ & CancellationState.POLL_INTERVAL) == 0) 222CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (2)
317if ((i++ & CancellationState.POLL_INTERVAL) == 0) 318CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (8)
192if ((i++ & CancellationState.POLL_INTERVAL) == 0) 193CancellationState.ThrowIfCanceled(m_cancellationToken); 205if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 206CancellationState.ThrowIfCanceled(m_cancellationToken); 278if ((i++ & CancellationState.POLL_INTERVAL) == 0) 279CancellationState.ThrowIfCanceled(m_cancellationToken); 292if ((i++ & CancellationState.POLL_INTERVAL) == 0) 293CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (4)
118if ((i++ & CancellationState.POLL_INTERVAL) == 0) 119CancellationState.ThrowIfCanceled(m_cancellationToken); 188if ((mutables.m_outputLoopCount++ & CancellationState.POLL_INTERVAL) == 0) 189CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (8)
180if ((i++ & CancellationState.POLL_INTERVAL) == 0) 181CancellationState.ThrowIfCanceled(m_cancellationToken); 193if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 194CancellationState.ThrowIfCanceled(m_cancellationToken); 282if ((i++ & CancellationState.POLL_INTERVAL) == 0) 283CancellationState.ThrowIfCanceled(m_cancellationToken); 306if ((i++ & CancellationState.POLL_INTERVAL) == 0) 307CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (8)
243if ((i++ & CancellationState.POLL_INTERVAL) == 0) 244CancellationState.ThrowIfCanceled(m_cancellationToken); 270if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 271CancellationState.ThrowIfCanceled(m_cancellationToken); 365if ((i++ & CancellationState.POLL_INTERVAL) == 0) 366CancellationState.ThrowIfCanceled(m_cancellationToken); 382if ((i++ & CancellationState.POLL_INTERVAL) == 0) 383CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (2)
115if ((i++ & CancellationState.POLL_INTERVAL) == 0) 116CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (2)
127if ((i++ & CancellationState.POLL_INTERVAL) == 0) 128CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (4)
146if ((i++ & CancellationState.POLL_INTERVAL) == 0) 147CancellationState.ThrowIfCanceled(m_cancellationToken); 160if ((i++ & CancellationState.POLL_INTERVAL) == 0) 161CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (2)
113if ((i++ & CancellationState.POLL_INTERVAL) == 0) 114CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (2)
127if ((i++ & CancellationState.POLL_INTERVAL) == 0) 128CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (4)
152if ((i++ & CancellationState.POLL_INTERVAL) == 0) 153CancellationState.ThrowIfCanceled(m_cancellationToken); 166if ((i++ & CancellationState.POLL_INTERVAL) == 0) 167CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (2)
115if ((i++ & CancellationState.POLL_INTERVAL) == 0) 116CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (2)
127if ((i++ & CancellationState.POLL_INTERVAL) == 0) 128CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (4)
150if ((i++ & CancellationState.POLL_INTERVAL) == 0) 151CancellationState.ThrowIfCanceled(m_cancellationToken); 163if ((i++ & CancellationState.POLL_INTERVAL) == 0) 164CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (2)
117if ((i++ & CancellationState.POLL_INTERVAL) == 0) 118CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (2)
127if ((i++ & CancellationState.POLL_INTERVAL) == 0) 128CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (4)
146if ((i++ & CancellationState.POLL_INTERVAL) == 0) 147CancellationState.ThrowIfCanceled(m_cancellationToken); 160if ((i++ & CancellationState.POLL_INTERVAL) == 0) 161CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (2)
117if ((i++ & CancellationState.POLL_INTERVAL) == 0) 118CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (2)
127if ((i++ & CancellationState.POLL_INTERVAL) == 0) 128CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (2)
117if ((i++ & CancellationState.POLL_INTERVAL) == 0) 118CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (4)
147if ((i++ & CancellationState.POLL_INTERVAL) == 0) 148CancellationState.ThrowIfCanceled(m_cancellationToken); 161if ((i++ & CancellationState.POLL_INTERVAL) == 0) 162CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (2)
116if ((i++ & CancellationState.POLL_INTERVAL) == 0) 117CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (2)
120if ((i++ & CancellationState.POLL_INTERVAL) == 0) 121CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (4)
142if ((i++ & CancellationState.POLL_INTERVAL) == 0) 143CancellationState.ThrowIfCanceled(m_cancellationToken); 156if ((i++ & CancellationState.POLL_INTERVAL) == 0) 157CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (2)
110if ((i++ & CancellationState.POLL_INTERVAL) == 0) 111CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (2)
122if ((i++ & CancellationState.POLL_INTERVAL) == 0) 123CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (4)
150if ((i++ & CancellationState.POLL_INTERVAL) == 0) 151CancellationState.ThrowIfCanceled(m_cancellationToken); 165if ((i++ & CancellationState.POLL_INTERVAL) == 0) 166CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (2)
110if ((i++ & CancellationState.POLL_INTERVAL) == 0) 111CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (2)
121if ((i++ & CancellationState.POLL_INTERVAL) == 0) 122CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (4)
150if ((i++ & CancellationState.POLL_INTERVAL) == 0) 151CancellationState.ThrowIfCanceled(m_cancellationToken); 165if ((i++ & CancellationState.POLL_INTERVAL) == 0) 166CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (2)
110if ((i++ & CancellationState.POLL_INTERVAL) == 0) 111CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (2)
121if ((i++ & CancellationState.POLL_INTERVAL) == 0) 122CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (4)
142if ((i++ & CancellationState.POLL_INTERVAL) == 0) 143CancellationState.ThrowIfCanceled(m_cancellationToken); 156if ((i++ & CancellationState.POLL_INTERVAL) == 0) 157CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (2)
113if ((i++ & CancellationState.POLL_INTERVAL) == 0) 114CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (2)
122if ((i++ & CancellationState.POLL_INTERVAL) == 0) 123CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (4)
143if ((i++ & CancellationState.POLL_INTERVAL) == 0) 144CancellationState.ThrowIfCanceled(m_cancellationToken); 157if ((i++ & CancellationState.POLL_INTERVAL) == 0) 158CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (2)
114if ((i++ & CancellationState.POLL_INTERVAL) == 0) 115CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (2)
31private CancellationState m_cancellationState; 49CancellationState cancellationState, int queryId)
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (3)
129if ((m_moveNextIteration & CancellationState.POLL_INTERVAL) == 0) 131CancellationState.ThrowWithStandardMessageIfCanceled( 165CancellationState.ThrowWithStandardMessageIfCanceled(m_querySettings.CancellationState.ExternalCancellationToken);
System\Linq\Parallel\QueryOperators\QuerySettings.cs (2)
36private CancellationState m_cancellationState; 41internal CancellationState CancellationState
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (2)
209if ((i++ & CancellationState.POLL_INTERVAL) == 0) 210CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (2)
195if ((i++ & CancellationState.POLL_INTERVAL) == 0) 196CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (4)
163if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 164CancellationState.ThrowIfCanceled(m_cancellationToken); 242if ((i++ & CancellationState.POLL_INTERVAL) == 0) 243CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (3)
134CancellationState cancelState = SpecifiedQuerySettings.CancellationState; 206if ((i++ & CancellationState.POLL_INTERVAL) == 0) 207CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (2)
182if ((i++ & CancellationState.POLL_INTERVAL) == 0) 183CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (2)
166if ((i++ & CancellationState.POLL_INTERVAL) == 0) 167CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (8)
338if ((i++ & CancellationState.POLL_INTERVAL) == 0) 339CancellationState.ThrowIfCanceled(m_cancellationToken); 402if ((i++ & CancellationState.POLL_INTERVAL) == 0) 403CancellationState.ThrowIfCanceled(m_cancellationToken); 571if ((i++ & CancellationState.POLL_INTERVAL) == 0) 572CancellationState.ThrowIfCanceled(m_cancellationToken); 647if ((i++ & CancellationState.POLL_INTERVAL) == 0) 648CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (2)
180if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 181CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (2)
179if ((loopCount & CancellationState.POLL_INTERVAL) == 0) 180CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
146if ((i++ & CancellationState.POLL_INTERVAL) == 0) 147CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (4)
287if ((m_mutables.m_lhsCount++ & CancellationState.POLL_INTERVAL) == 0) 288CancellationState.ThrowIfCanceled(m_cancellationToken); 417if ((m_mutables.m_lhsCount++ & CancellationState.POLL_INTERVAL) == 0) 418CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (2)
213if ((i++ & CancellationState.POLL_INTERVAL) == 0) 214CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (2)
277if ((i++ & CancellationState.POLL_INTERVAL) == 0) 278CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (2)
145if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0) 146CancellationState.ThrowIfCanceled(m_cancellationToken);
System\Linq\Parallel\Scheduling\QueryTaskGroupState.cs (4)
33private CancellationState m_cancellationState; // The cancellation state. 41internal QueryTaskGroupState(CancellationState cancellationState, int queryId) 60internal CancellationState CancellationState 159CancellationState.ThrowWithStandardMessageIfCanceled(m_cancellationState.ExternalCancellationToken); // Case #2
System\Linq\Parallel\Utils\CancellableEnumerable.cs (2)
35if ((count++ & CancellationState.POLL_INTERVAL) == 0) 36CancellationState.ThrowIfCanceled(token);
System\Linq\Parallel\Utils\ExceptionAggregator.cs (6)
33internal static IEnumerable<TElement> WrapEnumerable<TElement>(IEnumerable<TElement> source, CancellationState cancellationState) 70CancellationState cancellationState) 114internal static void ThrowOCEorAggregateException(Exception ex, CancellationState cancellationState) 118CancellationState.ThrowWithStandardMessageIfCanceled( 136internal static Func<T, U> WrapFunc<T, U>(Func<T, U> f, CancellationState cancellationState) 160private static bool ThrowAnOCE(Exception ex, CancellationState cancellationState)
System\Linq\Parallel\Utils\Sorting.cs (8)
247if ((i++ & CancellationState.POLL_INTERVAL) == 0) 248CancellationState.ThrowIfCanceled(cancelToken); 442if ((i & CancellationState.POLL_INTERVAL) == 0) 443CancellationState.ThrowIfCanceled(cancelToken); 515if ((i & CancellationState.POLL_INTERVAL) == 0) 516CancellationState.ThrowIfCanceled(cancelToken); 590if (right - left > CancellationState.POLL_INTERVAL) 591CancellationState.ThrowIfCanceled(cancelToken);
System\Linq\ParallelEnumerable.cs (1)
4454private static void DisposeEnumerator<TSource>(IEnumerator<TSource> e, CancellationState cancelState)