UCS/ASYNC: fix code according to CI

openucx · Jul 2, 2024 · ec7637b · ec7637b
1 parent 80f89f0
commit ec7637b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/ucs/datastruct/mpmc.c b/src/ucs/datastruct/mpmc.c
@@ -87,6 +87,7 @@ void ucs_mpmc_queue_remove_if(ucs_mpmc_queue_t *mpmc,
     ucs_queue_for_each_safe(elem, iter, &mpmc->queue, super) {
         if (predicate(elem->value, arg)) {
             ucs_queue_del_iter(&mpmc->queue, iter);
+            ucs_free(elem);
         }
     }
     ucs_spin_unlock(&mpmc->lock);