| | |
| | | { |
| | | queue->reference--; |
| | | LoggerFactory::getLogger().debug("SHMQueue destructor reference===%d", queue->reference.load()); |
| | | if(queue->reference == 0) { |
| | | if(queue->reference.load() == 0) { |
| | | delete queue; |
| | | hashtable_t *hashtable = getHashTable(); |
| | | hashtable_remove(hashtable, KEY); |
| | |
| | | static void *mem_sbrk(int incr); |
| | | static int is_allocated(void *ptr); |
| | | |
| | | |
| | | static int shmid = -1; |
| | | static void *shmp; |
| | | static int shmid = -1; |
| | | static void *shmp; |
| | | static int mutex = SemUtil::get(SHM_MUTEX_KEY, 1); |
| | | //static int mutex = SemUtil::get(IPC_PRIVATE, 1); |
| | | |