1 write to _partitionCount
System.Linq.Parallel (1)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (1)
81
_partitionCount
= partitionCount;
9 references to _partitionCount
System.Linq.Parallel (9)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (9)
109
if (
_partitionCount
== 1)
140
while (mutables._currentBufferIndex <
_partitionCount
)
189
if (mutables._currentBufferIndex <
_partitionCount
)
210
ListChunk<Pair<TInputOutput, THashKey>>[] privateBuffers = new ListChunk<Pair<TInputOutput, THashKey>>[
_partitionCount
];
211
ListChunk<TOrderKey>[] privateKeyBuffers = new ListChunk<TOrderKey>[
_partitionCount
];
228
destinationIndex = _repartitionStream.GetHashCode(elementHashKey) %
_partitionCount
;
233
destinationIndex = _repartitionStream.GetHashCode(element) %
_partitionCount
;
236
Debug.Assert(0 <= destinationIndex && destinationIndex <
_partitionCount
,
262
for (int i = 0; i <
_partitionCount
; i++)