Top ports - update input plugin base class

Author: Zadamsa

include/ipfixprobe/inputPlugin.hpp

@@ -92,7 +92,7 @@ class IPXP_API InputPlugin
 	};
 
 	/// Statistics related to packet parsing.
-	ParserStats m_parser_stats = {};
+	ParserStats m_parser_stats{10};
 
 private:
 	void create_parser_stats_telemetry(std::shared_ptr<telemetry::Directory> queues_dir);

include/ipfixprobe/parser-stats.hpp

@@ -25,6 +25,8 @@
 
 #pragma once
 
+#include "../../src/plugins/input/parser/topPorts.hpp"
+
 #include <cstdint>
 
 namespace ipxp {
@@ -33,6 +35,22 @@ namespace ipxp {
  * \brief Structure for storing parser statistics.
  */
 struct ParserStats {
+
+	ParserStats(size_t top_ports_count)
+		: top_ports(top_ports_count)
+		, mpls_packets(0)
+		, vlan_packets(0)
+		, pppoe_packets(0)
+		, trill_packets(0)
+		, ipv4_packets(0)
+		, ipv6_packets(0)
+		, tcp_packets(0)
+		, udp_packets(0)
+		, seen_packets(0)
+		, unknown_packets(0) {}
+		
+	TopPorts top_ports;
+
 	uint64_t mpls_packets;
 	uint64_t vlan_packets;
 	uint64_t pppoe_packets;

src/core/CMakeLists.txt

@@ -32,6 +32,7 @@ target_link_libraries(ipfixprobe-core
 	atomic::atomic
 	unwind::unwind
 	${CMAKE_DL_LIBS}
+	top-ports
 )
 
 add_executable(ipfixprobe main.cpp)

src/core/inputPlugin.cpp

@@ -13,6 +13,8 @@
  * SPDX-License-Identifier: BSD-3-Clause
  */
 
+#include <numeric>
+
 #include <ipfixprobe/inputPlugin.hpp>
 
 namespace ipxp {
@@ -34,6 +36,16 @@ static telemetry::Content get_parser_stats_content(const ParserStats& parserStat
 	dict["seen_packets"] = parserStats.seen_packets;
 	dict["unknown_packets"] = parserStats.unknown_packets;
 
+	const std::vector<TopPorts::PortStats>& ports = parserStats.top_ports.get_top_ports();
+	if (ports.empty()) {
+		dict["top_10_ports"] = "";
+    } else {
+		std::string top_ports = ports[0].to_string();
+		dict["top_10_ports"] = std::accumulate(ports.begin() + 1, ports.end(), top_ports, 
+		[](std::string acc, const TopPorts::PortStats& port_frequency) {
+			return acc + ", " + port_frequency.to_string();
+		});
+    }
 	return dict;
 }