1 write to m_buffers
System.Core (1)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
132
m_buffers
= new Queue<Pair<TKey, TOutput>>[partitionCount];
5 references to m_buffers
System.Core (5)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (5)
156
m_buffers
, m_bufferLocks, m_taskScheduler, m_autoBuffered);
389
Queue<Pair<TKey, TOutput>> buffer = m_mergeHelper.
m_buffers
[producer];
434
m_privateBuffer[producer] = m_mergeHelper.
m_buffers
[producer];
437
m_mergeHelper.
m_buffers
[producer] = new Queue<Pair<TKey, TOutput>>(INITIAL_BUFFER_SIZE);
475
int partitionCount = m_mergeHelper.
m_buffers
.Length;