Slot provide CTS on media and FEC packets as well

Author: baranovmv

src/internal_modules/roc_pipeline/sender_slot.cpp

@@ -142,13 +142,13 @@ status::StatusCode SenderSlot::refresh(core::nanoseconds_t current_time,
     status::StatusCode code = status::NoStatus;
 
     if (source_endpoint_) {
-        if ((code = source_endpoint_->pull_packets(0)) != status::StatusOK) {
+        if ((code = source_endpoint_->pull_packets(current_time)) != status::StatusOK) {
             return code;
         }
     }
 
     if (repair_endpoint_) {
-        if ((code = repair_endpoint_->pull_packets(0)) != status::StatusOK) {
+        if ((code = repair_endpoint_->pull_packets(current_time)) != status::StatusOK) {
             return code;
         }
     }

src/tests/roc_pipeline/test_loopback_sink_2_source.cpp

@@ -568,7 +568,7 @@ void send_receive(int flags,
     core::nanoseconds_t virtual_e2e_latency = 0;
 
     if (flags & FlagCTS) {
-        send_base_cts = 1000000000000000;
+        send_base_cts = core::timestamp(core::ClockUnix);
         virtual_e2e_latency = core::Millisecond * 100;
     }
 

src/tests/roc_pipeline/test_receiver_source.cpp

@@ -684,18 +684,19 @@ TEST(receiver_source, latency_lower_bound) {
 
     packet_writer.write_packets(1, SamplesPerPacket, packet_sample_spec);
     frame_reader.set_offset(0);
+    const core::nanoseconds_t base_cts = core::timestamp(core::ClockUnix);
 
     for (size_t np = 0; np < SmallTolerance / SamplesPerPacket; np++) {
         for (size_t nf = 0; nf < FramesPerPacket; nf++) {
-            refresh_source(receiver, frame_reader.refresh_ts());
+            refresh_source(receiver, frame_reader.refresh_ts(base_cts));
             frame_reader.read_samples(SamplesPerFrame, 1, output_sample_spec);
 
             UNSIGNED_LONGS_EQUAL(1, receiver.num_sessions());
         }
     }
 
     for (size_t nf = 0; nf < FramesPerPacket; nf++) {
-        refresh_source(receiver, frame_reader.refresh_ts());
+        refresh_source(receiver, frame_reader.refresh_ts(base_cts));
         frame_reader.read_any_samples(SamplesPerFrame, output_sample_spec);
     }