++

Author: Damir Zainullin

include/ipfixprobe/ipfix-elements.hpp

@@ -463,8 +463,7 @@ namespace ipxp {
 	F(MQTT_PUBLISH_FLAGS)                                                                          \
 	F(MQTT_TOPICS)
 
-#define IPFIX_TCP_RTT_TEMPLATE(F)                                                                     \
-	F(TCP_RTT)                                                                        \
+#define IPFIX_TCP_RTT_TEMPLATE(F) F(TCP_RTT)
 
 #define IPFIX_PSTATS_TEMPLATE(F)                                                                   \
 	F(STATS_PCKT_SIZES)                                                                            \

src/plugins/process/tcpRtt/src/tcpRtt.cpp

@@ -48,12 +48,10 @@ RecordExtTCPRTT* TCPRTTPlugin::get_ext() const
 	return new RecordExtTCPRTT(m_pluginID);
 }
 
-void TCPRTTPlugin::init([[maybe_unused]]const char* params)
-{
-}
+void TCPRTTPlugin::init([[maybe_unused]] const char* params) {}
 
 TCPRTTPlugin::TCPRTTPlugin(const TCPRTTPlugin& other) noexcept
-    : ProcessPlugin(other.m_pluginID)
+	: ProcessPlugin(other.m_pluginID)
 {
 }
 
@@ -64,45 +62,46 @@ ProcessPlugin* TCPRTTPlugin::copy()
 
 int TCPRTTPlugin::post_create(Flow& rec, const Packet& pkt)
 {
-    if (m_prealloced_extension == nullptr) {
+	if (m_prealloced_extension == nullptr) {
 		m_prealloced_extension.reset(get_ext());
 	}
 
-    if (pkt.ip_proto == IPPROTO_TCP) {
+	if (pkt.ip_proto == IPPROTO_TCP) {
 		rec.add_extension(m_prealloced_extension.release());
-    }
+	}
 
-    update_tcp_rtt_record(rec, pkt);
+	update_tcp_rtt_record(rec, pkt);
 	return 0;
 }
 
 int TCPRTTPlugin::pre_update(Flow& rec, Packet& pkt)
 {
-    update_tcp_rtt_record(rec, pkt);
+	update_tcp_rtt_record(rec, pkt);
 	return 0;
 }
 
 constexpr static inline bool is_tcp_syn(uint8_t tcp_flags) noexcept
 {
-    return tcp_flags & 0b10;
+	return tcp_flags & 0b10;
 }
 
 constexpr static inline bool is_tcp_syn_ack(uint8_t tcp_flags) noexcept
 {
-    return (tcp_flags & 0b10) && (tcp_flags & 0b10000);
+	return (tcp_flags & 0b10) && (tcp_flags & 0b10000);
 }
 
 void TCPRTTPlugin::update_tcp_rtt_record(Flow& rec, const Packet& pkt) noexcept
 {
 	auto* extension = static_cast<RecordExtTCPRTT*>(rec.get_extension(m_pluginID));
 
 	if (extension != nullptr && is_tcp_syn_ack(pkt.tcp_flags)) {
-        extension->tcp_synack_timestamp = pkt.ts;
+		extension->tcp_synack_timestamp = pkt.ts;
 	} else if (extension != nullptr && is_tcp_syn(pkt.tcp_flags)) {
-        extension->tcp_syn_timestamp = pkt.ts;
-    }
+		extension->tcp_syn_timestamp = pkt.ts;
+	}
 }
 
-static const PluginRegistrar<TCPRTTPlugin, ProcessPluginFactory> tcpRttRegistrar(tcpRttPluginManifest);
+static const PluginRegistrar<TCPRTTPlugin, ProcessPluginFactory>
+	tcpRttRegistrar(tcpRttPluginManifest);
 
-}
+} // namespace ipxp