三个没有回收的信号

wangzhengquan

2020-12-22 b90ba316b54db321d3e8aaac7df93b46d80b9d9c

 src/queue/mm.c

@@ -310,7 +310,14 @@
  if(shmctl(shmid, IPC_STAT, &shmid_ds) == 0) {
    //LoggerFactory::getLogger()->debug("shm_nattch=%d\n", shmid_ds.shm_nattch);
    // 只有当前一个进程attach到共享内存上
    if(shmid_ds.shm_nattch == 1) {
    if (shmid_ds.shm_nattch > 1) {
      //detache
      if (shmdt(shmp) == -1) {
        LoggerFactory::getLogger()->error(errno, "mm_destroy shmdt");
      }
      SemUtil::inc(mutex);
      return false;
    } else  {
      
      hashtable_destroy(hashtable);
      //detache
@@ -326,14 +333,13 @@
      else 
         LoggerFactory::getLogger()->debug("shared memory destroy\n");

      LoggerFactory::getLogger()->debug(errno, "mm_destroy: real destroy.");

      SemUtil::inc(mutex);
      SemUtil::remove(mutex);
      return true;

    } else {
      SemUtil::inc(mutex);
      return false;
    }
    } 
    
  } else {
    err_msg(errno, "mm_destroy shmctl IPC_STAT");