atsc_core_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_atsc1.h"
#include "atsc_core_atsc3_lls.h"
#include "atsc_core_common_serviceguide.h"
#include "atsc_core_atsc3_route_parser.h"
#include "atsc_core_utils_database.h"
#include "atsc_core_utils_dump_api.h"
#include "atsc_core_streamer_demodsender.h"
#include "atsc_core_streamer_ts2hlsmaker.h"
#include "atsc_mw_av_control.h"
 
class CCoreService{
public:
  CCoreService();
  ~CCoreService();
 
 
  int32_t ProcessAlpData(int32_t iCh, uint8_t *pData, uint32_t iDataLen);
 
 
  sServiceListTable_t GetSltServiceData( void );
  
  int32_t ProcessLLS(uint32_t iCh, uint8_t* pData, int32_t data_length);
 
  void StartOtherService( void );
 
  std::string GetGuideServiceInfo(char *sUri);
 
  std::string GetSystemTime( void );
 
  std::string GetOnScreenMsgNotify( void );
 
  sRrtDataTable_t GetRrt( void );
 
  bool DataBaseSelect(int32_t iType, char *pParam1);
 
  bool DataBaseDelete(int32_t iType, char *pParam1);
 
  std::list<sDownloadFileInfo_t> GetDataBaseFileInfo( void );
 
  size_t GetDataBaseHeldMsgSz( void );
 
  size_t GetDataBaseFileInfoSz( void );
 
  std::list<sHeldMsgProperties_t> GetDataBaseHeldMsgInfo( void );
 
  bool UpdateDataBase(int32_t iType, void *pParam1, void*pParam2);
 
  void GetUserServiceInfo( int32_t iServiceId , int32_t iPhyCh , int32_t iMajorCh , int32_t iMinorCh );
 
  std::map<int32_t, std::map<int32_t, sParser_t>> mServices;    
  std::map<std::string, sSubscribeDevice_t> mSubscribe;          
  CAvCtrl *mAvCtrl;                     
  CDatabase mDatabase;                  
  CDump mDumpApi;                       
  CDemodSender mDemodSender;            
  CTs2Hls mTs2Hls;                      
  sUserServiceInfo_t sUserServiceInfo;  
private:
     
    CLowLevelSignaling *mLLSService;                  
    CServiceGuide *mGuideService;                     
    bool mRunning;              
    bool mSubscribeEvent;       
    sNetworkInfo_t mNetwork;    
    std::thread *mStatusThread=nullptr;             
    std::thread *mSubscribeThread=nullptr;           
    std::queue <sDownloadFileInfo_t> mDownloadMsg;    
    std::queue <sServiceProperties_t> mEsgRemoveMsg;  
    std::queue <sSubscribeDevice_t> mSubscribeMsg;    
    std::queue <sHeldElement_t> mHeldMsg;             
    void CallbackRouteComponent(int32_t iSvcid, sRouteComponent_t *pComponent);
 
    void CallbackAppSignaling(int32_t type, void *info, const char* xml);
 
    void CallbackDownloadCompleted(sDownloadFileInfo_t stInfo);
 
    int32_t CreateService(int32_t iCh, sServiceListTable_t stSlt);
 
    void ThreadStatus(void);
 
    void GetSubscribeList(void);
 
    void ThreadSubscribe(void);
 
    void CallbackTvct(int32_t iId, int32_t iCh, sMpeg2Tvct_t sTvct);
};