spsc-queue: Reload cached_tail/head when opening queue

Reload cached_tail/head when opening queues. This fixes reconnecting to active queues. Signed-off-by: Edgar E. Iglesias <edgar.iglesias@amd.com>
zeroasiccorp · Jul 2, 2024 · 70247e6 · 70247e6
1 parent 1e816d8
commit 70247e6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/switchboard/cpp/spsc_queue.h b/switchboard/cpp/spsc_queue.h
@@ -136,6 +136,10 @@ static inline spsc_queue* spsc_open_mem(const char* name, size_t capacity, void*
  q->shm = (spsc_queue_shared*)p;
  q->name = strdup(name);
  q->capacity = capacity;
+
+ /* In case we're opening a pre-existing queue, pick up where we left off. */
+ __atomic_load(&q->shm->tail, &q->cached_tail, __ATOMIC_RELAXED);
+ __atomic_load(&q->shm->head, &q->cached_head, __ATOMIC_RELAXED);
  return q;
 
 err: