44 references to ExchangeUtilities
System.Linq.Parallel (44)
System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (4)
57ExchangeUtilities.Worse(OrdinalIndexState.Increasing, 58ExchangeUtilities.Worse(LeftChild.OrdinalIndexState, RightChild.OrdinalIndexState))); 90Debug.Assert(!ExchangeUtilities.IsWorseThan(leftStream.OrdinalIndexState, OrdinalIndexState.Increasing)); 109Debug.Assert(!ExchangeUtilities.IsWorseThan(rightStream.OrdinalIndexState, OrdinalIndexState.Increasing));
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (3)
61ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 68ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 86ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (4)
81ExchangeUtilities.HashRepartitionOrdered(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 87ExchangeUtilities.HashRepartition(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 103PartitionedStream<Pair<TRightInput, TKey>, TRightKey> rePartitionedRightStream = ExchangeUtilities.HashRepartitionOrdered( 119PartitionedStream<Pair<TRightInput, TKey>, int> rePartitionedRightStream = ExchangeUtilities.HashRepartition(
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (3)
63ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 70ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 88ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (6)
82if (ExchangeUtilities.IsWorseThan(LeftChild.OrdinalIndexState, OrdinalIndexState.Increasing)) 88ExchangeUtilities.HashRepartitionOrdered(leftStreamInt, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 94ExchangeUtilities.HashRepartitionOrdered(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 101ExchangeUtilities.HashRepartition(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), 122ExchangeUtilities.HashRepartitionOrdered(rightPartitionedStream, _rightKeySelector, _keyComparer, null, cancellationToken), 130ExchangeUtilities.HashRepartition(rightPartitionedStream, _rightKeySelector, _keyComparer, null, cancellationToken),
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (4)
68ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 77ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>( 96ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TRightKey>( 105ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TRightKey>(
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
204PartitionedStream<TOutput, int> partitionedStream = ExchangeUtilities.PartitionDataSource(this, _partitionCount, _preferStriping);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
113PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 121PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, _settings.DegreeOfParallelism.Value, _preferStriping);
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
54return ExchangeUtilities.PartitionDataSource(_source, _partitionCount, _useStriping);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
133PartitionedStream<TElement, int> partitionedStream = ExchangeUtilities.PartitionDataSource(
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
42SetOrdinalIndexState(ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Correct));
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
60ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TKey>( 67ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TKey>(
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
45if (ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct))
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
76ExchangeUtilities.HashRepartitionOrdered<TSource, TGroupKey, TKey>( 85ExchangeUtilities.HashRepartition<TSource, TGroupKey, TKey>(
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (2)
64if (ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct)) 71Debug.Assert(!ExchangeUtilities.IsWorseThan(indexState, OrdinalIndexState.Correct));
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
61if (ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct))
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
86_prematureMerge = ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Correct); 96_prematureMerge = ExchangeUtilities.IsWorseThan(childIndexState, OrdinalIndexState.Increasing);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
97OrdinalIndexState indexState = ExchangeUtilities.Worse(childIndexState, OrdinalIndexState.Correct);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
45ExchangeUtilities.Worse(Child.OrdinalIndexState, OrdinalIndexState.Increasing));
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (2)
117PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 124PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, _settings.DegreeOfParallelism.Value, _preferStriping);