MoveNextSlowPath()

bool System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator.MoveNextSlowPath ( )

inlineprivate

Definition at line 68 of file PartitionedDataSource.cs.

        {
            Mutables mutables = _mutables;
            int num = ++mutables._currentSection;
            int num2 = _sectionCount - num;
            if (num2 <= 0)
            {
                return false;
            }
            int num3 = num * _partitionCount * _maxChunkSize;
            mutables._currentPositionInChunk = 0;
            if (num2 > 1)
            {
                mutables._currentChunkSize = _maxChunkSize;
                mutables._currentChunkOffset = num3 + _partitionIndex * _maxChunkSize;
            }
            else
            {
                int num4 = _elementCount - num3;
                int num5 = num4 / _partitionCount;
                int num6 = num4 % _partitionCount;
                mutables._currentChunkSize = num5;
                if (_partitionIndex < num6)
                {
                    mutables._currentChunkSize++;
                }
                if (mutables._currentChunkSize == 0)
                {
                    return false;
                }
                mutables._currentChunkOffset = num3 + _partitionIndex * num5 + ((_partitionIndex < num6) ? _partitionIndex : num6);
            }
            return true;
        }

References System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator._elementCount, System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator._maxChunkSize, System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator._mutables, System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator._partitionCount, System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator._partitionIndex, and System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator._sectionCount.

Referenced by System.Linq.Parallel.PartitionedDataSource< T >.ArrayIndexRangeEnumerator.MoveNext().