88 references to PartitionCount
System.Core (88)
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)
24: base(inputStream.PartitionCount, inputStream.KeyComparer, hashKeyComparer, elementComparer) 27new OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey>[inputStream.PartitionCount]; 31CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); 33new ListChunk<Pair<TInputOutput, THashKey>>[inputStream.PartitionCount, inputStream.PartitionCount]; 34ListChunk<TOrderKey>[,] keyExchangeMatrix = new ListChunk<TOrderKey>[inputStream.PartitionCount, inputStream.PartitionCount]; 37for (int i = 0; i < inputStream.PartitionCount; i++) 40inputStream[i], inputStream.PartitionCount, i, hashKeySelector, this, barrier,
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;