| | |
|---|
| | | #define PROTO_UA9UWKL1 |
|---|
| | | |
|---|
| | | #include "bhome_msg.pb.h" |
|---|
| | | #include "bhome_msg_api.pb.h" |
|---|
| | | #include <chrono> |
|---|
| | | |
|---|
| | | using namespace bhome::msg; |
|---|
| | | |
|---|
| | |
|---|
| | | SetError(*msg.mutable_errmsg(), err_code, err_str); |
|---|
| | | return msg; |
|---|
| | | } |
|---|
| | | |
|---|
| | | std::string NewMsgId(); |
|---|
| | | BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id, const std::string &msgid); |
|---|
| | | BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id); |
|---|
| | | // inline void AddRoute(BHMsgHead &head, const MQId &id) { head.add_route()->set_mq_id(&id, sizeof(id)); } |
|---|
| | | inline bool IsSuccess(const ErrorCode ec) { return ec == eSuccess; } |
|---|
| | | bool IsMsgExpired(const BHMsgHead &head); |
|---|
| | | |
|---|
| | | inline int64_t CountSeconds(const std::chrono::steady_clock::time_point tp) |
|---|
| | | { |
|---|
| | | return std::chrono::duration_cast<std::chrono::seconds>(tp.time_since_epoch()).count(); |
|---|
| | | } |
|---|
| | | inline int64_t NowSec() |
|---|
| | | { |
|---|
| | | return CountSeconds(std::chrono::steady_clock::now()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | #endif // end of include guard: PROTO_UA9UWKL1 |
|---|
