1 write to _settings
System.Linq.Parallel (1)
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
99_settings = settings;
8 references to _settings
System.Linq.Parallel (8)
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (8)
106Debug.Assert(_settings.ExecutionMode != null); 108if (_settings.ExecutionMode.Value == ParallelExecutionMode.Default && _op.LimitsParallelism) 110Debug.Assert(_settings.DegreeOfParallelism != null); 112IEnumerable<TOutput> opSequential = _op.AsSequentialQuery(_settings.CancellationState.ExternalCancellationToken); 114opSequential, _settings.DegreeOfParallelism.Value, _preferStriping); 119Debug.Assert(_settings.DegreeOfParallelism != null); 121PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, _settings.DegreeOfParallelism.Value, _preferStriping); 127_leftChildQueryResults.GivePartitionedStream(new LeftChildResultsRecipient(recipient, this, _preferStriping, _settings));