update

wangzhengquan

2021-01-25 c46be6db32872bfd7c4010b43526b5e6bc0fa6a5

 src/shm/hashtable.cpp

@@ -110,13 +110,13 @@
  int rv;

  if( (rv = svsem_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(rv, "hashtable_remove\n");
    LoggerFactory::getLogger()->error(errno, "hashtable_remove\n");
  }
  tailq_header_t *my_tailq_head = hashtable->array[code] ;
  if ( my_tailq_head == NULL)
  {
    if((rv = svsem_post(hashtable->mutex)) != 0) {
      LoggerFactory::getLogger()->error(rv, "hashtable_remove\n");
      LoggerFactory::getLogger()->error(errno, "hashtable_remove\n");
    }
    return NULL;
  } else {
@@ -136,7 +136,7 @@
    }

    if((rv = svsem_post(hashtable->mutex)) != 0) {
      LoggerFactory::getLogger()->error(rv, "hashtable_remove\n");
      LoggerFactory::getLogger()->error(errno, "hashtable_remove\n");
    }

    return NULL;
@@ -155,13 +155,13 @@

  int rv;
  if(( rv = svsem_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(rv, "hashtable_put\n");
    LoggerFactory::getLogger()->error(errno, "hashtable_put\n");
  }

  _hashtable_put(hashtable, key, value);

  if(( rv = svsem_post(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(rv, "hashtable_put\n");
    LoggerFactory::getLogger()->error(errno, "hashtable_put\n");
  }
}

@@ -212,7 +212,7 @@
  int key = START_KEY;
  rv = svsem_wait(hashtable->mutex);
  if(rv != 0) {
    LoggerFactory::getLogger()->error(rv, "hashtable_alloc_key\n");
    LoggerFactory::getLogger()->error(errno, "hashtable_alloc_key\n");
  }

  while(_hashtable_get(hashtable, key) != NULL) {
@@ -223,7 +223,7 @@

  rv = svsem_post(hashtable->mutex);
  if(rv != 0) {
    LoggerFactory::getLogger()->error(rv, "hashtable_alloc_key\n");
    LoggerFactory::getLogger()->error(errno, "hashtable_alloc_key\n");
  }
  return key;
}
@@ -234,7 +234,7 @@
  tailq_entry_t *item;
  int rv;
  if( (rv = svsem_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(rv, "hashtable_removeall\n");
    LoggerFactory::getLogger()->error(errno, "hashtable_removeall\n");
  }
  for (int i = 0; i < MAPSIZE; i++)
  {
@@ -253,7 +253,7 @@
  }

  if((rv = svsem_post(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(rv, "hashtable_removeall\n");
    LoggerFactory::getLogger()->error(errno, "hashtable_removeall\n");
  }
}