From ab898268c8bc493ca9862b2d64f2e1e7d20e5a4c Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期三, 02 六月 2021 13:39:00 +0800
Subject: [PATCH] refactor.
---
utest/api_test.cpp | 36 ++++++++++++++++++++++++++++--------
1 files changed, 28 insertions(+), 8 deletions(-)
diff --git a/utest/api_test.cpp b/utest/api_test.cpp
index 7081435..bddcbf7 100644
--- a/utest/api_test.cpp
+++ b/utest/api_test.cpp
@@ -176,8 +176,21 @@
int reply_len = 0;
bool r = BHRegisterTopics(s.data(), s.size(), &reply, &reply_len, 1000);
DEFER1(BHFree(reply, reply_len));
- // printf("register topic : %s\n", r ? "ok" : "failed");
- // Sleep(1s);
+ }
+ { // Server Register Topics
+ MsgTopicList topics;
+ topics.add_topic_list("@should_fail");
+ std::string s = topics.SerializeAsString();
+ void *reply = 0;
+ int reply_len = 0;
+ bool r = BHRegisterTopics(s.data(), s.size(), &reply, &reply_len, 1000);
+ DEFER1(BHFree(reply, reply_len));
+ if (!r) {
+ int ec = 0;
+ std::string msg;
+ GetApiError(ec, msg);
+ printf("register rpc failed, %d, %s\n", ec, msg.c_str());
+ }
}
auto PrintProcs = [](MsgQueryProcReply const &result) {
printf("query proc result: %d\n", result.proc_list().size());
@@ -193,7 +206,7 @@
}
printf("\n");
};
- {
+ if (0) {
// query procs
std::string dest(BHAddress().SerializeAsString());
MsgQueryProc query;
@@ -211,14 +224,21 @@
// printf("register topic : %s\n", r ? "ok" : "failed");
// Sleep(1s);
}
- {
+ for (int i = 0; i < 3; ++i) {
// query procs with normal topic request
MsgRequestTopic req;
- req.set_topic("@center_query_procs");
+ req.set_topic("#center_query_procs");
// req.set_data("{\"proc_id\":\"#center.node\"}");
std::string s(req.SerializeAsString());
// Sleep(10ms, false);
- std::string dest(BHAddress().SerializeAsString());
+ BHAddress host;
+ printf("query with ip set\n");
+ host.set_ip("127.0.0.1");
+ host.set_port(kBHCenterPort);
+ host.set_mq_id(1000011);
+ host.set_abs_addr(10296);
+
+ std::string dest(host.SerializeAsString());
void *proc_id = 0;
int proc_id_len = 0;
DEFER1(BHFree(proc_id, proc_id_len););
@@ -234,7 +254,7 @@
} else {
MsgRequestTopicReply ret;
ret.ParseFromArray(reply, reply_len);
- printf("topic query proc : %s\n", ret.data().c_str());
+ printf("\ntopic query proc : %s\n", ret.data().c_str());
// MsgQueryProcReply result;
// if (result.ParseFromArray(ret.data().data(), ret.data().size()) && IsSuccess(result.errmsg().errcode())) {
// PrintProcs(result);
@@ -312,7 +332,7 @@
for (int i = 0; i < 1; ++i) {
MsgPublish pub;
pub.set_topic(topic_ + std::to_string(i));
- pub.set_data("pub_data_" + std::string(1024 * 1, 'a'));
+ pub.set_data("pub_data_" + std::string(104 * 1, 'a'));
std::string s(pub.SerializeAsString());
BHPublish(s.data(), s.size(), 0);
// Sleep(1s);
--
Gitblit v1.8.0