1 write to m_syncChannels
System.Core (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
84
m_syncChannels
=
11 references to m_syncChannels
System.Core (11)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (11)
86
m_channelEnumerator = new SynchronousChannelMergeEnumerator<TInputOutput>(m_taskGroupState,
m_syncChannels
);
90
Contract.Assert(
m_syncChannels
== null ||
m_syncChannels
.Length == partitions.PartitionCount);
108
else if (
m_syncChannels
!= null)
110
SpoolingTask.SpoolStopAndGo<TInputOutput, TIgnoreKey>(m_taskGroupState, m_partitions,
m_syncChannels
, m_taskScheduler);
145
if (
m_syncChannels
!= null)
149
for (int i = 0; i <
m_syncChannels
.Length; i++)
151
totalSize +=
m_syncChannels
[i].Count;
157
for (int i = 0; i <
m_syncChannels
.Length; i++)
159
m_syncChannels
[i].CopyTo(array, current);
160
current +=
m_syncChannels
[i].Count;