From 026bbfaf2b5d73a26b8e2fa49158883ef64c211b Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期四, 27 五月 2021 13:51:26 +0800
Subject: [PATCH] tcp server call center to send proxy requests.

---
 utest/tcp_test.cpp |   29 ++++++++++++++++++++++-------
 1 files changed, 22 insertions(+), 7 deletions(-)

diff --git a/utest/tcp_test.cpp b/utest/tcp_test.cpp
index ff31c3e..a838252 100644
--- a/utest/tcp_test.cpp
+++ b/utest/tcp_test.cpp
@@ -16,6 +16,8 @@
  * =====================================================================================
  */
 
+#include "defs.h"
+#include "node_center.h"
 #include "tcp_connection.h"
 #include "tcp_server.h"
 #include "util.h"
@@ -31,18 +33,31 @@
 
 BOOST_AUTO_TEST_CASE(TcpTest)
 {
-	const std::string bind_addr = "127.0.0.1";
-	const std::string connect_addr = "127.0.0.1";
-	const uint16_t port = 10000;
+	SharedMemory &shm = TestShm();
 
-	TcpServer server(port);
-	server.Start();
+	const std::string connect_addr = "127.0.0.1";
+	const uint16_t port = kBHCenterPort;
 
 	boost::asio::io_context io;
 
 	tcp::endpoint dest(ip::address::from_string(connect_addr), port);
-	for (int i = 0; i < 10; ++i) {
-		TcpRequest1::Create(io, dest, "client->server " + std::to_string(i));
+	MsgRequestTopic req;
+	req.set_topic("#center_query_procs");
+	req.set_data("");
+	auto head = InitMsgHead(GetType(req), "#test_proc", 1000000);
+	auto route = head.add_route();
+	route->set_mq_id(12345);
+	route->set_abs_addr(67890);
+
+	head.mutable_dest()->set_ip(connect_addr);
+	head.mutable_dest()->set_port(port);
+	head.mutable_dest()->set_mq_id(1000011);
+	head.mutable_dest()->set_abs_addr(10296);
+
+	auto request(MsgI::Serialize(head, req));
+	for (int i = 0; i < 1; ++i) {
+		LOG_DEBUG() << "request size: " << request.size();
+		TcpRequest1::Create(io, dest, request, DefaultSender(BHomeShm()));
 	}
 
 	io.run();

--
Gitblit v1.8.0