add desub

wangzhengquan

2020-08-06 203df24a403a8c0cd8e93d0f33eaf10de2788969

 src/socket/include/dmod_socket.h

@@ -48,6 +48,8 @@
   int _sub_( void *topic, int size, int port, struct timespec *timeout, int flags);
   int _pub_( void *topic, int topic_size, void *content, int content_size, int port, struct timespec *timeout, int flags);

   void _proxy_desub( char *topic, int port);
   int  _desub_( void *topic, int size, int port, struct timespec *timeout, int flags);
   static void  foreach_subscripters(std::function<void(SHMKeySet *, SHMKeySet::iterator)>  cb) ;
public:
   DModSocket();
@@ -116,6 +118,16 @@
   int  sub_nowait(void *topic, int size, int port);


    /**
    * 取消订阅指定主题
    * @topic 主题
    * @size 主题长度
    * @port 总线端口
    */
   int desub( void *topic, int size, int port);
   // 超时返回。 @sec 秒 ， @nsec 纳秒
   int desub_timeout(void *topic, int size, int port, struct timespec *timeout);
   int desub_nowait(void *topic, int size, int port) ;

   /**
    * 发布主题