8 instantiations of ListChunk
System.Core (8)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (1)
241
privateBuffers[destinationIndex] = buffer = new
ListChunk
<Pair<TInputOutput, THashKey>>(INITIAL_PRIVATE_BUFFER_SIZE);
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (2)
253
privateBuffers[destinationIndex] = buffer = new
ListChunk
<Pair<TInputOutput, THashKey>>(INITIAL_PRIVATE_BUFFER_SIZE);
254
privateKeyBuffers[destinationIndex] = keyBuffer = new
ListChunk
<TOrderKey>(INITIAL_PRIVATE_BUFFER_SIZE);
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (2)
143
currentValue.Second = new
ListChunk
<TRightInput>(INITIAL_CHUNK_SIZE);
155
currentValue.Second = new
ListChunk
<TRightInput>(INITIAL_CHUNK_SIZE);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
350
currentValue = new
ListChunk
<TSource>(INITIAL_CHUNK_SIZE);
414
currentValue = new
ListChunk
<TElement>(INITIAL_CHUNK_SIZE);
System\Linq\Parallel\Utils\ListChunk.cs (1)
50
m_tailChunk = new
ListChunk
<TInputOutput>(tail.m_chunkCount * 2);
50 references to ListChunk
System.Core (50)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (6)
36
private readonly
ListChunk
<Pair<TInputOutput, THashKey>>[,] m_valueExchangeMatrix; // Matrix to do inter-task communication.
45
internal
ListChunk
<Pair<TInputOutput, THashKey>> m_currentBuffer; // The buffer we're currently enumerating.
70
CountdownEvent barrier,
ListChunk
<Pair<TInputOutput, THashKey>>[,] valueExchangeMatrix, CancellationToken cancellationToken)
204
ListChunk
<Pair<TInputOutput, THashKey>>[] privateBuffers = new
ListChunk
<Pair<TInputOutput, THashKey>>[m_partitionCount];
237
ListChunk
<Pair<TInputOutput, THashKey>> buffer = privateBuffers[destinationIndex];
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (12)
36
private readonly
ListChunk
<Pair<TInputOutput, THashKey>>[,] m_valueExchangeMatrix; // Matrix to do inter-task communication of values.
37
private readonly
ListChunk
<TOrderKey>[,] m_keyExchangeMatrix; // Matrix to do inter-task communication of order keys.
46
internal
ListChunk
<Pair<TInputOutput, THashKey>> m_currentBuffer; // The buffer we're currently enumerating.
47
internal
ListChunk
<TOrderKey> m_currentKeyBuffer; // The buffer we're currently enumerating.
72
ListChunk
<Pair<TInputOutput, THashKey>>[,] valueExchangeMatrix,
ListChunk
<TOrderKey>[,] keyExchangeMatrix, CancellationToken cancellationToken)
213
ListChunk
<Pair<TInputOutput, THashKey>>[] privateBuffers = new
ListChunk
<Pair<TInputOutput, THashKey>>[m_partitionCount];
214
ListChunk
<TOrderKey>[] privateKeyBuffers = new
ListChunk
<TOrderKey>[m_partitionCount];
247
ListChunk
<Pair<TInputOutput, THashKey>> buffer = privateBuffers[destinationIndex];
248
ListChunk
<TOrderKey> keyBuffer = privateKeyBuffers[destinationIndex];
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (4)
32
ListChunk
<Pair<TInputOutput, THashKey>>[,] valueExchangeMatrix =
33
new
ListChunk
<Pair<TInputOutput, THashKey>>[inputStream.PartitionCount, inputStream.PartitionCount];
34
ListChunk
<TOrderKey>[,] keyExchangeMatrix = new
ListChunk
<TOrderKey>[inputStream.PartitionCount, inputStream.PartitionCount];
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (2)
38
ListChunk
<Pair<TInputOutput, THashKey>>[,] valueExchangeMatrix =
39
new
ListChunk
<Pair<TInputOutput, THashKey>>[inputStream.PartitionCount, inputStream.PartitionCount];
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (9)
54
internal HashLookup<THashKey, Pair<TRightInput,
ListChunk
<TRightInput>>> m_rightHashLookup; // The hash lookup.
55
internal
ListChunk
<TRightInput> m_currentRightMatches; // Current right matches (if any).
111
mutables.m_rightHashLookup = new HashLookup<THashKey, Pair<TRightInput,
ListChunk
<TRightInput>>>(m_keyComparer);
134
Pair<TRightInput,
ListChunk
<TRightInput>> currentValue = default(Pair<TRightInput,
ListChunk
<TRightInput>>);
137
currentValue = new Pair<TRightInput,
ListChunk
<TRightInput>>(rightElement, null);
174
ListChunk
<TRightInput> currentRightChunk = mutables.m_currentRightMatches;
192
Pair<TRightInput,
ListChunk
<TRightInput>> matchValue = default(Pair<TRightInput,
ListChunk
<TRightInput>>);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (12)
238
internal HashLookup<Wrapper<TGroupKey>,
ListChunk
<TElement>> m_hashLookup; // The lookup with key-value mappings.
296
protected abstract HashLookup<Wrapper<TGroupKey>,
ListChunk
<TElement>> BuildHashLookup();
328
protected override HashLookup<Wrapper<TGroupKey>,
ListChunk
<TSource>> BuildHashLookup()
330
HashLookup<Wrapper<TGroupKey>,
ListChunk
<TSource>> hashlookup =
331
new HashLookup<Wrapper<TGroupKey>,
ListChunk
<TSource>>(new WrapperEqualityComparer<TGroupKey>(m_keyComparer));
346
ListChunk
<TSource> currentValue = null;
392
protected override HashLookup<Wrapper<TGroupKey>,
ListChunk
<TElement>> BuildHashLookup()
394
HashLookup<Wrapper<TGroupKey>,
ListChunk
<TElement>> hashlookup =
395
new HashLookup<Wrapper<TGroupKey>,
ListChunk
<TElement>>(new WrapperEqualityComparer<TGroupKey>(m_keyComparer));
410
ListChunk
<TElement> currentValue = null;
695
private KeyValuePair<Wrapper<TGroupKey>,
ListChunk
<TElement>> m_keyValues; // A key value pair.
701
internal GroupByGrouping(KeyValuePair<Wrapper<TGroupKey>,
ListChunk
<TElement>> keyValues)
System\Linq\Parallel\Utils\ListChunk.cs (5)
27
private
ListChunk
<TInputOutput> m_nextChunk;
28
private
ListChunk
<TInputOutput> m_tailChunk;
47
ListChunk
<TInputOutput> tail = m_tailChunk;
60
internal
ListChunk
<TInputOutput> Next
78
ListChunk
<TInputOutput> curr = this;