9 references to COMPLETE_ADDING_ON_MASK
System.Collections.Concurrent (9)
System\Collections\Concurrent\BlockingCollection.cs (9)
82
return (_currentAdders ==
COMPLETE_ADDING_ON_MASK
);
448
if ((observedAdders &
COMPLETE_ADDING_ON_MASK
) != 0)
452
while (_currentAdders !=
COMPLETE_ADDING_ON_MASK
) spinner.SpinOnce();
458
Debug.Assert((observedAdders + 1) <= (~
COMPLETE_ADDING_ON_MASK
), "The number of concurrent adders thread exceeded the maximum limit.");
492
Debug.Assert((_currentAdders & ~
COMPLETE_ADDING_ON_MASK
) > 0);
1448
if ((observedAdders &
COMPLETE_ADDING_ON_MASK
) != 0)
1452
while (_currentAdders !=
COMPLETE_ADDING_ON_MASK
) spinner.SpinOnce();
1456
if (Interlocked.CompareExchange(ref _currentAdders, observedAdders |
COMPLETE_ADDING_ON_MASK
, observedAdders) == observedAdders)
1459
while (_currentAdders !=
COMPLETE_ADDING_ON_MASK
) spinner.SpinOnce();