Skip to content
Snippets Groups Projects
Commit f8b33b2f authored by Adrien Béraud's avatar Adrien Béraud
Browse files

bench: use local node by default

Change-Id: I4030534348074592b6f2a3ff8c1f8f2cb4438ca3
parent c3777bb6
No related branches found
No related tags found
No related merge requests found
...@@ -59,8 +59,8 @@ setupHandler(const std::string& name, ...@@ -59,8 +59,8 @@ setupHandler(const std::string& name,
h->dht = std::make_shared<dht::DhtRunner>(); h->dht = std::make_shared<dht::DhtRunner>();
h->dht->run(dhtConfig, std::move(dhtContext)); h->dht->run(dhtConfig, std::move(dhtContext));
//h->dht->bootstrap("127.0.0.1:36432"); h->dht->bootstrap("127.0.0.1:36432");
h->dht->bootstrap("bootstrap.jami.net"); //h->dht->bootstrap("bootstrap.jami.net");
auto config = std::make_shared<ConnectionManager::Config>(); auto config = std::make_shared<ConnectionManager::Config>();
config->dht = h->dht; config->dht = h->dht;
...@@ -97,8 +97,8 @@ runBench(std::shared_ptr<asio::io_context> ioContext, ...@@ -97,8 +97,8 @@ runBench(std::shared_ptr<asio::io_context> ioContext,
std::unique_lock<std::mutex> lock {mtx}; std::unique_lock<std::mutex> lock {mtx};
std::condition_variable serverConVar; std::condition_variable serverConVar;
//auto boostrap_node = std::make_shared<dht::DhtRunner>(); auto boostrap_node = std::make_shared<dht::DhtRunner>();
//boostrap_node->run(36432); boostrap_node->run(36432);
fmt::print("Generating identities…\n"); fmt::print("Generating identities…\n");
auto server = setupHandler("server", ioContext, ioContextRunner, factory, logger); auto server = setupHandler("server", ioContext, ioContextRunner, factory, logger);
...@@ -132,7 +132,7 @@ runBench(std::shared_ptr<asio::io_context> ioContext, ...@@ -132,7 +132,7 @@ runBench(std::shared_ptr<asio::io_context> ioContext,
constexpr size_t TX_GOAL = TX_SIZE * TX_NUM; constexpr size_t TX_GOAL = TX_SIZE * TX_NUM;
time_point start_connect, start_send; time_point start_connect, start_send;
std::this_thread::sleep_for(5s); std::this_thread::sleep_for(3s);
fmt::print("Connecting…\n"); fmt::print("Connecting…\n");
start_connect = clock::now(); start_connect = clock::now();
client->connectionManager->connectDevice(server->id.second, "channelName", [&](std::shared_ptr<ChannelSocket> socket, const DeviceId&) { client->connectionManager->connectDevice(server->id.second, "channelName", [&](std::shared_ptr<ChannelSocket> socket, const DeviceId&) {
...@@ -149,7 +149,7 @@ runBench(std::shared_ptr<asio::io_context> ioContext, ...@@ -149,7 +149,7 @@ runBench(std::shared_ptr<asio::io_context> ioContext,
}); });
ret.connection = clock::now() - start_connect; ret.connection = clock::now() - start_connect;
fmt::print("Connected in {}\n", dht::print_duration(ret.connection)); fmt::print("Connected in {}\n", dht::print_duration(ret.connection));
std::vector<uint8_t> data(TX_SIZE, 'y'); std::vector<uint8_t> data(TX_SIZE, (uint8_t)'y');
std::error_code ec; std::error_code ec;
start_send = clock::now(); start_send = clock::now();
for (unsigned i = 0; i < TX_NUM; ++i) { for (unsigned i = 0; i < TX_NUM; ++i) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment