decrease latency

Author: cnbatch

src/3rd_party/fecpp.cpp

@@ -502,7 +502,7 @@ namespace fecpp
 		std::vector<std::unique_ptr<uint8_t[]>> redundan;
 		for (size_t i = K; i != N; ++i)
 		{
-			redundan.emplace_back(std::make_unique<uint8_t[]>(block_size));
+			redundan.emplace_back(std::make_unique_for_overwrite<uint8_t[]>(block_size));
 			size_t index = i - K;
 			for (size_t j = 0; j != K; ++j)
 				addmul(redundan[index].get(), input + j * block_size,
@@ -521,8 +521,8 @@ namespace fecpp
 			return {};
 
 		std::map<size_t, std::vector<uint8_t>> missing_blocks;
-		std::unique_ptr<uint8_t[]> m_dec = std::make_unique<uint8_t[]>(K * K);
-		std::unique_ptr<size_t[]> indexes = std::make_unique<size_t[]>(K);
+		std::unique_ptr<uint8_t[]> m_dec = std::make_unique_for_overwrite<uint8_t[]>(K * K);
+		std::unique_ptr<size_t[]> indexes = std::make_unique_for_overwrite<size_t[]>(K);
 		std::unique_ptr<const uint8_t *[]> sharesv = std::make_unique<const uint8_t * []>(K);
 
 		std::map<size_t, const uint8_t*>::const_iterator shares_b_iter = shares.begin();

src/main.cpp

@@ -16,15 +16,15 @@
 int main(int argc, char *argv[])
 {
 #ifdef __cpp_lib_format
-	std::cout << std::format("{} version 20250301\n", app_name);
+	std::cout << std::format("{} version 20250406\n", app_name);
 	if (argc <= 1)
 	{
 		std::cout << std::format("Usage: {} config1.conf\n", app_name);
 		std::cout << std::format("       {} config1.conf config2.conf...\n", (int)app_name.length(), app_name.data());
 		return 0;
 	}
 #else
-	std::cout << app_name << " version 20250301\n";
+	std::cout << app_name << " version 20250406\n";
 	if (argc <= 1)
 	{
 		std::cout << "Usage: " << app_name << " config1.conf\n";
@@ -33,33 +33,34 @@ int main(int argc, char *argv[])
 	}
 #endif
 
-	uint16_t thread_group_count = 2;
-	int io_thread_count = std::thread::hardware_concurrency() == 1 ? 1 : 2;
-	std::unique_ptr<ttp::task_thread_pool> parallel_pool_1;
-	std::unique_ptr<ttp::task_thread_pool> parallel_pool_2;
-	if (std::thread::hardware_concurrency() > 2)
-	{
-		auto thread_counts = std::thread::hardware_concurrency();
-		thread_group_count = thread_counts;
-		io_thread_count = (int)round(log2(thread_counts));
-	}
-
-	if (std::thread::hardware_concurrency() > 1)
-	{
-		parallel_pool_1 = std::make_unique<ttp::task_thread_pool>();
-		parallel_pool_2 = std::make_unique<ttp::task_thread_pool>();
-	}
-
-	ttp::task_group_pool task_groups{ thread_group_count };
-	task_pool_colloector task_pools =
-	{
-		.parallel_encryption_pool = parallel_pool_1.get(),
-		.parallel_decryption_pool = parallel_pool_2.get(),
-		.listener_parallels = parallel_pool_1.get(),
-		.forwarder_parallels = parallel_pool_2.get()
-	};
-
-	asio::io_context ioc{ io_thread_count };
+	//uint16_t thread_group_count = 2;
+	//int io_thread_count = std::thread::hardware_concurrency() == 1 ? 1 : 2;
+	//std::unique_ptr<ttp::task_thread_pool> parallel_pool_1;
+	//std::unique_ptr<ttp::task_thread_pool> parallel_pool_2;
+	//if (std::thread::hardware_concurrency() > 2)
+	//{
+	//	auto thread_counts = std::thread::hardware_concurrency();
+	//	thread_group_count = thread_counts;
+	//	io_thread_count = (int)round(log2(thread_counts));
+	//}
+
+	//if (std::thread::hardware_concurrency() > 1)
+	//{
+	//	parallel_pool_1 = std::make_unique<ttp::task_thread_pool>();
+	//	parallel_pool_2 = std::make_unique<ttp::task_thread_pool>();
+	//}
+
+	//ttp::task_group_pool task_groups{ thread_group_count };
+	//task_pool_colloector task_pools =
+	//{
+	//	.parallel_encryption_pool = parallel_pool_1.get(),
+	//	.parallel_decryption_pool = parallel_pool_2.get(),
+	//	.listener_parallels = parallel_pool_1.get(),
+	//	.forwarder_parallels = parallel_pool_2.get()
+	//};
+
+	//asio::io_context ioc{ io_thread_count };
+	asio::io_context ioc;
 
 	std::vector<client_mode> clients;
 	std::vector<relay_mode> relays;
@@ -117,13 +118,13 @@ int main(int argc, char *argv[])
 		switch (settings.mode)
 		{
 		case running_mode::client:
-			clients.emplace_back(client_mode(ioc, task_groups, task_pools, settings));
+			clients.emplace_back(client_mode(ioc, /*task_groups, task_pools,*/ settings));
 			break;
 		case running_mode::relay:
-			relays.emplace_back(relay_mode(ioc, task_groups, task_pools, settings));
+			relays.emplace_back(relay_mode(ioc, /*task_groups, task_pools,*/ settings));
 			break;
 		case running_mode::server:
-			servers.emplace_back(server_mode(ioc, task_groups, task_pools, settings));
+			servers.emplace_back(server_mode(ioc, /*task_groups, task_pools,*/ settings));
 			break;
 		default:
 			break;