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. --- utest/speed_test.cpp | 6 +++--- 1 files changed, 3 insertions(+), 3 deletions(-) diff --git a/utest/speed_test.cpp b/utest/speed_test.cpp index d145ab4..302d4bd 100644 --- a/utest/speed_test.cpp +++ b/utest/speed_test.cpp @@ -38,7 +38,7 @@ MsgRequestTopic body; body.set_topic("topic"); body.set_data(str); - auto head(InitMsgHead(GetType(body), proc_id)); + auto head(InitMsgHead(GetType(body), proc_id, mq.Id())); msg.Make(head, body); assert(msg.valid()); DEFER1(msg.Release();); @@ -156,7 +156,7 @@ MsgRequestTopic req_body; req_body.set_topic("topic"); req_body.set_data(msg_content); - auto req_head(InitMsgHead(GetType(req_body), client_proc_id)); + auto req_head(InitMsgHead(GetType(req_body), client_proc_id, cli.id())); req_head.add_route()->set_mq_id(cli.id()); return cli.Send(srv.id(), req_head, req_body); }; @@ -180,7 +180,7 @@ MsgRequestTopic reply_body; reply_body.set_topic("topic"); reply_body.set_data(msg_content); - auto reply_head(InitMsgHead(GetType(reply_body), server_proc_id, req_head.msg_id())); + auto reply_head(InitMsgHead(GetType(reply_body), server_proc_id, srv.id(), req_head.msg_id())); return srv.Send(src_id, reply_head, reply_body); }; Reply(); -- Gitblit v1.8.0