51 references to FullyBuffered
System.Linq.Parallel (51)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
63
if (options != ParallelMergeOptions.
FullyBuffered
)
System\Linq\Parallel\Merging\MergeExecutor.cs (2)
55
Debug.Assert(!ignoreOutput || options == ParallelMergeOptions.
FullyBuffered
, "Pipelining with no output is not supported.");
60
if (options != ParallelMergeOptions.
FullyBuffered
&& !partitions.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing))
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
115
using (IEnumerator<TIntermediate> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
94
false, ParallelMergeOptions.
FullyBuffered
, settings.TaskScheduler, _leftChild.OutputOrdered,
105
false, ParallelMergeOptions.
FullyBuffered
, settings.TaskScheduler, _rightChild.OutputOrdered,
System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (1)
45
using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (1)
47
using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (1)
43
using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (1)
53
using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (1)
43
using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (1)
52
using (IEnumerator<float> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (1)
43
using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (1)
47
using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (1)
44
using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (1)
44
using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (1)
47
using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (1)
43
using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (1)
47
using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (1)
43
using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (1)
53
using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (1)
43
using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (1)
53
using (IEnumerator<float?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (1)
43
using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (1)
47
using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (1)
43
using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (1)
43
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (1)
47
using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (1)
43
using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
235
new PartitionedStreamMerger<TOutput>(false, ParallelMergeOptions.
FullyBuffered
, querySettings.TaskScheduler,
290
openedChild, false, ParallelMergeOptions.
FullyBuffered
, taskScheduler, outputOrdered,
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
72
using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
57
using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
147
using (IEnumerator<TSource> e = GetEnumerator(ParallelMergeOptions.
FullyBuffered
))
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
62
IEnumerator<TInput>? enumerator = GetOpenedEnumerator(ParallelMergeOptions.
FullyBuffered
, true, true,
System\Linq\ParallelEnumerable.cs (7)
389
&& mergeOptions != ParallelMergeOptions.
FullyBuffered
)
4879
input = asOperator.GetEnumerator(ParallelMergeOptions.
FullyBuffered
);
4968
IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true);
5066
IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true);
5153
IEnumerator<IGrouping<TKey, TSource>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
);
5240
IEnumerator<IGrouping<TKey, TElement>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
);
5336
using (IEnumerator<TSource> e = queryOp.GetEnumerator(ParallelMergeOptions.
FullyBuffered
))