I forgor (closing the pipes) ...

2026-06-08 20:28:31 +02:00
parent 700dbe00dd
commit 07c75d024d
1 changed files with 7 additions and 1 deletions
@@ -13,8 +13,9 @@ int mq_read(mq_response_t* response_buf) {
    char abs_path[128];
    snprintf(abs_path, sizeof(abs_path), "/dev/mqueue%s", path);

+    // wait untill file exitst
    while (access(abs_path, F_OK) == -1) {
-        usleep(100);
+        usleep(200);
    }

    mqd_t queue = mq_open(path, O_RDONLY);
@@ -24,6 +25,9 @@ int mq_read(mq_response_t* response_buf) {
    }

    int err = mq_receive(queue,(char*)response_buf, sizeof(mq_response_t), 0); 
+
+    mq_close(queue);
+
    return err;
 }

@@ -35,5 +39,7 @@ int mq_write(mq_message_t message) {
    }

    int err = mq_send(queue, (const char*)&message, sizeof(mq_message_t), 0);
+
+    mq_close(queue);
    return err;
 }