| | |
| | | |
| | | private: |
| | | void _proxy_sub( char *topic, int key); |
| | | void _proxy_pub( char *topic, size_t head_len, void *buf, size_t size, int key); |
| | | void *run_pubsub_proxy(); |
| | | int parse_pubsub_topic(char *str, size_t size, char **_action, char **_topic, size_t *head_len ); |
| | | void _proxy_pub( char *topic, void *buf, size_t size, int key); |
| | | void *_run_proxy_(); |
| | | // int parse_pubsub_topic(char *str, size_t size, char **_action, char **_topic, size_t *head_len ); |
| | | |
| | | void _proxy_desub( char *topic, int key); |
| | | void _proxy_desub_all(int key); |