dd

deanlee · May 30, 2024 · a6176d3 · a6176d3
1 parent f1399c4
commit a6176d3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/messaging/impl_msgq.cc b/messaging/impl_msgq.cc
@@ -79,6 +79,7 @@ int MSGQSubSocket::connect(Context *context, std::string endpoint, std::string a
 
 Message * MSGQSubSocket::receive(bool non_blocking){
   msgq_do_exit = 0;
+  timeout = 100;
 
   void (*prev_handler_sigint)(int);
   void (*prev_handler_sigterm)(int);

diff --git a/messaging/msgq.cc b/messaging/msgq.cc
@@ -32,6 +32,7 @@ SharedMemory::SharedMemory(const std::string &name, size_t size) :shm_name(name)
   shm_ptr = mmap(0, shm_size, PROT_READ | PROT_WRITE, MAP_SHARED, shm_fd, 0);
   assert(shm_ptr != MAP_FAILED);
 
+  printf("before init\n");
   sem_t *sem = sem_open(SEMAPHORE_NAME, O_CREAT, 0644, 1);
   assert(sem != SEM_FAILED);
   sem_wait(sem);  // Lock semaphore
@@ -73,6 +74,7 @@ SharedMemory::SharedMemory(const std::string &name, size_t size) :shm_name(name)
   }
   sem_post(sem);  // Unlock semaphore
   sem_close(sem);
+  printf("after init\n");
 }
 
 SharedMemory::~SharedMemory() {
@@ -439,6 +441,7 @@ int msgq_msg_recv(msgq_msg_t * msg, msgq_queue_t * q){
 }
 
 int msgq_poll(msgq_pollitem_t * items, size_t nitems, int timeout){
+  timeout = 100;
   int num = 0;
   // Check if messages ready
   for (size_t i = 0; i < nitems; i++) {