atsc_core_atsc3_route_parser.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 <iostream>
#include <string>
#include <list>
#include <cstdio>
#include <sys/stat.h>
#include <map>
 
#include "atsc_core_streamer_hlsmaker.h"
#include "atsc_core_atsc3_route_dashbuflist.h"
#include "atsc_types.h"
 
// ESG (Eletronic Service Guide)
// IBB (Integrated Broadcast Broadband)
//
// ESG - SGDD(Service Guide Delivery Descriptor)
//     L SGDU(Service Guide Delivery Unit)
//
// SGDU - Service Fragment
//      L Content Fragment
//      L Schedule Fragment
//
 
typedef struct{
    int32_t iDataLen;       
    uint8_t *pData;         
    uint32_t iTsi;          
    uint32_t iToi;          
    uint32_t iOffset;       
    uint32_t iTotalSize;    
}sRouteParamLite_t;
 
typedef struct{
    uint32_t iType;         
    uint32_t iServiceId;    
    uint32_t iCategory;     
    uint32_t iMsg;          
}sRouteSignaling_t;
 
typedef enum{
    eRouteSignallingMsgEsgUpdate = 0,   
}eRouteSignallingMsg_t;
 
typedef std::function<void(sDownloadFileInfo_t)> funcDownloadDone;
 
typedef std::function<void(int32_t, void*, const char*)> funcAppSignal;
 
class CRoute
{
public:
 
    CRoute( const char* pHlsPath, const char* pDataPath, sSltService_t stService, int32_t iPhysicalCh );
 
    ~CRoute();
 
    sRouteParseResult_t Parse(uint8_t* pData, int32_t iDataLen);
 
    uint32_t GetServiceValue(eSltServiceType_t eSltType);
 
    void DownloadDone(sSessionFileProperties_t properties, sTransportSessionId_t session);
 
    void SetHandler(funcDownloadDone f1, funcAppSignal f2);
 
    void SetAppContextId( char *pContextId, char *pPackageUrl );
 
    bool ClearDownloadStatus( void );
 
    std::list<sEfdtFile_t> GetProgress(void);
 
    std::string GetBaseUrl( void );
 
    int32_t GetMediaType( void );
private:
 
    void ProcessNRTData(sSessionFileProperties_t properties, sTransportSessionId_t session);
 
    void ProcessAVData(sSessionFileProperties_t properties, sTransportSessionId_t session);
 
    int32_t ParseSls(uint8_t *pData, int32_t iDataLen, uint32_t iTsi, uint32_t iToi);
 
    int32_t WriteSLS(sRouteParamLite_t param);
 
    int32_t WriteData(sRouteParamLite_t param);
 
    int32_t UpdateDataSession( void );
 
    bool IsReceived(uint32_t iTsi, uint32_t iToi);
 
    bool SetReceived(uint32_t iTsi, uint32_t iToi);
 
    void SaveMsg(uint8_t* pData,int32_t iDataLen,  uint32_t iTsi, uint32_t iToi, char* pContentLocation);
 
    funcDownloadDone mCbDownloadDone;   
    funcAppSignal mCbAppSignal;         
    sMediaPresentationDesc_t mMpd;                  
    sServiceTransportSessionInstanceDesc_t mStsid;  
    sMetadataEnvelope_t mEnvelope;                  
    sHeldElement_t mHeld;                           
    CHLSMaker mHls;                                 
    std::map<uint32_t , CSessionBuf*> mSession;             
    std::map<std::string, int32_t> mContentTypeMap;         
    std::list<std::string> mContentTypeList;                
    std::map<std::string, uint32_t > mSignalingVersionMap;  
    std::map<std::string, std::string>mAppContextIdMap;     
    std::map<std::string, std::string> mSignalingMap;       
    std::map<uint32_t , std::map<uint32_t , bool>> mReceivedMap;    
    std::map<uint32_t , std::map<uint32_t ,sEfdtFile_t>> mNrtFiles; 
    char mHlsDirectory[256];    
    char mBaseUrl[256];         
    char mSlsFdtData[65535];    
    char mSlsData[65535];       
    uint32_t mServiceId;        
    uint32_t mDestinationPort;  
    uint32_t mServiceCategory;  
    uint32_t mSourceIp;         
    uint32_t mDestinationIp;    
    uint32_t mSlsToi;           
    timespec mFileCleanUpTime;  
};