commit

wangzhengquan

2020-07-27 aeaeda81cfe398081a7c1a5c287981c8df974aa2

 src/socket/dgram_mod_socket.c

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


static Logger logger = LoggerFactory::getLogger();

#define BUS_MAP_KEY 1
//typedef std::basic_string<char, std::char_traits<char>, SHM_STL_Allocator<char> > SHMString;
typedef std::set<int,  std::less<int>, SHM_STL_Allocator<int> > SHMKeySet;
typedef std::map<SHMString, SHMKeySet *, std::less<SHMString>, SHM_STL_Allocator<std::pair<SHMString, SHMKeySet *> > > SHMTopicSubMap;
@@ -49,7 +49,7 @@
         subscripter_set = map_iter->second;
         delete subscripter_set;
      }
      delete topic_sub_map;
      mem_pool_free_by_key(BUS_MAP_KEY);
   }
   

@@ -108,7 +108,7 @@
   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
printf("mem_pool_malloc_by_key before\n");
   // void *map_ptr = mem_pool_malloc_by_key(1, sizeof(SHMTopicSubMap));
   socket->topic_sub_map =   mem_pool_attach<SHMTopicSubMap>(1);
   socket->topic_sub_map =   mem_pool_attach<SHMTopicSubMap>(BUS_MAP_KEY);
printf("mem_pool_malloc_by_key after\n");

   // socket->topic_sub_map = new(map_ptr) SHMTopicSubMap;