1 write to m_partitionCount
System.Core (1)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (1)
82
m_partitionCount
= partitionCount;
8 references to m_partitionCount
System.Core (8)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (8)
109
if (
m_partitionCount
== 1)
142
while (mutables.m_currentBufferIndex <
m_partitionCount
)
184
if (mutables.m_currentBufferIndex <
m_partitionCount
)
204
ListChunk<Pair<TInputOutput, THashKey>>[] privateBuffers = new ListChunk<Pair<TInputOutput, THashKey>>[
m_partitionCount
];
221
destinationIndex = m_repartitionStream.GetHashCode(elementHashKey) %
m_partitionCount
;
226
destinationIndex = m_repartitionStream.GetHashCode(element) %
m_partitionCount
;
229
Contract.Assert(0 <= destinationIndex && destinationIndex <
m_partitionCount
,
251
for (int i = 0; i <
m_partitionCount
; i++)