dd

messaging/msgq.cc

@@ -36,6 +36,22 @@ SharedMemory::SharedMemory(const std::string &name, size_t size) :shm_name(name)
   assert(sem != SEM_FAILED);
   sem_wait(sem);  // Lock semaphore
   header = (SharedMemoryHeader *)shm_ptr;
+
+  /*
+  bool is_mutex_initialized() {
+    int result = pthread_mutex_trylock(&mutex);
+    if (result == 0) {
+        pthread_mutex_unlock(&mutex);
+        return true;
+    } else if (result == EBUSY) {
+        return true;
+    } else if (result == EINVAL) {
+        return false;
+    }
+    return false;
+}
+  */
+
   if (!header->initialized) {
     pthread_mutexattr_t mutex_attr;
     pthread_condattr_t cond_attr;
@@ -448,7 +464,6 @@ int msgq_poll(msgq_pollitem_t * items, size_t nitems, int timeout){
       break;
     }
   }
-
   return num;
 }