30 writes to Value
System.Core (30)
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (1)
112m_currentCount.Value = nextCount;
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (1)
114++m_currentIndex.Value;
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (5)
383int current = ++m_currentIndex.Value; 561int current = ++m_currentIndex.Value; 686m_exceptionTracker.Value = true; 703m_currentIndex.Value += i; 728if (Interlocked.Decrement(ref m_activeEnumeratorsCount.Value) == 0)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (1)
205if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (1)
193if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (1)
270if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (1)
79m_topLevelDisposedFlag.Value = true;
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
222m_resultFoundFlag.Value = true;
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
208m_resultFoundFlag.Value = true;
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
186Interlocked.Increment(ref m_sharedEmptyCount.Value);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)
163if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
218m_resultFoundFlag.Value = true;
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
180if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
150m_bufferIndex.Value++; 155if (--m_bufferIndex.Value >= 0)
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (2)
161Interlocked.Increment(ref m_totalElementCount.Value); 180if (Volatile.Read(ref m_totalElementCount.Value) > 1)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (3)
252++m_bufferIndex.Value; 280for (m_bufferIndex.Value++; m_bufferIndex.Value < m_buffer.Count; m_bufferIndex.Value++)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (3)
355++m_bufferIndex.Value; 374for (m_bufferIndex.Value++; m_bufferIndex.Value < m_buffer.Count; m_bufferIndex.Value++)
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
145if ((m_outputLoopCount.Value++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)
148m_results.Value = sortedOutput;
System\Linq\Parallel\Utils\Shared.cs (1)
27this.Value = value;
38 references to Value
System.Core (38)
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (1)
109int nextCount = m_currentCount.Value + 1;
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (2)
112if (m_currentIndex.Value < (m_count - 1)) 116currentKey = m_currentIndex.Value + m_indexOffset;
System\Linq\Parallel\Merging\MergeEnumerator.cs (1)
72Contract.Assert(m_taskGroupState.CancellationState.TopLevelDisposedFlag.Value);
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (3)
73Contract.Assert(m_results.Value != null); 74return ((IEnumerable<TInputOutput>)m_results.Value).GetEnumerator(); 84return m_results.Value;
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (2)
671if (m_exceptionTracker.Value) 700mutables.m_chunkBaseIndex = m_currentIndex.Value;
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (1)
97if (m_topLevelDisposedFlag.Value)
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (2)
192if (m_resultFoundFlag.Value) 212if (m_resultFoundFlag.Value)
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (2)
179if (m_resultFoundFlag.Value) 198if (m_resultFoundFlag.Value)
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
170if (m_sharedEmptyCount.Value == m_partitionCount - 1)
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
209if (m_resultFoundFlag.Value)
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
157currentElement = m_buffer[m_bufferIndex.Value].First; 158currentKey = m_buffer[m_bufferIndex.Value].Second;
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (9)
246if (m_count == 0 || m_bufferIndex.Value >= m_buffer.Count - 1) 253currentElement = m_buffer[m_bufferIndex.Value].First; 254currentKey = m_buffer[m_bufferIndex.Value].Second; 258|| m_keyComparer.Compare(m_buffer[m_bufferIndex.Value].Second, m_sharedIndices.MaxValue) <= 0; 278if (m_bufferIndex.Value < m_buffer.Count - 1) 280for (m_bufferIndex.Value++; m_bufferIndex.Value < m_buffer.Count; m_bufferIndex.Value++) 284if (m_keyComparer.Compare(m_buffer[m_bufferIndex.Value].Second, minKey) > 0) 286currentElement = m_buffer[m_bufferIndex.Value].First; 287currentKey = m_buffer[m_bufferIndex.Value].Second;
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (8)
349if (m_bufferIndex.Value >= m_buffer.Count - 1) 356currentElement = m_buffer[m_bufferIndex.Value].First; 357currentKey = m_buffer[m_bufferIndex.Value].Second; 372if (m_bufferIndex.Value < m_buffer.Count - 1) 374for (m_bufferIndex.Value++; m_bufferIndex.Value < m_buffer.Count; m_bufferIndex.Value++) 378if (m_keyComparer.Compare(m_buffer[m_bufferIndex.Value].Second, m_operatorState.m_currentLowKey) >= 0) 380currentElement = m_buffer[m_bufferIndex.Value].First; 381currentKey = m_buffer[m_bufferIndex.Value].Second;
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)
81Contract.Requires(results.Value == null);
System\Linq\Parallel\Scheduling\QueryTaskGroupState.cs (2)
157if (!m_cancellationState.TopLevelDisposedFlag.Value) 164Contract.Assert(m_cancellationState.TopLevelDisposedFlag.Value);