dump

src/internal_modules/roc_pipeline/receiver_session_group.cpp

@@ -69,9 +69,9 @@ ReceiverSessionGroup::create_control_pipeline(ReceiverEndpoint* control_endpoint
     // We pass this as implementation of rtcp::IParticipant.
     // rtcp::Communicator will call our methods right now (in constructor)
     // and later when we call generate_packets() or process_packets().
-    rtcp_communicator_.reset(new (rtcp_communicator_) rtcp::Communicator(
-        source_config_.common.rtcp, *this, *control_endpoint->outbound_writer(),
-        *control_endpoint->outbound_composer(), packet_factory_, arena_));
+    rtcp_communicator_.reset(new(rtcp_communicator_) rtcp::Communicator(
+            source_config_.common.rtcp, *this, *control_endpoint->outbound_writer(),
+            *control_endpoint->outbound_composer(), packet_factory_, arena_, dumper_));
 
     const status::StatusCode code = rtcp_communicator_->init_status();
     if (code != status::StatusOK) {

src/internal_modules/roc_pipeline/sender_session.cpp

@@ -233,9 +233,9 @@ SenderSession::create_control_pipeline(SenderEndpoint* control_endpoint) {
 
     rtcp_outbound_addr_ = control_endpoint->outbound_address();
 
-    rtcp_communicator_.reset(new (rtcp_communicator_) rtcp::Communicator(
-        sink_config_.rtcp, *this, control_endpoint->outbound_writer(),
-        control_endpoint->outbound_composer(), packet_factory_, arena_));
+    rtcp_communicator_.reset(new(rtcp_communicator_) rtcp::Communicator(
+            sink_config_.rtcp, *this, control_endpoint->outbound_writer(),
+            control_endpoint->outbound_composer(), packet_factory_, arena_, dumper_));
 
     const status::StatusCode code = rtcp_communicator_->init_status();
     if (code != status::StatusOK) {

src/internal_modules/roc_rtcp/communicator.cpp

@@ -10,6 +10,7 @@
 #include "roc_core/log.h"
 #include "roc_core/panic.h"
 #include "roc_core/time.h"
+#include "roc_dbgio/csv_dumper.h"
 #include "roc_packet/ntp.h"
 #include "roc_packet/units.h"
 #include "roc_rtcp/headers.h"
@@ -25,17 +26,14 @@ const core::nanoseconds_t LogInterval = core::Second * 30;
 
 } // namespace
 
-Communicator::Communicator(const Config& config,
-                           IParticipant& participant,
-                           packet::IWriter& packet_writer,
-                           packet::IComposer& packet_composer,
-                           packet::PacketFactory& packet_factory,
-                           core::IArena& arena)
+Communicator::Communicator(const Config &config, IParticipant &participant, packet::IWriter &packet_writer,
+                           packet::IComposer &packet_composer, packet::PacketFactory &packet_factory,
+                           core::IArena &arena, dbgio::CsvDumper* dumper)
     : packet_factory_(packet_factory)
     , packet_writer_(packet_writer)
     , packet_composer_(packet_composer)
     , config_(config)
-    , reporter_(config, participant, arena)
+    , reporter_(config, participant, arena, dumper)
     , next_deadline_(0)
     , dest_addr_count_(0)
     , dest_addr_index_(0)
@@ -50,7 +48,8 @@ Communicator::Communicator(const Config& config,
     , processed_packet_count_(0)
     , generated_packet_count_(0)
     , log_limiter_(LogInterval)
-    , init_status_(status::NoStatus) {
+    , init_status_(status::NoStatus)
+    , dumper_(dumper) {
     if ((init_status_ = reporter_.init_status()) != status::StatusOK) {
         return;
     }

src/internal_modules/roc_rtcp/communicator.h

@@ -17,6 +17,7 @@
 #include "roc_core/rate_limiter.h"
 #include "roc_core/stddefs.h"
 #include "roc_core/time.h"
+#include "roc_dbgio/csv_dumper.h"
 #include "roc_packet/icomposer.h"
 #include "roc_packet/iwriter.h"
 #include "roc_packet/packet.h"
@@ -56,12 +57,9 @@ namespace rtcp {
 class Communicator : public core::NonCopyable<> {
 public:
     //! Initialize.
-    Communicator(const Config& config,
-                 IParticipant& participant,
-                 packet::IWriter& packet_writer,
-                 packet::IComposer& packet_composer,
-                 packet::PacketFactory& packet_factory,
-                 core::IArena& arena);
+    Communicator(const Config &config, IParticipant &participant, packet::IWriter &packet_writer,
+                 packet::IComposer &packet_composer, packet::PacketFactory &packet_factory,
+                 core::IArena &arena, dbgio::CsvDumper* dumper);
 
     //! Check if the object was successfully constructed.
     status::StatusCode init_status() const;
@@ -169,6 +167,8 @@ class Communicator : public core::NonCopyable<> {
     core::RateLimiter log_limiter_;
 
     status::StatusCode init_status_;
+
+    dbgio::CsvDumper* dumper_;
 };
 
 } // namespace rtcp

src/internal_modules/roc_rtcp/reporter.cpp

@@ -21,7 +21,7 @@
 namespace roc {
 namespace rtcp {
 
-Reporter::Reporter(const Config& config, IParticipant& participant, core::IArena& arena)
+Reporter::Reporter(const Config &config, IParticipant &participant, core::IArena &arena, dbgio::CsvDumper *dumper)
     : arena_(arena)
     , participant_(participant)
     , local_source_id_(0)
@@ -43,7 +43,8 @@ Reporter::Reporter(const Config& config, IParticipant& participant, core::IArena
     , report_time_(0)
     , config_(config)
     , max_delay_(packet::ntp_2_nanoseconds(header::MaxDelay))
-    , init_status_(status::NoStatus) {
+    , init_status_(status::NoStatus)
+    , dumper_(dumper) {
     memset(local_cname_, 0, sizeof(local_cname_));
 
     const ParticipantInfo part_info = participant_.participant_info();
@@ -1400,7 +1401,7 @@ Reporter::find_stream_(packet::stream_source_t source_id, CreateMode mode) {
                 (unsigned long)source_id);
 
         stream =
-            new (stream_pool_) Stream(stream_pool_, source_id, report_time_, config_.rtt);
+                new(stream_pool_) Stream(stream_pool_, source_id, report_time_, config_.rtt, dumper_);
         if (!stream) {
             report_error_ = status::StatusNoMem;
             return NULL;

src/internal_modules/roc_rtcp/reporter.h

@@ -34,6 +34,7 @@
 #include "roc_rtcp/rtt_estimator.h"
 #include "roc_rtcp/sdes.h"
 #include "roc_status/status_code.h"
+#include "roc_dbgio/csv_dumper.h"
 
 namespace roc {
 namespace rtcp {
@@ -90,7 +91,7 @@ namespace rtcp {
 class Reporter : public core::NonCopyable<> {
 public:
     //! Initialize.
-    Reporter(const Config& config, IParticipant& participant, core::IArena& arena);
+    Reporter(const Config &config, IParticipant &participant, core::IArena &arena, dbgio::CsvDumper *dumper);
     ~Reporter();
 
     //! Check if the object was successfully constructed.
@@ -261,16 +262,14 @@ class Reporter : public core::NonCopyable<> {
     struct Stream : core::RefCounted<Stream, core::PoolAllocation>,
                     core::HashmapNode<>,
                     core::ListNode<> {
-        Stream(core::IPool& pool,
-               packet::stream_source_t source_id,
-               core::nanoseconds_t report_time,
-               const RttConfig& rtt_config)
+        Stream(core::IPool &pool, packet::stream_source_t source_id, core::nanoseconds_t report_time,
+               const RttConfig &rtt_config, dbgio::CsvDumper *dumper)
             : core::RefCounted<Stream, core::PoolAllocation>(pool)
             , source_id(source_id)
             , has_remote_recv_report(false)
-            , remote_recv_rtt(rtt_config)
+            , remote_recv_rtt(rtt_config, dumper)
             , has_remote_send_report(false)
-            , remote_send_rtt(rtt_config)
+            , remote_send_rtt(rtt_config, dumper)
             , local_recv_report(NULL)
             , last_update(report_time)
             , last_local_sr(0)
@@ -483,6 +482,8 @@ class Reporter : public core::NonCopyable<> {
     const core::nanoseconds_t max_delay_;
 
     status::StatusCode init_status_;
+
+    dbgio::CsvDumper* dumper_;
 };
 
 } // namespace rtcp

src/internal_modules/roc_rtcp/rtt_estimator.cpp

@@ -12,12 +12,13 @@
 namespace roc {
 namespace rtcp {
 
-RttEstimator::RttEstimator(const RttConfig& config)
+RttEstimator::RttEstimator(const RttConfig &config, dbgio::CsvDumper *dumper)
     : config_(config)
     , metrics_()
     , has_metrics_(false)
     , first_report_ts_(0)
-    , last_report_ts_(0) {
+    , last_report_ts_(0)
+    , dumper_(dumper) {
 }
 
 bool RttEstimator::has_metrics() const {
@@ -89,6 +90,18 @@ void RttEstimator::update(core::nanoseconds_t local_report_ts,
     metrics_.rtt = rtt;
 
     has_metrics_ = true;
+
+    dump_();
+}
+
+void RttEstimator::dump_() {
+    dbgio::CsvEntry e;
+    e.type = 'r';
+    e.n_fields = 3;
+    e.fields[0] = core::timestamp(core::ClockUnix);
+    e.fields[1] = metrics_.rtt;
+    e.fields[2] = metrics_.clock_offset;
+    dumper_->write(e);
 }
 
 } // namespace rtcp

src/internal_modules/roc_rtcp/rtt_estimator.h

@@ -14,6 +14,7 @@
 
 #include "roc_core/time.h"
 #include "roc_packet/units.h"
+#include "roc_dbgio/csv_dumper.h"
 
 namespace roc {
 namespace rtcp {
@@ -51,7 +52,7 @@ struct RttMetrics {
 class RttEstimator {
 public:
     //! Initialize.
-    RttEstimator(const RttConfig& config);
+    RttEstimator(const RttConfig &config, dbgio::CsvDumper *dumper);
 
     //! Check whether metrics are already available.
     bool has_metrics() const;
@@ -71,12 +72,17 @@ class RttEstimator {
                 core::nanoseconds_t local_reply_ts);
 
 private:
+    void dump_();
+
     const RttConfig config_;
     RttMetrics metrics_;
     bool has_metrics_;
 
     core::nanoseconds_t first_report_ts_;
     core::nanoseconds_t last_report_ts_;
+
+    dbgio::CsvDumper *dumper_;
+
 };
 
 } // namespace rtcp