From 5b6ced44157b6e7fab519ae48f5cffcdc2b3cd7c Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期日, 25 四月 2021 19:28:57 +0800 Subject: [PATCH] use node mqid ssn id to index online nodes. --- src/proto.h | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/proto.h b/src/proto.h index c30b4fd..94a438c 100644 --- a/src/proto.h +++ b/src/proto.h @@ -74,8 +74,8 @@ 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); +BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id, const uint64_t ssn_id, const std::string &msgid); +BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id, const uint64_t ssn_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); -- Gitblit v1.8.0