atsc_mw_service.h

Go to the documentation of this file.

/*******************************************************************************
  * Copyright © 2014 The DTVKit Open Software Foundation Ltd (www.dtvkit.org)
  *
  * This file is part of a DTVKit Software Component
  * You are permitted to copy, modify or distribute this file subject to the terms
  * of the DTVKit 1.0 Licence which can be found in licence.txt or at www.dtvkit.org
  *
  * THIS CODE AND INFORMATION ARE PROVIDED "AS IS" WITHOUT WARRANTY OF ANY KIND,
  * EITHER EXPRESSED OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE IMPLIED WARRANTIES
  * OF MERCHANTABILITY AND/OR FITNESS FOR A PARTICULAR PURPOSE.
  *
  * If you or your organisation is not a member of DTVKit then you have access
  * to this source code outside of the terms of the licence agreement
  * and you are expected to delete this and any associated files immediately.
  * Further information on DTVKit, membership and terms can be found at www.dtvkit.org
  *******************************************************************************/
 
#pragma once
#include <pthread.h>
#include <mutex>
 
#include "atsc_types.h"
#include "atsc_core_utils_json.h"
#include "atsc_mw_frontend_control.h"
#include "atsc_core.h"
 
typedef struct {
    uint32_t iSize;         
    uint8_t cCh;            
    uint8_t sData[2048];    
}sAlpBuffer_t;
 
typedef struct {
    int32_t iStartCh;       
    int32_t iEndCh;         
    int32_t iPlpId;         
    int32_t iTunerId;       
    eDemod_t iDemod;        
    eRegion_t iRegionId;    
}sFeScan_t;
 
 
class CMwService{
public:
  CMwService();
 
  ~CMwService();
 
  int32_t GetSupportedStandards(void);
 
  int32_t GetAvailNoOfFrontendInstances(void);
 
  eATSCResult_t SetRegion(eRegion_t iRegion);
 
  eRegion_t GetRegion(void);
 
  eATSCResult_t SetDemod(eDemod_t iDemod);
 
  eDemod_t GetDemod( void );
 
  eATSCResult_t Frontend_TuneToChannel(int32_t iId,int32_t iCh,int32_t iPlp,
                                        eDemod_t iDemod,eRegion_t iRegion);
            
  eATSCResult_t Frontend_TuneToChannel( int32_t iId, int32_t iCh,int32_t iPlp);
 
  eATSCResult_t Frontend_ScanChannels(int32_t iTunerId, int32_t iStartCh,
                                    int32_t iEndCh, int32_t iDemod , int32_t iPlpId);
 
  eATSCResult_t Frontend_ScanChannels(int32_t iId, int32_t iStartCh,
                             int32_t iEndCh,int32_t iDemod,int32_t iPlp,
                             int32_t iRegion);
  eATSCResult_t Frontend_StopChannelScan(int32_t iId);
 
  eATSCResult_t Frontend_Start(int32_t iId);
 
  eATSCResult_t Frontend_Stop(int32_t iId);
 
 
  eATSCResult_t Frontend_GetProperties( int32_t iId,sFeProp_t *pProps );
 
 
  eATSCResult_t Frontend_GetStatus( int32_t iId , sFeStatus_t *pStatus );
 
 
  eATSCResult_t Frontend_RegisterStatusEventCb(FeStatusCbFunc fStatusPtr);
 
  eATSCResult_t Frontend_RegisterParamEventCb(FeParamsCbFunc ptrfunc);
 
  sServiceListTable_t GetSltServiceData( void );
 
  bool mScanning;                 
  std::string GetQueryHttpResponse( std::string sContentData );
 
  std::string GetGuideInfo(char *sUri);
 
  std::string GetTunerInfo(sFeStatus_t *pStatus,int32_t iTunerId);
 
  std::string GetTunersInfo( void );
 
  std::string GetVersion( char *pVersion );
 
  std::string GetPrepareTunerInfo(int32_t iInstance , sFeStatus_t *pStatus);
 
  std::string GetDumpHistory(void);
 
  std::string RequestMWService(std::string sUri, char *pContentData);
 
  std::string RequestMWDump(std::string sUri, int32_t iHttpType);
 
  std::string MwRequestTuners(std::string sUri, char *pContentData);
 
  std::string MwRequestUserService(std::string sUri, char *pContentData );
 
  std::string MwRequestScan(std::string sUri, char *pContentData);
 
  void StartScan(sScanScenario_t *scenario);
 
  void StopScan( void );
 
  Json::Value GetScanningInfo( void );
 
  std::list<sScanResult_t> GetScanningStatus( void );
 
  void ThreadScan();
 
  std::string GetSystemTime( void );
 
  sRrtDataTable_t GetRrt( void );
 
  void RegisterOnsnEventNotify(OnScreenNotify fParamsPtr);
 
  std::string GetFrontendConfiguration( void );
 
  void GetUserServiceInfo( int32_t iServiceId , int32_t iPhyCh , int32_t iMajorCh , int32_t iMinorCh );
 
  bool ChannelBasedTune(  int32_t iUserCh );
 
private:
    bool mRunning;                  
    int32_t mTunerId;
    int32_t mInstances;             
    int32_t mChannel;               
    eRegion_t mRegion;              
    eDemod_t mDemod;                
    sFeStatus_t mTunerInfo[16];     
    std::thread *mAlpThread;        
    std::thread *mScanThread;       
    std::recursive_mutex mMut;      
    std::queue<sAlpBuffer_t> mAlpQueue;  
    std::map<uint32_t, CFeCtrl*>mTunerCtrl; 
    FeStatusCbFunc mFrontendStatusCb = nullptr;    
    FeParamsCbFunc mFrontendParamsCb = nullptr;    
    OnScreenNotify mOnScreenNotify = nullptr;      
    CAtscCore *mAtscCore;                
    sScanScenario_t mScanScenario;        
    std::list<sScanResult_t> mScanResult; 
    eScanResult scanstatus;               
    std::thread *mSystemTimeThread;       
//private methods
  eATSCResult_t OpenFrontend(int32_t iCount);
 
    eATSCResult_t StartService(void);
 
  void Frontend_CbDataEvent(sFeData_t *pData);
 
  void Frontend_CbNotifyEvent(sFeParams_t notify);
 
  void Frontend_CbStatusEvent( sFeStatus_t status);
 
  eATSCResult_t GetAlpData(uint8_t *pData, uint32_t *pSize, uint32_t *pCh);
 
  int32_t ProcessAlpData(int32_t iCh, uint8_t *pData, uint32_t iDataLen);
  
  void AlpDataHandlerThread( void );
 
  void ChannelScanHandlerThread( void );
 
  void ThreadOnscrenNotify(void);
};