wangzhengquan
2020-08-06 203df24a403a8c0cd8e93d0f33eaf10de2788969
src/socket/dgram_mod_socket.c
@@ -144,6 +144,29 @@
/**
 * 取消订阅指定主题
 * @topic 主题
 * @size 主题长度
 * @port 总线端口
 */
int  dgram_mod_desub(void * _socket, void *topic, int size, int port){
   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
   return socket->m_socket->desub(topic,  size,  port);
}
// 超时返回。 @sec 秒 , @nsec 纳秒
int  dgram_mod_desub_timeout(void * _socket, void *topic, int size, int port, int sec, int nsec){
   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
   struct timespec timeout = {sec, nsec};
   return socket->m_socket->desub_timeout(topic,  size,  port, &timeout);
}
int  dgram_mod_desub_nowait(void * _socket, void *topic, int size, int port){
   dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
   return socket->m_socket->desub_nowait(topic,  size,  port);
}
/**
 * 发布主题
 * @topic 主题
 * @content 主题内容