85 references to ParallelMergeOptions
netstandard (1)
netstandard.cs (1)
1041[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Linq.ParallelMergeOptions))]
System.Core (1)
System.Core.cs (1)
179[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Linq.ParallelMergeOptions))]
System.Linq.Parallel (83)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (2)
45internal DefaultMergeHelper(PartitionedStream<TInputOutput, TIgnoreKey> partitions, bool ignoreOutput, ParallelMergeOptions options, 63if (options != ParallelMergeOptions.FullyBuffered)
System\Linq\Parallel\Merging\MergeExecutor.cs (10)
50PartitionedStream<TInputOutput, TKey> partitions, bool ignoreOutput, ParallelMergeOptions options, TaskScheduler taskScheduler, bool isOrdered, 55Debug.Assert(!ignoreOutput || options == ParallelMergeOptions.FullyBuffered, "Pipelining with no output is not supported."); 60if (options != ParallelMergeOptions.FullyBuffered && !partitions.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing)) 62Debug.Assert(options == ParallelMergeOptions.NotBuffered || options == ParallelMergeOptions.AutoBuffered); 63bool autoBuffered = (options == ParallelMergeOptions.AutoBuffered); 147internal static AsynchronousChannel<TInputOutput>[] MakeAsynchronousChannels(int partitionCount, ParallelMergeOptions options, IntValueEvent? consumerEvent, CancellationToken cancellationToken) 151Debug.Assert(options == ParallelMergeOptions.NotBuffered || options == ParallelMergeOptions.AutoBuffered); 161if (options == ParallelMergeOptions.NotBuffered)
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
115using (IEnumerator<TIntermediate> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
94false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, _leftChild.OutputOrdered, 105false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, _rightChild.OutputOrdered,
System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (1)
45using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (1)
47using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (1)
43using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (1)
53using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (1)
43using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (1)
52using (IEnumerator<float> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (1)
43using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (1)
47using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (1)
44using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (1)
44using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (1)
47using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (1)
43using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (1)
47using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (1)
43using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (1)
53using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (1)
43using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (1)
53using (IEnumerator<float?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (1)
43using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (1)
47using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (1)
43using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (1)
43using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (1)
47using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (1)
43using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Options\OrderingQueryOperator.cs (1)
37internal override IEnumerator<TSource> GetEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (2)
21private readonly ParallelMergeOptions _mergeOptions; 44internal PartitionedStreamMerger(bool forEffectMerge, ParallelMergeOptions mergeOptions, TaskScheduler taskScheduler, bool outputOrdered,
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (2)
28private readonly ParallelMergeOptions? _mergeOptions; 48internal QueryOpeningEnumerator(QueryOperator<TOutput> queryOperator, ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\QueryOperator.cs (5)
95public IEnumerator<TOutput> GetEnumerator(ParallelMergeOptions? mergeOptions) 111internal virtual IEnumerator<TOutput> GetEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation) 124internal IEnumerator<TOutput>? GetOpenedEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrder, bool forEffect, 235new PartitionedStreamMerger<TOutput>(false, ParallelMergeOptions.FullyBuffered, querySettings.TaskScheduler, 290openedChild, false, ParallelMergeOptions.FullyBuffered, taskScheduler, outputOrdered,
System\Linq\Parallel\QueryOperators\QuerySettings.cs (8)
31private ParallelMergeOptions? _mergeOptions; 65internal ParallelMergeOptions? MergeOptions 84ParallelMergeOptions? mergeOptions) 130ParallelMergeOptions? mergeOptions = this.MergeOptions.HasValue ? this.MergeOptions : settings2.MergeOptions; 179settings.MergeOptions ??= ParallelMergeOptions.Default; 180if (settings.MergeOptions == ParallelMergeOptions.Default) 182settings.MergeOptions = ParallelMergeOptions.AutoBuffered; 191Debug.Assert(settings.MergeOptions != ParallelMergeOptions.Default);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
77internal override IEnumerator<TElement> GetEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
72using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
57using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
147using (IEnumerator<TSource> e = GetEnumerator(ParallelMergeOptions.FullyBuffered))
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
62IEnumerator<TInput>? enumerator = GetOpenedEnumerator(ParallelMergeOptions.FullyBuffered, true, true,
System\Linq\ParallelEnumerable.cs (13)
372/// <seealso cref="ParallelMergeOptions"/> registered.</returns> 377/// <paramref name="mergeOptions"/> is not a valid <see cref="System.Linq.ParallelMergeOptions"/> value. 382public static ParallelQuery<TSource> WithMergeOptions<TSource>(this ParallelQuery<TSource> source, ParallelMergeOptions mergeOptions) 386if (mergeOptions != ParallelMergeOptions.Default 387&& mergeOptions != ParallelMergeOptions.AutoBuffered 388&& mergeOptions != ParallelMergeOptions.NotBuffered 389&& mergeOptions != ParallelMergeOptions.FullyBuffered) 4879input = asOperator.GetEnumerator(ParallelMergeOptions.FullyBuffered); 4968IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered, true); 5066IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered, true); 5153IEnumerator<IGrouping<TKey, TSource>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered); 5240IEnumerator<IGrouping<TKey, TElement>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered); 5336using (IEnumerator<TSource> e = queryOp.GetEnumerator(ParallelMergeOptions.FullyBuffered))