CHANNEL LOGGING

pwojcikdev · Mar 12, 2024 · 002a09a · 002a09a
1 parent c5679d8
commit 002a09a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/nano/lib/logging.hpp b/nano/lib/logging.hpp
@@ -38,6 +38,12 @@ auto microseconds (std::chrono::time_point<Clock> time)
 {
 	return std::chrono::duration_cast<std::chrono::microseconds> (time.time_since_epoch ()).count ();
 }
+
+template <class Clock>
+auto milliseconds_delta (std::chrono::time_point<Clock> time, std::chrono::time_point<Clock> now = Clock::now ())
+{
+	return std::chrono::duration_cast<std::chrono::milliseconds> (time - now).count ();
+}
 }
 
 namespace nano

diff --git a/nano/node/transport/channel.cpp b/nano/node/transport/channel.cpp
@@ -65,8 +65,14 @@ nano::endpoint nano::transport::channel::get_peering_endpoint () const
 
 void nano::transport::channel::operator() (nano::object_stream & obs) const
 {
+	nano::lock_guard<nano::mutex> lk (channel_mutex);
+
 	obs.write ("endpoint", get_endpoint ());
 	obs.write ("peering_endpoint", get_peering_endpoint ());
 	obs.write ("node_id", get_node_id ().to_node_id ());
 	obs.write ("alive", alive ());
+
+	obs.write ("last_bootstrap_attempt", nano::log::milliseconds_delta (get_last_bootstrap_attempt ()));
+	obs.write ("last_packet_received", nano::log::milliseconds_delta (get_last_packet_received ()));
+	obs.write ("last_packet_sent", nano::log::milliseconds_delta (get_last_packet_sent ()));
 }