update

wangzhengquan

2020-07-20 9052085027b66a7a6e69405834e36981b201618b

update

 queue/include/shm_queue.h

@@ -40,7 +40,7 @@

    inline ELEM_T& operator[](unsigned i);

    static void remove_queues_exclued(int *keys, size_t length);
    static void remove_queues_exclude(int *keys, size_t length);
private:


@@ -56,7 +56,7 @@


template < typename ELEM_T >
void SHMQueue<ELEM_T>::remove_queues_exclued(int *keys, size_t length)
void SHMQueue<ELEM_T>::remove_queues_exclude(int *keys, size_t length)
{
    hashtable_t *hashtable = mm_get_hashtable();
    std::set<int>* keyset = hashtable_keyset(hashtable);

 queue/include/shm_queue_wrapper.h

@@ -13,7 +13,7 @@
 

//移除不包含在keys中的队列
void shm_remove_queues_exclued(void *keys, int length);
void shm_remove_queues_exclude(void *keys, int length);
/**
 * 创建队列
 * @ shmqueue 

 queue/libshm_queue.a

Binary files differ

 queue/shm_queue_wrapper.c

@@ -15,7 +15,7 @@


//移除不包含在keys中的队列
void shm_remove_queues_exclued(void *keys, int length) {
void shm_remove_queues_exclude(void *keys, int length) {
    SHMQueue<ele_t>::remove_queues_exclued((int*)keys, (size_t)length);
}


 test/communication

Binary files differ

 test2/pub_sub

Binary files differ

 test2/req_rep

Binary files differ