1 write to m_taskGroupState
System.Core (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
54
m_taskGroupState
= new QueryTaskGroupState(cancellationState, queryId);
6 references to m_taskGroupState
System.Core (6)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (6)
73
m_channelEnumerator = new AsynchronousChannelMergeEnumerator<TInputOutput>(
m_taskGroupState
, m_asyncChannels, consumerEvent);
79
m_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0],
m_taskGroupState
.CancellationState).GetEnumerator();
86
m_channelEnumerator = new SynchronousChannelMergeEnumerator<TInputOutput>(
m_taskGroupState
, m_syncChannels);
106
SpoolingTask.SpoolPipeline<TInputOutput, TIgnoreKey>(
m_taskGroupState
, m_partitions, m_asyncChannels, m_taskScheduler);
110
SpoolingTask.SpoolStopAndGo<TInputOutput, TIgnoreKey>(
m_taskGroupState
, m_partitions, m_syncChannels, m_taskScheduler);
114
SpoolingTask.SpoolForAll<TInputOutput, TIgnoreKey>(
m_taskGroupState
, m_partitions, m_taskScheduler);