cond

1 files changed, 5 insertions, 4 deletions

diff --git a/libclapi/cl_command_queue.c b/libclapi/cl_command_queue.c
index fc625a1c..ae02cd1f 100644
--- a/libclapi/cl_command_queue.c
+++ b/libclapi/cl_command_queue.c
@@ -21,6 +21,7 @@
 #include <string.h>
 #include "cl_command_queue.h"
 #include "cl_alloc.h"
+#include "cl_mutex.h"
 #include "cl_internals.h"
 #include "cl_driver.h"
 #include "cl_context.h"
@@ -47,12 +48,12 @@ static cl_command_queue cl_command_queue_new(cl_context ctx, cl_device_id device
   cl_retain_device_id(device);
 
   /* Append the command queue in the list */
-  pthread_mutex_lock(&ctx->lock);
+  CL_MUTEX_LOCK(&ctx->lock);
   queue->next = ctx->queues;
   if (ctx->queues != NULL)
     ctx->queues->prev = queue;
   ctx->queues = queue;
-  pthread_mutex_unlock(&ctx->lock);
+  CL_MUTEX_UNLOCK(&ctx->lock);
 
   return queue;
 }
@@ -63,14 +64,14 @@ static void cl_command_queue_delete(cl_command_queue queue)
   assert(queue->ctx);
   assert(queue->device);
 
-  pthread_mutex_lock(&queue->ctx->lock);
+  CL_MUTEX_LOCK(&queue->ctx->lock);
   if (queue->prev)
     queue->prev->next = queue->next;
   if (queue->next)
     queue->next->prev = queue->prev;
   if (queue->ctx->queues == queue)
     queue->ctx->queues = queue->next;
-  pthread_mutex_unlock(&queue->ctx->lock);
+  CL_MUTEX_UNLOCK(&queue->ctx->lock);
 
   cl_release_context(queue->ctx);
   cl_release_device_id(queue->device);