DUMP

nano/lib/object_stream.hpp

@@ -281,7 +281,7 @@ class array_stream : private object_stream_base
 
 	array_stream (array_stream const &) = delete; // Disallow copying
 
-private:
+public:
 	template <class Value>
 	void write_single (Value const & value)
 	{
@@ -290,7 +290,6 @@ class array_stream : private object_stream_base
 		ctx.end_array_element ();
 	}
 
-public:
 	// Handle `.write (container)`
 	template <class Container>
 	void write (Container const & container)

nano/node/blockprocessor.cpp

@@ -303,7 +303,11 @@ auto nano::block_processor::process_batch (nano::unique_lock<nano::mutex> & lock
 
 	lock_a.lock ();
 
-	queue.periodic_update ();
+	bool updated = queue.periodic_update ();
+	if (updated)
+	{
+		node.logger.info (nano::log::type::test, "Fair queue: {}", nano::streamed (queue));
+	}
 
 	timer_l.start ();
 

nano/node/fair_queue.hpp

@@ -1,5 +1,7 @@
 #pragma once
 
+#include <nano/lib/object_stream.hpp>
+#include <nano/lib/object_stream_adapters.hpp>
 #include <nano/lib/utility.hpp>
 #include <nano/node/transport/channel.hpp>
 
@@ -43,6 +45,18 @@ class fair_queue final
 		}
 
 		auto operator<=> (origin const &) const = default;
+
+		void operator() (nano::object_stream & obs) const
+		{
+			obs.write ("source", source);
+
+			if (channel)
+			{
+				obs.write ("channel", channel);
+				obs.write ("channel_ptr", channel.get ());
+				obs.write ("channel_ref_count", channel.use_count ());
+			}
+		}
 	};
 
 private:
@@ -88,6 +102,13 @@ class fair_queue final
 		{
 			return requests.size ();
 		}
+
+		void operator() (nano::object_stream & obs) const
+		{
+			obs.write ("priority", priority);
+			obs.write ("max_size", max_size);
+			obs.write ("requests", requests.size ());
+		}
 	};
 
 public:
@@ -286,5 +307,13 @@ class fair_queue final
 		composite->add_component (std::make_unique<container_info_leaf> (container_info{ "total_size", total_size (), sizeof (typename decltype (queues)::value_type) }));
 		return composite;
 	}
+
+	void operator() (nano::object_stream & obs) const
+	{
+		obs.write_range ("queues", queues, [] (auto const & entry, nano::object_stream & obs) {
+			obs.write ("source", entry.first);
+			obs.write ("queue", entry.second);
+		});
+	}
 };
 }

nano/node/transport/channel.cpp

@@ -68,4 +68,5 @@ void nano::transport::channel::operator() (nano::object_stream & obs) const
 	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 ());
 }