/**
* Unsets fifo event flag.
*
- * Also acts as a release barrier.
+ * Also acts as an acquire barrier.
*/
always_inline void
svm_fifo_unset_event (svm_fifo_t * f)
{
- clib_atomic_release (&f->has_event);
+ __atomic_exchange_n (&f->has_event, 0, __ATOMIC_ACQUIRE);
}
svm_fifo_t *svm_fifo_create (u32 data_size_in_bytes);
rv = svm_fifo_enqueue_nowait (f, sizeof (hdr), (u8 *) & hdr);
ASSERT (rv == sizeof (hdr));
- if ((rv = svm_fifo_enqueue_nowait (f, actual_write, data)) > 0)
+ rv = svm_fifo_enqueue_nowait (f, actual_write, data);
+ if (do_evt)
{
- if (do_evt && svm_fifo_set_event (f))
+ if (rv > 0 && svm_fifo_set_event (f))
app_send_io_evt_to_vpp (vpp_evt_q, f->master_session_index, evt_type,
noblock);
}
{
int rv;
- if ((rv = svm_fifo_enqueue_nowait (f, len, data)) > 0)
+ rv = svm_fifo_enqueue_nowait (f, len, data);
+ if (do_evt)
{
- if (do_evt && svm_fifo_set_event (f))
+ if (rv > 0 && svm_fifo_set_event (f))
app_send_io_evt_to_vpp (vpp_evt_q, f->master_session_index, evt_type,
noblock);
}