48 references to _state
System.Threading.Tasks.Dataflow (48)
src\libraries\Common\src\System\Collections\Concurrent\SingleProducerSingleConsumerQueue.cs (48)
82
int last = segment.
_state
._last; // local copy to avoid multiple volatile reads
86
if (tail2 != segment.
_state
._firstCopy)
89
segment.
_state
._last = tail2;
104
if (segment.
_state
._firstCopy != segment.
_state
._first)
106
segment.
_state
._firstCopy = segment.
_state
._first;
116
newSegment.
_state
._last = 1;
117
newSegment.
_state
._lastCopy = 1;
136
int first = segment.
_state
._first; // local copy to avoid multiple volatile reads
139
if (first != segment.
_state
._lastCopy)
143
segment.
_state
._first = (first + 1) & (array.Length - 1);
158
int first = segment.
_state
._first; // local copy to avoid multiple volatile reads
161
if (first != segment.
_state
._lastCopy)
182
if (segment.
_state
._last != segment.
_state
._lastCopy)
184
segment.
_state
._lastCopy = segment.
_state
._last;
190
if (segment._next != null && segment.
_state
._first == segment.
_state
._last)
197
int first = segment.
_state
._first; // local copy to avoid extraneous volatile reads
199
if (first == segment.
_state
._last)
209
segment.
_state
._first = (first + 1) & (segment._array.Length - 1);
210
segment.
_state
._lastCopy = segment.
_state
._last; // Refresh _lastCopy to ensure that _first has not passed _lastCopy
224
int first = segment.
_state
._first; // local copy to avoid multiple volatile reads
227
if (first != segment.
_state
._lastCopy)
233
segment.
_state
._first = (first + 1) & (array.Length - 1);
256
if (segment.
_state
._last != segment.
_state
._lastCopy)
258
segment.
_state
._lastCopy = segment.
_state
._last;
262
if (segment._next != null && segment.
_state
._first == segment.
_state
._last)
269
int first = segment.
_state
._first; // local copy to avoid extraneous volatile reads
271
if (first == segment.
_state
._last)
281
segment.
_state
._first = (first + 1) & (segment._array.Length - 1);
282
segment.
_state
._lastCopy = segment.
_state
._last; // Refresh _lastCopy to ensure that _first has not passed _lastCopy
305
if (head.
_state
._first != head.
_state
._lastCopy)
310
if (head.
_state
._first != head.
_state
._last)
325
for (int pt = segment.
_state
._first;
326
pt != segment.
_state
._last;
350
first = segment.
_state
._first;
351
last = segment.
_state
._last;
352
if (first == segment.
_state
._first)