MoveNext() [1/2]

override bool System.Linq.Parallel.PartitionedDataSource< T >.ContiguousChunkLazyEnumerator.MoveNext ( [AllowNull] ref T currentElement, ref int currentKey )

inlinepackage

Definition at line 321 of file PartitionedDataSource.cs.

        {
            Mutables mutables = _mutables;
            if (mutables == null)
            {
                mutables = (_mutables = new Mutables());
            }
            T[] chunkBuffer;
            int num;
            while (true)
            {
                chunkBuffer = mutables._chunkBuffer;
                num = ++mutables._currentChunkIndex;
                if (num < mutables._currentChunkSize)
                {
                    break;
                }
                lock (_sourceSyncLock)
                {
                    int i = 0;
                    if (_exceptionTracker.Value)
                    {
                        return false;
                    }
                    try
                    {
                        for (; i < mutables._nextChunkMaxSize; i++)
                        {
                            if (!_source.MoveNext())
                            {
                                break;
                            }
                            chunkBuffer[i] = _source.Current;
                        }
                    }
                    catch
                    {
                        _exceptionTracker.Value = true;
                        throw;
                    }
                    mutables._currentChunkSize = i;
                    if (i == 0)
                    {
                        return false;
                    }
                    mutables._chunkBaseIndex = _currentIndex.Value;
                    checked
                    {
                        _currentIndex.Value += i;
                    }
                }
                if (mutables._nextChunkMaxSize < chunkBuffer.Length && (mutables._chunkCounter++ & 7) == 7)
                {
                    mutables._nextChunkMaxSize *= 2;
                    if (mutables._nextChunkMaxSize > chunkBuffer.Length)
                    {
                        mutables._nextChunkMaxSize = chunkBuffer.Length;
                    }
                }
                mutables._currentChunkIndex = -1;
            }
            currentElement = chunkBuffer[num];
            currentKey = mutables._chunkBaseIndex + num;
            return true;
        }

References System.Linq.Parallel.PartitionedDataSource< T >.ContiguousChunkLazyEnumerator._currentIndex, System.Linq.Parallel.PartitionedDataSource< T >.ContiguousChunkLazyEnumerator._exceptionTracker, System.Linq.Parallel.PartitionedDataSource< T >.ContiguousChunkLazyEnumerator._mutables, System.Linq.Parallel.PartitionedDataSource< T >.ContiguousChunkLazyEnumerator._source, System.Linq.Parallel.PartitionedDataSource< T >.ContiguousChunkLazyEnumerator._sourceSyncLock, System.Collections.Generic.IEnumerator< out T >.Current, and System.Linq.Parallel.Shared< T >.Value.