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