TCP CHANNELS LOGGING

pwojcikdev · Mar 12, 2024 · 15e10e9 · 15e10e9
1 parent 5a3a1b1
commit 15e10e9
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/nano/lib/stats_enums.hpp b/nano/lib/stats_enums.hpp
@@ -159,6 +159,10 @@ enum class detail : uint8_t
 	node_id_handshake_network_error,
 	node_id_handshake_response_invalid,
 
+	// tcp_channels
+	channel_accepted,
+	channel_rejected,
+
 	// bootstrap, callback
 	initiate,
 	initiate_legacy_age,

diff --git a/nano/node/transport/tcp.cpp b/nano/node/transport/tcp.cpp
@@ -203,6 +203,8 @@ std::shared_ptr<nano::transport::channel_tcp> nano::transport::tcp_channels::cre
 
 		if (check (endpoint, node_id))
 		{
+			node.stats.inc (nano::stat::type::tcp_channels, nano::stat::detail::channel_accepted);
+
 			auto channel = std::make_shared<nano::transport::channel_tcp> (node, socket);
 			channel->set_endpoint ();
 			channel->set_node_id (node_id);
@@ -220,7 +222,10 @@ std::shared_ptr<nano::transport::channel_tcp> nano::transport::tcp_channels::cre
 		}
 		else
 		{
-			// TODO: Stat & log
+			node.stats.inc (nano::stat::type::tcp_channels, nano::stat::detail::channel_rejected);
+			node.logger.debug (nano::log::type::tcp_channels, "Rejected new channel from: {} ({})",
+			fmt::streamed (socket->remote_endpoint ()),
+			node_id.to_node_id ());
 		}
 	}
 	return nullptr;