ExternalSignalMonitor.cpp

Go to the documentation of this file.

// -*- Mode: c++ -*-
 
#include <cerrno>
#include <cstring>
 
#include <QtGlobal>
#if QT_VERSION >= QT_VERSION_CHECK(6,5,0)
#include <QtSystemDetection>
#endif
 
#include <fcntl.h>
#include <unistd.h>
#ifndef Q_OS_WINDOWS
#include <sys/select.h>
#endif
 
#include "libmythbase/mythdbcon.h"
#include "libmythbase/mythlogging.h"
 
#include "ExternalChannel.h"
#include "ExternalRecorder.h"
#include "ExternalSignalMonitor.h"
#include "ExternalStreamHandler.h"
#include "mpeg/atscstreamdata.h"
#include "mpeg/atsctables.h"
#include "mpeg/mpegtables.h"
 
#define LOC QString("ExternSigMon[%1](%2): ").arg(m_inputid).arg(m_loc)
 
ExternalSignalMonitor::ExternalSignalMonitor(int db_cardnum,
                                             ExternalChannel *_channel,
                                             bool _release_stream,
                                             uint64_t _flags)
    : DTVSignalMonitor(db_cardnum, _channel, _release_stream, _flags)
{
    LOG(VB_CHANNEL, LOG_INFO, LOC + "ctor");
    m_streamHandler = ExternalStreamHandler::Get(m_channel->GetDevice(),
                                                  m_channel->GetInputID(),
                                                  m_channel->GetMajorID());
    if (!m_streamHandler || m_streamHandler->HasError())
    {
        LOG(VB_GENERAL, LOG_ERR, LOC + "Open failed");
        if (m_streamHandler)
            ExternalStreamHandler::Return(m_streamHandler, m_inputid);
    }
    else
    {
        m_lockTimeout = GetLockTimeout();
    }
 
    ExternalChannel *channel = GetExternalChannel();
    if (channel && channel->IsBackgroundTuning())
        m_scriptStatus.SetValue(1);
}
 
ExternalSignalMonitor::~ExternalSignalMonitor()
{
    LOG(VB_CHANNEL, LOG_INFO, LOC + "dtor");
    ExternalSignalMonitor::Stop();
    if (m_streamHandler)
        ExternalStreamHandler::Return(m_streamHandler, m_inputid);
}
 
void ExternalSignalMonitor::Stop(void)
{
    LOG(VB_CHANNEL, LOG_INFO, LOC + "Stop() -- begin");
 
    SignalMonitor::Stop();
    if (GetStreamData())
    {
        m_streamHandler->StopStreaming();
        m_streamHandler->RemoveListener(GetStreamData());
    }
    m_streamHandlerStarted = false;
 
    LOG(VB_CHANNEL, LOG_INFO, LOC + "Stop() -- end");
}
 
void ExternalSignalMonitor::UpdateValues(void)
{
    if (!m_running || m_exit)
        return;
 
    ExternalChannel *channel = GetExternalChannel();
    if (channel == nullptr)
        return;
 
    if (channel->IsExternalChannelChangeInUse())
    {
        SignalMonitor::UpdateValues();
 
        QMutexLocker locker(&m_statusLock);
        if (!m_scriptStatus.IsGood())
            return;
    }
 
    if (channel->IsBackgroundTuning())
    {
        QMutexLocker locker(&m_statusLock);
        if (m_scriptStatus.GetValue() < 2)
            m_scriptStatus.SetValue(channel->GetTuneStatus());
 
        if (!m_scriptStatus.IsGood())
            return;
    }
 
    if (m_streamHandlerStarted)
    {
        if (!m_streamHandler->IsRunning())
        {
            m_error = QObject::tr("Error: stream handler died");
            LOG(VB_CHANNEL, LOG_ERR, LOC + m_error);
            m_updateDone = true;
            return;
        }
 
        EmitStatus();
        if (IsAllGood())
            SendMessageAllGood();
 
        m_updateDone = true;
        return;
    }
 
    AddFlags(kSigMon_WaitForSig);
 
    int strength   = GetSignalStrengthPercent();
    bool is_locked = HasLock();
 
    // Set SignalMonitorValues
    {
        QMutexLocker locker(&m_statusLock);
        m_signalStrength.SetValue(strength);
        m_signalLock.SetValue(static_cast<int>(is_locked));
    }
 
    EmitStatus();
    if (IsAllGood())
        SendMessageAllGood();
 
    // Start table monitoring if we are waiting on any table
    // and we have a lock.
    if (is_locked && GetStreamData() &&
        HasAnyFlag(kDTVSigMon_WaitForPAT | kDTVSigMon_WaitForPMT |
                   kDTVSigMon_WaitForMGT | kDTVSigMon_WaitForVCT |
                   kDTVSigMon_WaitForNIT | kDTVSigMon_WaitForSDT))
    {
        if (!m_streamHandlerStarted)
        {
            m_streamHandler->AddListener(GetStreamData());
            m_streamHandler->StartStreaming(false);
            m_streamHandlerStarted = true;
        }
    }
 
    m_updateDone = true;
}
 
bool ExternalSignalMonitor::HasLock(void)
{
    QString result;
 
    m_streamHandler->ProcessCommand("HasLock?", result);
    if (result.startsWith("OK:"))
    {
        return result.mid(3, 3) == "Yes";
    }
    LOG(VB_CHANNEL, LOG_ERR, LOC + QString
        ("HasLock: invalid response '%1'").arg(result));
    if (!result.startsWith("WARN"))
        m_error = QString("HasLock: invalid response '%1'").arg(result);
    return false;
}
 
int ExternalSignalMonitor::GetSignalStrengthPercent(void)
{
    QString result;
 
    m_streamHandler->ProcessCommand("SignalStrengthPercent?", result);
    if (result.startsWith("OK:"))
    {
        bool ok = false;
#if QT_VERSION < QT_VERSION_CHECK(6,0,0)
        int percent = result.midRef(3).toInt(&ok);
#else
        int percent = QStringView(result).mid(3).toInt(&ok);
#endif
        if (!ok)
        {
            LOG(VB_CHANNEL, LOG_ERR, LOC + QString
                ("GetSignalStrengthPercent: invalid response '%1'")
                .arg(result));
            return -1;
        }
        return percent;
    }
    LOG(VB_CHANNEL, LOG_ERR, LOC + QString
        ("GetSignalStrengthPercent: invalid response '%1'").arg(result));
    if (!result.startsWith("WARN"))
        m_error = QString("GetSignalStrengthPercent: invalid response '%1'")
                .arg(result);
    return -1;
}
 
std::chrono::seconds ExternalSignalMonitor::GetLockTimeout(void)
{
    QString result;
 
    m_streamHandler->ProcessCommand("LockTimeout?", result, 10s);
    if (result.startsWith("OK:"))
    {
        bool ok = false;
        auto timeout = std::chrono::seconds(result.mid(3).toInt(&ok));
        if (!ok)
        {
            LOG(VB_CHANNEL, LOG_ERR, LOC + QString
                ("GetLockTimeout: invalid response '%1'")
                .arg(result));
            return -1s;
        }
        return timeout;
    }
    LOG(VB_CHANNEL, LOG_ERR, LOC + QString
        ("GetLockTimeout: invalid response '%1'").arg(result));
    if (!result.startsWith("WARN"))
        m_error = QString("GetLockTimeout: invalid response '%1'").arg(result);
    return -1s;
}