Skip to content

RDKEMW-15487 [Rialto][CPU] High CPU Usage of Rialto Server - Checkpoint4 #465

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
rekhap2kandhavelan wants to merge 2 commits into
base: master
Choose a base branch
from
Open

RDKEMW-15487 [Rialto][CPU] High CPU Usage of Rialto Server - Checkpoint4 #465

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
c4722f8
added debug print to trace high cpu
rkandh015 Mar 19, 2026
5f1a035
Merge branch 'master' into feature/RDKEMW-15487
rekhap2kandhavelan Apr 8, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions media/server/gstplayer/source/GstGenericPlayer.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
* limitations under the License.
*/

#include <atomic>
#include <chrono>
#include <cinttypes>
#include <cstring>
Expand Down Expand Up @@ -467,10 +468,23 @@ void GstGenericPlayer::setSourceFlushed(const MediaSourceType &mediaSourceType)

void GstGenericPlayer::notifyPlaybackInfo()
{
static std::atomic<int> notifyCount{0};
const int currentCount = ++notifyCount;
const auto start = std::chrono::steady_clock::now();
Comment on lines +471 to +473

PlaybackInfo info;
getPosition(info.currentPosition);
getVolume(info.volume);
m_gstPlayerClient->notifyPlaybackInfo(info);

const auto elapsed = std::chrono::duration_cast<std::chrono::microseconds>(
std::chrono::steady_clock::now() - start);

if ((currentCount % 1) == 0)
{
RIALTO_SERVER_LOG_INFO("notifyPlaybackInfo cycle %d took %lld us", currentCount,
static_cast<long long>(elapsed.count()));
}
Comment on lines +483 to +487
}

GstElement *GstGenericPlayer::getDecoder(const MediaSourceType &mediaSourceType)
Expand Down Expand Up @@ -2211,9 +2225,13 @@ void GstGenericPlayer::startNotifyPlaybackInfoTimer()
static constexpr std::chrono::milliseconds kPlaybackInfoTimerMs{32};
if (m_playbackInfoTimer && m_playbackInfoTimer->isActive())
{
RIALTO_SERVER_LOG_DEBUG("NotifyPlaybackInfoTimer already active, skipping start");
return;
}

RIALTO_SERVER_LOG_DEBUG("Starting NotifyPlaybackInfoTimer (interval %d ms)",
static_cast<int>(kPlaybackInfoTimerMs.count()));

notifyPlaybackInfo();

m_playbackInfoTimer =
Expand Down
1 change: 1 addition & 0 deletions media/server/gstplayer/source/tasks/generic/HandleBusMessage.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -76,6 +76,7 @@ void HandleBusMessage::execute() const
}
case GST_STATE_PAUSED:
{
RIALTO_SERVER_LOG_DEBUG("PAUSED state: starting notify playback info timer");
m_player.startNotifyPlaybackInfoTimer();
m_player.stopPositionReportingAndCheckAudioUnderflowTimer();
if (pending != GST_STATE_PAUSED)
Expand Down
Loading