代码拉取完成,页面将自动刷新
同步操作将从 kibaamor/knet 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
#include "cecho_conn.h"
#include <knet/kconnector.h>
#include <knet/kasync_worker.h>
#include <knet/kutils.h>
int main(int argc, char** argv)
{
// parse command line
const char* ip = argc > 1 ? argv[1] : "localhost";
const char* port = argc > 2 ? argv[2] : "8888";
const auto client_num = argc > 3 ? std::atoi(argv[3]) : 1000;
const auto timeout_ms = argc > 4 ? std::atoi(argv[4]) : -1;
const auto thread_num = argc > 5 ? std::atoi(argv[5]) : std::thread::hardware_concurrency();
// log parameter info
std::cout << "Hi, KNet(Async Client)" << std::endl
<< "ip:" << ip << std::endl
<< "port: " << port << std::endl
<< "client_num: " << client_num << std::endl
<< "timeout_ms: " << timeout_ms << std::endl
<< "thread_num: " << thread_num << std::endl;
// parse ip address
address addr;
if (!address::resolve_one(ip, port, family_t::Ipv4, addr)) {
std::cerr << "resolve address " << ip << ":" << port << " failed!" << std::endl;
return -1;
}
// create worker
echo_conn_factory<cecho_conn> cf;
async_worker wkr(cf);
if (!wkr.start(thread_num)) {
std::cerr << "async_echo_conn_mgr::start failed" << std::endl;
return -1;
}
// create connector
connector cnctor(wkr);
// check console input
mgr.is_server = false;
mgr.can_log = false;
mgr.check_console_input();
auto last_ms = now_ms();
while (true) {
const auto beg_ms = now_ms();
const auto delta_ms = (beg_ms > last_ms ? beg_ms - last_ms : 0);
last_ms = beg_ms;
const auto inst_num = mgr.inst_num.load();
if (mgr.disconnect_all) {
if (0 == inst_num) {
break;
}
} else if (inst_num < client_num) {
if (!cnctor.connect(addr, timeout_ms)) {
std::cerr << "connect failed! address: " << addr << std::endl;
}
}
mgr.update(delta_ms);
const auto end_ms = now_ms();
const auto cost_ms = end_ms > beg_ms ? end_ms - beg_ms : 0;
constexpr int64_t min_interval_ms = 50;
sleep_ms(cost_ms < min_interval_ms ? min_interval_ms - cost_ms : 1);
}
wkr.stop();
return 0;
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。