fujuntang
2021-10-10 d69e2a2ed12d639cca99a4718250aacd6579987c
src/shm/hashtable.cpp
@@ -102,7 +102,7 @@
  void *oldvalue;
  int rv;
  if( (rv = svsem_wait(hashtable->mutex)) != 0) {
  if( (rv = svsem_uni_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(errno, "hashtable_remove\n");
  }
  tailq_header_t *my_tailq_head = hashtable->array[code] ;
@@ -140,7 +140,7 @@
void *hashtable_get(hashtable_t *hashtable, int key) {
  int rv;
  if((rv = svsem_wait(hashtable->mutex)) != 0) {
  if((rv = svsem_uni_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(errno, "hashtable_get\n");
  }
  void * res = _hashtable_get(hashtable, key);
@@ -154,7 +154,7 @@
void hashtable_put(hashtable_t *hashtable, int key, void *value) {
  int rv;
  if((rv = svsem_wait(hashtable->mutex)) != 0) {
  if((rv = svsem_uni_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(errno, "hashtable_put\n");
  }
  _hashtable_put(hashtable, key, value); 
@@ -170,7 +170,7 @@
  int rv;
  void * val;
  if(( rv = svsem_wait(hashtable->mutex)) != 0) {
  if(( rv = svsem_uni_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(errno, "hashtable_put\n");
  }
  if(overwrite) {
@@ -208,7 +208,7 @@
    key = START_KEY;
  }
  rv = svsem_wait(hashtable->mutex);
  rv = svsem_uni_wait(hashtable->mutex);
  if(rv != 0) {
    LoggerFactory::getLogger()->error(errno, "hashtable_alloc_key\n");
  }
@@ -271,7 +271,7 @@
{
  tailq_entry_t *item;
  int rv;
  if( (rv = svsem_wait(hashtable->mutex)) != 0) {
  if( (rv = svsem_uni_wait(hashtable->mutex)) != 0) {
    LoggerFactory::getLogger()->error(errno, "hashtable_removeall\n");
  }
  for (int i = 0; i < MAPSIZE; i++)