1 write to m_partitionCount
System.Core (1)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (1)
84
m_partitionCount
= partitionCount;
9 references to m_partitionCount
System.Core (9)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (9)
112
if (
m_partitionCount
== 1)
143
while (mutables.m_currentBufferIndex <
m_partitionCount
)
192
if (mutables.m_currentBufferIndex <
m_partitionCount
)
213
ListChunk<Pair<TInputOutput, THashKey>>[] privateBuffers = new ListChunk<Pair<TInputOutput, THashKey>>[
m_partitionCount
];
214
ListChunk<TOrderKey>[] privateKeyBuffers = new ListChunk<TOrderKey>[
m_partitionCount
];
231
destinationIndex = m_repartitionStream.GetHashCode(elementHashKey) %
m_partitionCount
;
236
destinationIndex = m_repartitionStream.GetHashCode(element) %
m_partitionCount
;
239
Contract.Assert(0 <= destinationIndex && destinationIndex <
m_partitionCount
,
266
for (int i = 0; i <
m_partitionCount
; i++)