PartitionCount

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

69if (partitions.PartitionCount > 1) 72MergeExecutor<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerEvent, cancellationState.MergedCancellationToken); 85MergeExecutor<TInputOutput>.MakeSynchronousChannels(partitions.PartitionCount); 89Contract.Assert(m_asyncChannels == null || m_asyncChannels.Length == partitions.PartitionCount); 90Contract.Assert(m_syncChannels == null || m_syncChannels.Length == partitions.PartitionCount); 120Contract.Assert(m_partitions.PartitionCount == 1);

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

59Contract.Assert(partitions.PartitionCount > 0); 70if (partitions.PartitionCount > 1)

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

131int partitionCount = m_partitions.PartitionCount; 251int partitionCount = mergeHelper.m_partitions.PartitionCount; 285for (int producer = 0; producer < m_mergeHelper.m_partitions.PartitionCount; producer++)

System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (9)

System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (7)

30: base(inputStream.PartitionCount, Util.GetDefaultComparer<int>(), keyComparer, elementComparer) 33m_partitions = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>[inputStream.PartitionCount]; 37CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); 39new ListChunk<Pair<TInputOutput, THashKey>>[inputStream.PartitionCount, inputStream.PartitionCount]; 42for (int i = 0; i < inputStream.PartitionCount; i++) 45inputStream[i], inputStream.PartitionCount, i, keySelector, this,

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

202int partitionCount = inputStream.PartitionCount;

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

60Contract.Assert(leftStream.PartitionCount == rightStream.PartitionCount); 87int partitionCount = leftHashStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (3)

80Contract.Assert(rightStream.PartitionCount == leftStream.PartitionCount); 81int partitionCount = leftStream.PartitionCount;

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

62Contract.Assert(leftPartitionedStream.PartitionCount == rightPartitionedStream.PartitionCount); 89int partitionCount = leftHashStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (3)

83Contract.Assert(rightStream.PartitionCount == leftStream.PartitionCount); 108int partitionCount = leftHashStream.PartitionCount;

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

64Contract.Assert(leftStream.PartitionCount == rightStream.PartitionCount); 65int partitionCount = leftStream.PartitionCount;

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

133int partitionCount = inputStream.PartitionCount;

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

112int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (3)

88ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings); 107ExecuteAndCollectResults(rightStream, leftStreamInc.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings); 122int partitionCount = leftStreamInc.PartitionCount;

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

99int partitionCount = inputStream.PartitionCount;

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

64int partitionCount = inputStream.PartitionCount;

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

86int partitionCount = hashStream.PartitionCount;

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

73int partitionCount = inputStream.PartitionCount;

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

66ListQueryResults<TSource> listResults = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 78int partitionCount = inputStream.PartitionCount;

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

90int partitionCount = inputStream.PartitionCount;

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

107int partitionCount = hashStream.PartitionCount; 146int partitionCount = hashStream.PartitionCount;

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

95int partitionCount = inputStream.PartitionCount;

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

90int partitionCount = inputStream.PartitionCount;

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

67ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream(); 78int partitionCount = inputStream.PartitionCount;

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

63int partitionCount = inputStream.PartitionCount;

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

110int partitionCount = inputStream.PartitionCount; 154int partitionCount = inputStream.PartitionCount; 174var outputStream = new PartitionedStream<TOutput, Pair<int, int>>(inputStream.PartitionCount, keyComparer, OrdinalIndexState); 176for (int i = 0; i < inputStream.PartitionCount; i++)

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

57new PartitionedStream<TOutput, TKey>(inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState); 58for (int i = 0; i < inputStream.PartitionCount; i++)

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

62int partitionCount = inputStream.PartitionCount;

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

116new PartitionedStream<TInputOutput, TSortKey>(inputStream.PartitionCount, this.m_comparer, OrdinalIndexState); 118for (int i = 0; i < outputStream.PartitionCount; i++)

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

99inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 111int partitionCount = inputStream.PartitionCount;

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

122ListQueryResults<TResult> results = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 136int partitionCount = inputStream.PartitionCount;

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

58inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState); 59for (int i = 0; i < inputStream.PartitionCount; i++)

System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (3)

159Contract.Requires(producerDone != null && producerDone.Length == partitions.PartitionCount); 160Contract.Requires(buffers != null && buffers.Length == partitions.PartitionCount); 163int degreeOfParallelism = partitions.PartitionCount;

System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)

84int maxToRunInParallel = partitions.PartitionCount - 1;

System\Linq\Parallel\Scheduling\SpoolingTask.cs (5)

41Contract.Requires(partitions.PartitionCount == channels.Length); 48int maxToRunInParallel = partitions.PartitionCount - 1; 94Contract.Requires(partitions.PartitionCount == channels.Length); 105for (int i = 0; i < partitions.PartitionCount; i++) 145int maxToRunInParallel = partitions.PartitionCount - 1;

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

79Contract.Assert(returnValue.PartitionCount == partitionCount);

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

108int degreeOfParallelism = partitions.PartitionCount;