buf_ring: Ensure correct ordering of loads
When enqueueing on an architecture with a weak memory model ensure loading br->br_prod_head and br->br_cons_tail are ordered correctly. If br_cons_tail is loaded first then other threads may perform a dequeue and enqueue before br_prod_head is loaded. This will mean the tail is one less than it should be and the code under the prod_next == cons_tail check could incorrectly be skipped. buf_ring_dequeue_mc has the same issue with br->br_prod_tail and br->br_cons_head so needs the same fix. Reported by: Ali Saidi <alisaidi@amazon.com> Co-developed by: Ali Saidi <alisaidi@amazon.com> Reviewed by: imp, kib, markj Sponsored by: Arm Ltd Differential Revision: https://reviews.freebsd.org/D46155
This commit is contained in:
+17
-2
@@ -89,7 +89,17 @@ buf_ring_enqueue(struct buf_ring *br, void *buf)
|
||||
#endif
|
||||
critical_enter();
|
||||
do {
|
||||
prod_head = br->br_prod_head;
|
||||
/*
|
||||
* br->br_prod_head needs to be read before br->br_cons_tail.
|
||||
* If not then we could perform the dequeue and enqueue
|
||||
* between reading br_cons_tail and reading br_prod_head. This
|
||||
* could give us values where br_cons_head == br_prod_tail
|
||||
* (after masking).
|
||||
*
|
||||
* To work around this us a load acquire. This is just to
|
||||
* ensure ordering within this thread.
|
||||
*/
|
||||
prod_head = atomic_load_acq_32(&br->br_prod_head);
|
||||
prod_next = prod_head + 1;
|
||||
cons_tail = atomic_load_acq_32(&br->br_cons_tail);
|
||||
|
||||
@@ -137,7 +147,12 @@ buf_ring_dequeue_mc(struct buf_ring *br)
|
||||
critical_enter();
|
||||
mask = br->br_cons_mask;
|
||||
do {
|
||||
cons_head = br->br_cons_head;
|
||||
/*
|
||||
* As with buf_ring_enqueue ensure we read the head before
|
||||
* the tail. If we read them in the wrong order we may
|
||||
* think the bug_ring is full when it is empty.
|
||||
*/
|
||||
cons_head = atomic_load_acq_32(&br->br_cons_head);
|
||||
cons_next = cons_head + 1;
|
||||
prod_tail = atomic_load_acq_32(&br->br_prod_tail);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user