We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 19b524f commit af96d58Copy full SHA for af96d58
1 file changed
src/queue.c
@@ -426,11 +426,13 @@ int queue_push_right(queue_t *q, void *value)
426
retain_ref(next->refcnt, ATOMIC_READ(next->node));
427
queue_entry_t *prev = get_node_ptr(deref_link(next->refcnt, &next->prev));
428
if (!prev) {
429
+ release_ref(next->refcnt, ATOMIC_READ(next->node));
430
destroy_entry(entry);
431
return -1;
432
}
433
while (1) {
434
if (ATOMIC_READ(prev->next) != ATOMIC_READ(next->node)) {
435
+ release_ref(prev->refcnt, ATOMIC_READ(prev->node));
436
prev = help_insert(prev, next);
437
continue;
438
0 commit comments