fmt

roc-streaming · Dec 19, 2024 · a475567 · a475567
1 parent 9c839bb
commit a475567
Show file tree

Hide file tree

Showing 4 changed files with 130 additions and 72 deletions.
diff --git a/src/tests/roc_pipeline/test_helpers/control_writer.h b/src/tests/roc_pipeline/test_helpers/control_writer.h
@@ -45,8 +45,7 @@ class ControlWriter : public core::NonCopyable<> {
         , cname_("test_cname") {
     }
 
-    void write_sender_report(core::nanoseconds_t  ts,
-                             packet::stream_timestamp_t rtp_ts) {
+    void write_sender_report(core::nanoseconds_t ts, packet::stream_timestamp_t rtp_ts) {
         core::Slice<uint8_t> buff = packet_factory_.new_packet_buffer();
         CHECK(buff);
 

diff --git a/src/tests/roc_pipeline/test_helpers/frame_reader.h b/src/tests/roc_pipeline/test_helpers/frame_reader.h
@@ -251,7 +251,7 @@ class FrameReader : public core::NonCopyable<> {
     }
 
 private:
-    audio::FramePtr read_frame_(status::StatusCode expected_status,
+    audio::FramePtr gread_frame_(status::StatusCode expected_status,
                                 size_t requested_samples,
                                 const audio::SampleSpec& sample_spec,
                                 audio::FrameReadMode read_mode) {

diff --git a/src/tests/roc_pipeline/test_sender_sink.cpp b/src/tests/roc_pipeline/test_sender_sink.cpp
@@ -660,8 +660,8 @@ TEST(sender_sink, metrics_feedback) {
         control_writer.set_link_metrics(link_metrics);
         control_writer.set_latency_metrics(latency_metrics);
 
-        control_writer.write_receiver_report(
-            frame_writer.refresh_ts(), packet_sample_spec);
+        control_writer.write_receiver_report(frame_writer.refresh_ts(),
+                                             packet_sample_spec);
 
         for (size_t nf = 0; nf < FramesPerPacket; nf++) {
             frame_writer.write_samples(SamplesPerFrame, input_sample_spec, unix_base);
@@ -821,8 +821,8 @@ TEST(sender_sink, reports_one_receiver) {
 
     for (size_t np = 0; np < (ReportInterval / SamplesPerPacket) * ManyReports; np++) {
         if (np % (ReportInterval / SamplesPerPacket) == 0) {
-            control_writer.write_receiver_report(
-                frame_writer.refresh_ts(), packet_sample_spec);
+            control_writer.write_receiver_report(frame_writer.refresh_ts(),
+                                                 packet_sample_spec);
         }
 
         for (size_t nf = 0; nf < FramesPerPacket; nf++) {
@@ -915,10 +915,10 @@ TEST(sender_sink, reports_two_receivers) {
 
     for (size_t np = 0; np < (ReportInterval / SamplesPerPacket) * ManyReports; np++) {
         if (np % (ReportInterval / SamplesPerPacket) == 0) {
-            control_writer1.write_receiver_report(
-                frame_writer.refresh_ts(), packet_sample_spec);
-            control_writer2.write_receiver_report(
-                frame_writer.refresh_ts(), packet_sample_spec);
+            control_writer1.write_receiver_report(frame_writer.refresh_ts(),
+                                                  packet_sample_spec);
+            control_writer2.write_receiver_report(frame_writer.refresh_ts(),
+                                                  packet_sample_spec);
         }
 
         for (size_t nf = 0; nf < FramesPerPacket; nf++) {