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 index 1b0e76443..66aede479 100644 --- 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 index 132da2038..b3c22752f 100644 --- 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 index 7b016e39e..7b692d028 100644 --- 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;