Changes in uspace/lib/c/generic/thread/mpsc.c [09ab0a9a:45c8eea] in mainline

File:

• uspace/lib/c/generic/thread/mpsc.c (modified) (2 diffs)

uspace/lib/c/generic/thread/mpsc.c

@@ -80 +80 @@
         }
 
+        if (fibril_rmutex_initialize(&q->t_lock) != EOK) {
+                free(q);
+                free(n);
+                free(c);
+                return NULL;
+        }
+
         q->elem_size = elem_size;
-        fibril_rmutex_initialize(&q->t_lock);
         q->head = q->tail = n;
         q->close_node = c;
@@ -97 +103 @@
         }
 
-        // TODO: fibril_rmutex_destroy()
+        fibril_rmutex_destroy(&q->t_lock);
 
         free(q);