40 references to ExchangeUtilities
System.Core (40)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (3)
65ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 72ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 90ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (3)
86ExchangeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 92ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 106PartitionedStream<Pair<TRightInput, TKey>, int> rightHashStream = ExchangeUtilities.HashRepartition(
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (3)
67ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 74ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 92ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (3)
88ExchangeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 94ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken), 109PartitionedStream<Pair<TRightInput, TKey>, int> rightHashStream = ExchangeUtilities.HashRepartition(
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (4)
72ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 81ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 100ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TRightKey>( 109ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
205PartitionedStream<TOutput, int> partitionedStream = ExchangeUtilities.PartitionDataSource(this, m_partitionCount, m_preferStriping);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
115PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 122PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, m_settings.DegreeOfParallelism.Value, m_preferStriping);
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
58return ExchangeUtilities.PartitionDataSource(m_source, m_partitionCount, m_useStriping);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
139PartitionedStream<TElement, int> partitionedStream = ExchangeUtilities.PartitionDataSource(
System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (4)
61ExchangeUtilities.Worse(OrdinalIndexState.Increasing, 62ExchangeUtilities.Worse(LeftChild.OrdinalIndexState, RightChild.OrdinalIndexState))); 94Contract.Assert(!ExchangeUtilities.IsWorseThan(leftStream.OrdinalIndexState, OrdinalIndexState.Increasing)); 113Contract.Assert(!ExchangeUtilities.IsWorseThan(rightStream.OrdinalIndexState, OrdinalIndexState.Increasing));
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
46SetOrdinalIndexState(ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Correct));
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
64ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TKey>( 71ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TKey>(
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
49if (ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct))
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
80ExchangeUtilities.HashRepartitionOrdered<TSource, TGroupKey, TKey>( 89ExchangeUtilities.HashRepartition<TSource, TGroupKey, TKey>(
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (2)
68if (ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct)) 75Contract.Assert(!ExchangeUtilities.IsWorseThan(indexState, OrdinalIndexState.Correct));
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
65if (ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct))
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
90m_prematureMerge = ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct); 100m_prematureMerge = ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Increasing);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
101OrdinalIndexState indexState = ExchangeUtilities.Worse(childIndexState, OrdinalIndexState.Correct);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
49ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Increasing));
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (2)
121PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 128PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, m_settings.DegreeOfParallelism.Value, m_preferStriping);