51 references to FullyBuffered
System.Core (51)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
67
if (options != ParallelMergeOptions.
FullyBuffered
)
System\Linq\Parallel\Merging\MergeExecutor.cs (2)
60
Contract.Assert(!ignoreOutput || options == ParallelMergeOptions.
FullyBuffered
, "@BUGBUG: pipelining w/ no output not supported -- need it?");
65
if (options != ParallelMergeOptions.
FullyBuffered
&& !partitions.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing))
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
122
using (IEnumerator<TIntermediate> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
97
false, ParallelMergeOptions.
FullyBuffered
, settings.TaskScheduler, m_leftChild.OutputOrdered,
107
false, ParallelMergeOptions.
FullyBuffered
, settings.TaskScheduler, m_rightChild.OutputOrdered,
System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (1)
49
using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (1)
50
using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (1)
54
using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (1)
51
using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (1)
49
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (1)
59
using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (1)
50
using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (1)
49
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (1)
58
using (IEnumerator<float> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (1)
51
using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (1)
50
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (1)
54
using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (1)
52
using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (1)
50
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (1)
52
using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (1)
54
using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (1)
51
using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (1)
47
using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (1)
51
using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (1)
48
using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (1)
47
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (1)
57
using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (1)
48
using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (1)
47
using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (1)
57
using (IEnumerator<float?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (1)
48
using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (1)
47
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (1)
51
using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (1)
48
using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (1)
47
using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (1)
51
using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (1)
48
using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
231
new PartitionedStreamMerger<TOutput>(false, ParallelMergeOptions.
FullyBuffered
, querySettings.TaskScheduler,
285
openedChild, false, ParallelMergeOptions.
FullyBuffered
, taskScheduler, outputOrdered,
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
76
using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
69
using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true))
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
150
using (IEnumerator<TSource> e = GetEnumerator(ParallelMergeOptions.
FullyBuffered
))
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
66
IEnumerator<TInput> enumerator = GetOpenedEnumerator(ParallelMergeOptions.
FullyBuffered
, true, true,
System\Linq\ParallelEnumerable.cs (7)
446
&& mergeOptions != ParallelMergeOptions.
FullyBuffered
)
4918
input = asOperator.GetEnumerator(ParallelMergeOptions.
FullyBuffered
);
5007
IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true);
5110
IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
, true);
5202
IEnumerator<IGrouping<TKey, TSource>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
);
5289
IEnumerator<IGrouping<TKey, TElement>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.
FullyBuffered
);
5383
using (IEnumerator<TSource> e = queryOp.GetEnumerator(ParallelMergeOptions.
FullyBuffered
))