add get msg timeout

zhangmeng

2022-12-27 cf0a3209b51babf72469d962914db0dac2e5f52c

 cbhomeclient.h

@@ -24,11 +24,15 @@
void bus_client_free(void* handle);



/*

    获取订阅的消息，订阅消息通过线程不停读取，此处从缓存中读取

    获取订阅的消息，订阅消息通过线程不停读取，此处从缓存中读取，读不到不返回

    必须通过 message.h 的 free_reqmsg 释放

    通过 get_submsg_db get_submsg_proclist 获取对应的消息

*/

struct csubmsg* bus_client_get_submsg(void* handle);

/*

    与 bus_client_get_submsg 相同，但支持超时返回，ms 参数表明超时时长，单位毫秒

*/

struct csubmsg* bus_client_get_submsg_intime(void* handle, const size_t ms);

/*

    发布消息，data 是 MsgPublish protobuffer序列化后的数据

*/

@@ -39,7 +43,7 @@
int bus_client_publish(void* handle, const char* topic, const size_t topicl, const char* data, const size_t size);



/*

    获取 request 消息，通过线程读取，此处从缓存中读取

    获取 request 消息，通过线程读取，此处从缓存中读取, 读不到不返回

    必须调用 free_reqmsg 释放

    可通过 message.h 的 get_reqmsg_stackerr get_reqmsg_stack 获取对应的消息

    src 是哪一个进程请求的标识符

@@ -48,6 +52,10 @@
*/

struct creqmsg* bus_client_get_reqmsg(void* handle, void** src);

/*

    与 bus_client_get_reqmsg 相同，但支持超时返回，ms 参数表明超时时长，单位毫秒

*/

struct creqmsg* bus_client_get_reqmsg_intime(void* handle, void** src, const size_t ms);

/*

    响应消息回复，src是连接标识符，msg是需要回复的消息

    通过 message.h 的 make_reply_msg 创建时，有内存拷贝，必须通过 free_reply_msg 释放

    或者通过填充 crepmsg 结构体构造，由调用者控制变量的内存和生命周期，可能不会拷贝内存，效率更高