lib: Handle errors when creating cdap_req structs

1 files changed, 13 insertions, 2 deletions

diff --git a/src/lib/cdap_req.c b/src/lib/cdap_req.c
index bb11dbf6..a89d6b2a 100644
--- a/src/lib/cdap_req.c
+++ b/src/lib/cdap_req.c
@@ -48,12 +48,23 @@ struct cdap_req * cdap_req_create(int         fd,
         creq->data.data = NULL;
         creq->data.len  = 0;
 
+        if (pthread_mutex_init(&creq->lock, NULL)) {
+                free(creq);
+                return NULL;
+        }
+
         pthread_condattr_init(&cattr);
 #ifndef __APPLE__
         pthread_condattr_setclock(&cattr, PTHREAD_COND_CLOCK);
 #endif
-        pthread_cond_init(&creq->cond, &cattr);
-        pthread_mutex_init(&creq->lock, NULL);
+        if (pthread_cond_init(&creq->cond, &cattr)) {
+                pthread_condattr_destroy(&cattr);
+                pthread_mutex_destroy(&creq->lock);
+                free(creq);
+                return NULL;
+        }
+
+        pthread_condattr_destroy(&cattr);
 
         list_head_init(&creq->next);