427 |
|
// finish registration whenever parent registration |
428 |
|
// succeeded, even when racing with termination, |
429 |
|
// since these are part of the same "transaction". |
430 |
< |
while (!STATE.weakCompareAndSetVolatile |
430 |
> |
while (!STATE.weakCompareAndSet |
431 |
|
(this, s, |
432 |
|
((long)phase << PHASE_SHIFT) | adjust)) { |
433 |
|
s = state; |
459 |
|
// CAS to root phase with current parties, tripping unarrived |
460 |
|
while ((phase = (int)(root.state >>> PHASE_SHIFT)) != |
461 |
|
(int)(s >>> PHASE_SHIFT) && |
462 |
< |
!STATE.weakCompareAndSetVolatile |
462 |
> |
!STATE.weakCompareAndSet |
463 |
|
(this, s, |
464 |
|
s = (((long)phase << PHASE_SHIFT) | |
465 |
|
((phase < 0) ? (s & COUNTS_MASK) : |