5 writes to m_currentBufferIndex
System.Core (5)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (5)
52
m_currentBufferIndex
= ENUMERATION_NOT_STARTED;
178
mutables.
m_currentBufferIndex
= ENUMERATION_NOT_STARTED;
182
mutables.
m_currentBufferIndex
++;
188
mutables.
m_currentBufferIndex
++;
275
mutables.
m_currentBufferIndex
= m_partitionIndex;
9 references to m_currentBufferIndex
System.Core (9)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (9)
133
if (mutables.
m_currentBufferIndex
== ENUMERATION_NOT_STARTED)
136
Contract.Assert(mutables.
m_currentBufferIndex
!= ENUMERATION_NOT_STARTED);
143
while (mutables.
m_currentBufferIndex
< m_partitionCount)
173
if (mutables.
m_currentBufferIndex
== m_partitionIndex)
185
if (mutables.
m_currentBufferIndex
== m_partitionIndex)
192
if (mutables.
m_currentBufferIndex
< m_partitionCount)
194
mutables.m_currentBuffer = m_valueExchangeMatrix[mutables.
m_currentBufferIndex
, m_partitionIndex];
195
mutables.m_currentKeyBuffer = m_keyExchangeMatrix[mutables.
m_currentBufferIndex
, m_partitionIndex];
287
if (m_mutables == null || (m_mutables.
m_currentBufferIndex
== ENUMERATION_NOT_STARTED))