1 write to m_partitionIndex
System.Core (1)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)
83m_partitionIndex = partitionIndex;
8 references to m_partitionIndex
System.Core (8)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (8)
126m_buffers[m_partitionIndex].Enqueue(chunk[i]); 129if (m_consumerWaiting[m_partitionIndex]) 132m_consumerWaiting[m_partitionIndex] = false; 138if (m_buffers[m_partitionIndex].Count >= OrderPreservingPipeliningMergeHelper<TOutput, TKey>.MAX_BUFFER_SIZE) 140m_producerWaiting[m_partitionIndex] = true; 206m_producerDone[m_partitionIndex] = true; 207if (m_consumerWaiting[m_partitionIndex]) 210m_consumerWaiting[m_partitionIndex] = false;