| | |
| | |
|
| | | /*
|
| | | 获取订阅的消息,订阅消息通过线程不停读取,此处从缓存中读取
|
| | | 可通过 message.h 对应的 get_submsg_db get_submsg_proclist 获取对应的消息
|
| | | 必须通过 message.h 的 free_reqmsg 释放
|
| | | 通过 get_submsg_db get_submsg_proclist 获取对应的消息
|
| | | */
|
| | | struct csubmsg* bus_client_get_submsg(void* handle);
|
| | | /*
|
| | |
| | |
|
| | | /*
|
| | | 获取 request 消息,通过线程读取,此处从缓存中读取
|
| | | 必须调用 free_reqmsg 释放
|
| | | 可通过 message.h 的 get_reqmsg_stackerr get_reqmsg_stack 获取对应的消息
|
| | | src 是哪一个进程请求的标识符
|
| | | 可以响应多个request发送的消息,同时需要满足异步响应,使用 src 进行区分
|
| | |
| | | struct creqmsg* bus_client_get_reqmsg(void* handle, void** src);
|
| | | /*
|
| | | 响应消息回复,src是连接标识符,msg是需要回复的消息
|
| | | 通过 message.h 的 make_reply_msg 创建
|
| | | 通过 message.h 的 make_reply_msg 创建时,有内存拷贝,必须通过 free_reply_msg 释放
|
| | | 或者通过填充 crepmsg 结构体构造,由调用者控制变量的内存和生命周期,可能不会拷贝内存,效率更高
|
| | | */
|
| | | int bus_client_reply_msg(void* handle, void* src, const struct crepmsg* msg);
|
| | | /*
|
| | | 同步的request请求,发送 creqmsg 获取 crepmsg 回复
|
| | | 通过 message.h 的 make_req_msg 创建 request 消息
|
| | | 获取的 crepmsg 回复消息,需要使用 free_reply_msg 释放
|
| | | 通过 message.h 的 make_req_msg 创建 request 消息时,必须调用 free_reqmsg 释放
|
| | | 或者通过填充 creqmsg 结构体构造,由调用者控制变量的内存和生命周期,可能不会拷贝内存,效率更高
|
| | | 获取的 crepmsg 回复消息,必须使用 free_reply_msg 释放
|
| | | */
|
| | | int bus_client_request(void* handle, struct creqmsg* msg, struct crepmsg** repmsg);
|
| | |
|