update

wangzhengquan

2020-07-27 d94bfb19c54d4b980c1b4d63b42f3dfa0bc202a6

 src/socket/dgram_mod_socket.c

@@ -17,7 +17,6 @@
static Logger logger = LoggerFactory::getLogger();

typedef struct dgram_mod_socket_t {
   socket_mod_t mod;
  shm_socket_t *shm_socket;
  // pthread_t recv_thread;
  // <主题， 订阅者>
@@ -85,7 +84,7 @@



int dgram_mod_get_socket_port(void * _socket) {
int dgram_mod_get_port(void * _socket) {
   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
   return socket->shm_socket->port;
}
@@ -95,7 +94,7 @@
   free(buf);
}

int start_bus(void * _socket) {
int  dgram_mod_start_bus(void * _socket) {
   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
   socket->topic_sub_map = new std::map<std::string, std::set<int> *>;
   run_pubsub_proxy(socket);
@@ -108,7 +107,7 @@
/**
 * @port 总线端口
 */
int sub(void * _socket, void *topic, int size, int port) {
int  dgram_mod_sub(void * _socket, void *topic, int size, int port) {
   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
   char buf[8192];
   snprintf(buf,  8192, "%ssub%s%s%s%s", ACTION_LIDENTIFIER, ACTION_RIDENTIFIER, TOPIC_LIDENTIFIER, (char *)topic, TOPIC_RIDENTIFIER);
@@ -118,7 +117,7 @@
/**
 * @port 总线端口
 */
int pub(void * _socket, void *topic, int topic_size, void *content, int content_size, int port) {
int  dgram_mod_pub(void * _socket, void *topic, int topic_size, void *content, int content_size, int port) {

   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
   int head_len;