pb.go MsgQueryProcReply add subLocalTopics and subNetTopics

liuxiaolong

2022-01-05 27d8bc7cad4a8f68c2da3efbb77f45ec70ae40e6

 src/shm/hashtable.h

@@ -5,7 +5,8 @@
#include <functional>
#include <set>

#define MAPSIZE 1024
#define START_KEY 1000
#define MAPSIZE 4096

// 创建Queue数量的上限
#define QUEUE_COUNT_LIMIT 300
@@ -31,12 +32,9 @@
void hashtable_put(hashtable_t *hashtable, int key, void *value) ;
bool  hashtable_check_put(hashtable_t *hashtable, int key, void *value, bool overwrite) ;

void *hashtable_remove(hashtable_t *hashtable, int key);
static inline void _hashtable_remove(hashtable_t *hashtable, int key);
void hashtable_remove(hashtable_t *hashtable, int key);
void hashtable_removeall(hashtable_t *hashtable);

int hashtable_lock(hashtable_t *hashtable);
int hashtable_unlock(hashtable_t *hashtable);

int hashtable_get_queue_count(hashtable_t *hashtable) ;
/** 
 * 遍历hash_table