!2398 fix message queue concurrent bug

From: @jikai11 Reviewed-by: @xuxuepeng Signed-off-by: @xuxuepeng
openeuler-mirror · Apr 2, 2024 · 4732e0b · 4732e0b
2 parents 8504a6b + f90a145
commit 4732e0b
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/daemon/mailbox/message_queue.c b/src/daemon/mailbox/message_queue.c
@@ -106,11 +106,12 @@ message_queue *message_queue_create(void (*release)(void *))
         return NULL;
     }
 
-    bq = blocking_queue_create(BLOCKING_QUEUE_NO_TIMEOUT, release);
-    if (bq == NULL) {
+    mq->messages = blocking_queue_create(BLOCKING_QUEUE_NO_TIMEOUT, release);
+    if (mq->messages == NULL) {
         ERROR("Failed to create events queue");
         return NULL;
     }
+    bq = mq->messages;
 
     mq->subscribers = map_new(MAP_PTR_INT, MAP_DEFAULT_CMP_FUNC, message_queue_subscriber_free);
     if (mq->subscribers == NULL) {
@@ -131,7 +132,7 @@ message_queue *message_queue_create(void (*release)(void *))
         return NULL;
     }
 
-    mq->messages = isula_transfer_ptr(bq);
+    bq = NULL;
     return isula_transfer_ptr(mq);
 }