1 instantiation of OrderPreservingPipeliningMergeHelper
System.Core (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
73
mergeExecutor.m_mergeHelper = new
OrderPreservingPipeliningMergeHelper
<TInputOutput, TKey>(
4 references to OrderPreservingPipeliningMergeHelper
System.Core (4)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (2)
212
private
OrderPreservingPipeliningMergeHelper
<TOutput, TKey> m_mergeHelper;
248
internal OrderedPipeliningMergeEnumerator(
OrderPreservingPipeliningMergeHelper
<TOutput, TKey> mergeHelper, IComparer<Producer<TKey>> producerComparer)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (2)
138
if (m_buffers[m_partitionIndex].Count >=
OrderPreservingPipeliningMergeHelper
<TOutput, TKey>.MAX_BUFFER_SIZE)
168
buffers[i] = new Queue<Pair<TKey, TOutput>>(
OrderPreservingPipeliningMergeHelper
<TOutput, TKey>.INITIAL_BUFFER_SIZE);