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