SCHED_RR for network io

baranovmv · Dec 3, 2024 · cac69bb · cac69bb
1 parent 212c322
commit cac69bb
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/src/internal_modules/roc_core/target_posix/roc_core/thread.cpp b/src/internal_modules/roc_core/target_posix/roc_core/thread.cpp
@@ -57,6 +57,7 @@ bool Thread::enable_realtime() {
                 errno_to_str(err).c_str());
         return false;
     }
+    roc_log(LogDebug, "thread: set realtime priority");
 
     return true;
 }

diff --git a/src/internal_modules/roc_netio/target_libuv/roc_netio/network_loop.cpp b/src/internal_modules/roc_netio/target_libuv/roc_netio/network_loop.cpp
@@ -140,6 +140,7 @@ NetworkLoop::NetworkLoop(core::IPool& packet_pool,
     task_sem_.data = this;
     task_sem_initialized_ = true;
 
+    enable_realtime();
     if (!(started_ = Thread::start())) {
         init_status_ = status::StatusErrThread;
         return;

diff --git a/src/internal_modules/roc_rtcp/rtt_estimator.cpp b/src/internal_modules/roc_rtcp/rtt_estimator.cpp
@@ -93,10 +93,10 @@ void RttEstimator::update(core::nanoseconds_t local_report_ts,
     rtt_stats_.add(p);
     RttOffsetPair min = rtt_stats_.mov_min();
 
-    metrics_.clock_offset = clock_offset;
-    metrics_.rtt = rtt;
-//    metrics_.clock_offset = min.offset;
-//    metrics_.rtt = min.rtt;
+//    metrics_.clock_offset = clock_offset;
+//    metrics_.rtt = rtt;
+    metrics_.clock_offset = min.offset;
+    metrics_.rtt = min.rtt;
 
     has_metrics_ = true;