mirror of
https://github.com/qicosmos/rest_rpc.git
synced 2026-08-29 16:40:48 +08:00
add benchmark test.
This commit is contained in:
@@ -600,7 +600,29 @@ void test_ssl() {
|
||||
std::getchar();
|
||||
}
|
||||
|
||||
void benchmark_test(){
|
||||
rpc_client client;
|
||||
bool r = client.connect("127.0.0.1", 9000);
|
||||
if (!r) {
|
||||
return;
|
||||
}
|
||||
|
||||
for (size_t i = 0; i < 1000000; i++) {
|
||||
client.async_call("echo", [i](boost::system::error_code ec, string_view data) {
|
||||
if (ec) {
|
||||
return;
|
||||
}
|
||||
|
||||
}, "hello wolrd");
|
||||
std::this_thread::sleep_for(std::chrono::microseconds(2));
|
||||
}
|
||||
|
||||
std::getchar();
|
||||
std::cout<<"benchmark test finished\n";
|
||||
}
|
||||
|
||||
int main() {
|
||||
// benchmark_test();
|
||||
test_sub1();
|
||||
test_connect();
|
||||
test_callback();
|
||||
|
||||
@@ -84,6 +84,7 @@ void async_echo(rpc_conn conn, const std::string& src) {
|
||||
}
|
||||
|
||||
std::string echo(rpc_conn conn, const std::string& src) {
|
||||
g_qps.increase();
|
||||
return src;
|
||||
}
|
||||
|
||||
@@ -98,7 +99,14 @@ void test_ssl() {
|
||||
server.run();
|
||||
}
|
||||
|
||||
void benchmark_test(){
|
||||
rpc_server server(9000, std::thread::hardware_concurrency());
|
||||
server.register_handler("echo", echo);
|
||||
server.run();
|
||||
}
|
||||
|
||||
int main() {
|
||||
// benchmark_test();
|
||||
rpc_server server(9000, std::thread::hardware_concurrency());
|
||||
|
||||
dummy d;
|
||||
|
||||
Reference in New Issue
Block a user