9 references to COMPLETE_ADDING_ON_MASK
System (9)
sys\system\collections\concurrent\BlockingCollection.cs (9)
93
return (m_currentAdders ==
COMPLETE_ADDING_ON_MASK
);
469
if ((observedAdders &
COMPLETE_ADDING_ON_MASK
) != 0)
473
while (m_currentAdders !=
COMPLETE_ADDING_ON_MASK
) spinner.SpinOnce();
478
Debug.Assert((observedAdders + 1) <= (~
COMPLETE_ADDING_ON_MASK
), "The number of concurrent adders thread excceeded the maximum limit.");
530
Debug.Assert((m_currentAdders & ~
COMPLETE_ADDING_ON_MASK
) > 0);
1501
if ((observedAdders &
COMPLETE_ADDING_ON_MASK
) != 0)
1505
while (m_currentAdders !=
COMPLETE_ADDING_ON_MASK
) spinner.SpinOnce();
1509
if (Interlocked.CompareExchange(ref m_currentAdders, observedAdders |
COMPLETE_ADDING_ON_MASK
, observedAdders) == observedAdders)
1512
while (m_currentAdders !=
COMPLETE_ADDING_ON_MASK
) spinner.SpinOnce();