5 writes to _currentBufferIndex
System.Linq.Parallel (5)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (5)
49
_currentBufferIndex
= ENUMERATION_NOT_STARTED;
175
mutables.
_currentBufferIndex
= ENUMERATION_NOT_STARTED;
179
mutables.
_currentBufferIndex
++;
185
mutables.
_currentBufferIndex
++;
271
mutables.
_currentBufferIndex
= _partitionIndex;
9 references to _currentBufferIndex
System.Linq.Parallel (9)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (9)
130
if (mutables.
_currentBufferIndex
== ENUMERATION_NOT_STARTED)
133
Debug.Assert(mutables.
_currentBufferIndex
!= ENUMERATION_NOT_STARTED);
140
while (mutables.
_currentBufferIndex
< _partitionCount)
170
if (mutables.
_currentBufferIndex
== _partitionIndex)
182
if (mutables.
_currentBufferIndex
== _partitionIndex)
189
if (mutables.
_currentBufferIndex
< _partitionCount)
191
mutables._currentBuffer = _valueExchangeMatrix[mutables.
_currentBufferIndex
][_partitionIndex];
192
mutables._currentKeyBuffer = _keyExchangeMatrix[mutables.
_currentBufferIndex
][_partitionIndex];
283
if (_mutables == null || (_mutables.
_currentBufferIndex
== ENUMERATION_NOT_STARTED))