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