On Thu, Jan 23, 2020 at 11:22:51AM +0000, Will Deacon wrote:
> > Argh, make that:
> >
> > tail_2nd->next = NULL;
> >
> > smp_wmb();
> >
> > > if (!atomic_try_cmpxchg_relaxed(&lock, &val, new)) {
>
> ... or could you drop the smp_wmb() and make this
> atomic_try_cmpxchg_release()?
My current code has the smp_wmb(), because most _releases end up being
an smp_mb() (except for powerpc where it is of equal cost to wmb and
arm64, where I have no idea of the costs).
> To be honest, I've failed to understand the code prior to your changes
> in this area: it appears to reply on a control-dependency from the two
> cmpxchg_relaxed() calls (which isn't sufficient to order the store parts
> afaict) and I also don't get how we deal with a transiently circular primary
> queue.
Ha!, yes, so this little piece took me a while too. Let me attempt an
explanation.
+ * cna_node
+ * +----------+ +--------+ +--------+
+ * |mcs:next | --> |mcs:next| --> ... |mcs:next| --> NULL [Primary queue]
+ * |mcs:locked| -. +--------+ +--------+
+ * +----------+ |
+ * `----------------------.
+ * v
+ * +--------+ +--------+
+ * |mcs:next| --> ... |mcs:next| [Secondary queue]
+ * +--------+ +--------+
+ * ^ |
+ * `--------------------'
So @node is the current lock holder, node->next == NULL (primary queue
is empty) and we're going to try and splice the secondary queue to the
head of the primary.
+ tail_2nd = decode_tail(node->locked);
+ head_2nd = tail_2nd->next;
this gets the secondary head and tail, so far so simple
+ new = ((struct cna_node *)tail_2nd)->encoded_tail + _Q_LOCKED_VAL;
this encodes the new primary tail (as kept in lock->val), still simple
+ if (atomic_try_cmpxchg_relaxed(&lock->val, &val, new)) {
if this here succeeds, we've got the primary tail pointing at the
secondary tail. This is safe because only the lock holder (us) ever
modifies the secondary queue.
+ /*
+ * Try to reset @next in tail_2nd to NULL, but no need to check
+ * the result - if failed, a new successor has updated it.
+ */
+ cmpxchg_relaxed(&tail_2nd->next, head_2nd, NULL);
This is (broken, as per the prior argument) breaking the circular link
the secondary queue has. The trick here is that since we're the lock
holder, nothing will actually iterate the primary ->next chain, so a
bogus value in there is of no concern.
_However_ a new waiter might at this point do:
old = xchg_tail(lock, node);
if (old) {
prev = decode_tail(old);
WRITE_ONCE(prev->next, node);
...
}
which then results in conflicting stores to the one ->next variable.
The cmpxchg() is attempting to terminate the list, while the new waiter
is extending the list, it is therefore paramount the new waiter always
wins this. To that end they're employing the cmpxchg, but it very much
relies on the @head_2nd load to have happened before we exposed the
secondary tail as primary tail, otherwise it can have loaded the new
->next pointer and overwriten it.
+ arch_mcs_pass_lock(&head_2nd->locked, 1);
+ return true;
+ }
+
+ return false;
Did that help, or just make it worse?
