1 write to m_mergeHelper
System.Core (1)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
253m_mergeHelper = mergeHelper;
15 references to m_mergeHelper
System.Core (15)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (15)
285for (int producer = 0; producer < m_mergeHelper.m_partitions.PartitionCount; producer++) 353if (m_mergeHelper.m_taskGroupState.CancellationState.MergedCancellationToken.IsCancellationRequested) 359object[] locks = m_mergeHelper.m_bufferLocks; 389Queue<Pair<TKey, TOutput>> buffer = m_mergeHelper.m_buffers[producer]; 390object bufferLock = m_mergeHelper.m_bufferLocks[producer]; 397if (m_mergeHelper.m_producerDone[producer]) 403m_mergeHelper.m_consumerWaiting[producer] = true; 409Contract.Assert(m_mergeHelper.m_producerDone[producer]); 419if (m_mergeHelper.m_producerWaiting[producer]) 422m_mergeHelper.m_producerWaiting[producer] = false; 434m_privateBuffer[producer] = m_mergeHelper.m_buffers[producer]; 437m_mergeHelper.m_buffers[producer] = new Queue<Pair<TKey, TOutput>>(INITIAL_BUFFER_SIZE); 475int partitionCount = m_mergeHelper.m_buffers.Length; 478object bufferLock = m_mergeHelper.m_bufferLocks[producer]; 481if (m_mergeHelper.m_producerWaiting[producer])