Source Code for Demo Qt5 Recorder Control View Plugin

Location

./src/examples/src/adtf/system_services/gui/demo_recorder_control_view/

Build Environment

To see how to set up the build environment have a look at ADTF CMake Environment

this implementation shows:

• how to create a view within the Qt5 ADTF XSystem UI Service
• how to use the adtf::services::bat::IRecorder remote interface

Header

 
/*
 * This file depends on Qt which is licensed under LGPLv3.
 * See ADTF_DIR/3rdparty/qt5 and doc/license for detailed information.
 */
 
#ifndef _DEMO_RECORDER_CONTROL_VIEW_CLASS_HEADER_
#define _DEMO_RECORDER_CONTROL_VIEW_CLASS_HEADER_
 
class cRecorderControlViewSrv : public cQtUIService, public IRecorderControlView
{
    public:
        ADTF_CLASS_ID_NAME(cRecorderControlViewSrv, "demo_qt_recorder_control_view.ui_service.adtf.cid", "Demo Qt5 Recorder Control View");
        ADTF_CLASS_DEPENDENCIES(REQUIRE_INTERFACE(adtf::ui::IQtXSystem));
 
    protected:
        cRecorderControlWidget* m_pWidget;
        std::map<cString, object_ptr<adtf::services::IRecorder>> m_mapRecorders;
 
        tTimeStamp m_tmLastUpdate = 0;
        tTimeStamp m_tmMinInterval = 200000;
 
    public:
        cRecorderControlViewSrv();
 
        tResult ServiceEvent(int nEventId,
                             uint32_t ui32Param1 = 0,
                             uint32_t ui32Param2 = 0,
                             void* pvData = nullptr,
                             int szData = 0) override;
                             
 
    protected:
        QWidget* CreateView() override;
        void    ReleaseView() override;
        tResult  OnIdle() override;
 
    public:
        void StartRecording(const QString& strRecorderName) override;
        void StopRecording(const QString& strRecorderName) override;
        void SplitRecording(const QString& strRecorderName) override;
 
};
 
#endif // _DEMO_RECORDER_CONTROL_VIEW_CLASS_HEADER_

Implementation

 
/*
 * This file depends on Qt which is licensed under LGPLv3.
 * See ADTF_DIR/3rdparty/qt5 and doc/license for detailed information.
 */
 
#include "stdafx.h"
#include "demo_rec_ctrl_widget.h"
#include "demo_rec_ctrl_view.h"
 
ADTF_PLUGIN("Demo Qt5 Recorder Control View Plugin", cRecorderControlViewSrv);
 
#ifdef GetObject
#undef GetObject
#endif
 
#ifdef GetCurrentTime
#undef GetCurrentTime
#endif
 
void show_result(QWidget* pWidget, tResult nRes)
{
    LOG_RESULT(nRes);
    QMessageBox::critical(pWidget,
                          cString::Format("Error %d - [%s] ", nRes.GetErrorCode().value, nRes.GetErrorString()).GetPtr(),
                          nRes.GetDescription());
}
 
tResult local_set_run_level(QWidget* pWidget, tADTFRunLevel eLevel)
{
    tResult nRes = _runtime->SetRunLevel(eLevel);
    if (IS_FAILED(nRes))
    {
        show_result(pWidget, nRes);
    }
    return nRes;
}
 
 
cRecorderControlViewSrv::cRecorderControlViewSrv()
{
    m_strTitle = cString("Demo Recorder Control");
    m_pWidget = nullptr;
    SetDefaultRunlevel(tADTFRunLevel::RL_StreamingGraph);
 
    // sets a short description for the component
    SetDescription("Use this UI Service to extend the ADTF System with a User Interface to control the ADTFDAT File Recorder.");
 
    // set help link to jump to documentation from ADTF Configuration Editor
    SetHelpLink("$(ADTF_DIR)/doc/adtf_html/page_demo_recorder_control_view.html");
}
 
QWidget* cRecorderControlViewSrv::CreateView()
{
    m_pWidget = new cRecorderControlWidget(nullptr, *this);
    return m_pWidget;
}
 
void cRecorderControlViewSrv::ReleaseView()
{
    delete m_pWidget;
    m_pWidget = nullptr;
}
 
tResult cRecorderControlViewSrv::OnIdle()
{
    RETURN_IF_POINTER_NULL(m_pWidget);
 
    if (cHighResTimer::GetTime() - m_tmLastUpdate < m_tmMinInterval)
    {
        RETURN_ERROR(ERR_NOERROR);
    }
 
    if (m_pWidget)
    {
        std::list<tRecorderInfo> lstInfo;
        if (!m_mapRecorders.empty())
        {
            for (auto it : m_mapRecorders)
            {
                tRecorderInfo sInfo;
                sInfo.eState  = it.second->GetCurrentState();
                it.second->GetCurrentFileName(adtf_string_intf(sInfo.strFile));
                sInfo.strRecorderName = it.first.GetPtr();
                lstInfo.push_back(sInfo);
            }
        }
 
        m_pWidget->Update(lstInfo);
    }
    m_tmLastUpdate = cHighResTimer::GetTime();
    RETURN_NOERROR;
}
 
tResult cRecorderControlViewSrv::ServiceEvent(int nEventId,
                                              uint32_t ui32Param1,
                                              uint32_t ui32Param2,
                                              void* pvData,
                                              int szData)
{
    if (nEventId == IService::SE_ChangeRunLevel)
    {
        if (ui32Param2 == IRuntime::CRLF_PostIncrementLevel ||
            ui32Param2 == IRuntime::CRLF_PostDecrementLevel)
        {
            m_mapRecorders.clear();
            //we do not synchronize this since ServiceEvent is always called within main context!
            //OnIdle is within GUI context too
            object_list<adtf::services::IRecorder> lstRecorder;
            adtf::services::get_recorders(lstRecorder);
 
            int nIdx = 0;
            for (auto it : lstRecorder)
            {
                cString strRecorderName;
                INamedGraphObject* pNamedObject = ucom_cast<INamedGraphObject*>(it.Get());
                if (pNamedObject)
                {
                    strRecorderName = get_named_graph_object_full_name(*pNamedObject);
                }
                else
                {
 
                    strRecorderName = cString::Format("Recorder_index_%d", ++nIdx);
                }
                m_mapRecorders[strRecorderName] = it;
            }
 
        }
    }
    return cQtUIService::ServiceEvent(nEventId, ui32Param1, ui32Param2, pvData, szData);
}
 
 
void cRecorderControlViewSrv::StartRecording(const QString& strRecorderName)
{
    auto itRecorder = m_mapRecorders.find(cString(static_cast<const char*>(strRecorderName.toUtf8())));
    if (itRecorder != m_mapRecorders.end())
    {
        itRecorder->second->Start("");
    }
}
 
void cRecorderControlViewSrv::StopRecording(const QString& strRecorderName)
{
    auto itRecorder = m_mapRecorders.find(cString(static_cast<const char*>(strRecorderName.toUtf8())));
    if (itRecorder != m_mapRecorders.end())
    {
        itRecorder->second->Stop("");
    }
}
 
void cRecorderControlViewSrv::SplitRecording(const QString& strRecorderName)
{
    auto itRecorder = m_mapRecorders.find(cString(static_cast<const char*>(strRecorderName.toUtf8())));
    if (itRecorder != m_mapRecorders.end())
    {
        itRecorder->second->Split("");
    }
}