atsc_core_atsc3_mmt_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 <stdio.h>
#include <cstdio>
#include <thread>
#include <queue>
#include <sys/time.h>
#include <functional>
#include <iostream>
#include <string>
#include <list>
#include <sys/stat.h>
#include <map>
#include <math.h>
 
#include "atsc_types.h"
#include "atsc_core_utils_network.h"
#include "atsc_core_streamer_hlsmaker.h"
#include "atsc_core_atsc3_mmt_mpubuflist.h"
#include "atsc_core_atsc3_signaling_types.h"
 
typedef struct
{
    CMpuBuf mpu;        
    CMpuBuf mfu;        
    CMpuBuf fragment;   
}sMpuBufProperties_t;
 
class CMmt
{
public:
    CMmt(const char* pHlsPath, const char* pDataPath, sSltService_t stService, int32_t iPhysicalCh);
 
    int32_t Parse(uint8_t* pData, uint32_t iDataLen);
 
    typedef std::function<void(sDownloadFileInfo_t)> funcDownloadDone;              
    typedef std::function<void(int32_t, void*, const char*)> funcAppSignal;         
    typedef std::function<void(int32_t, sRouteComponent_t*)> funcRouteComponent;    
    uint32_t GetServiceValue(eSltServiceType_t eSLTType);
 
    bool Compare(uint32_t iServiceId, uint32_t iDestinationIp, uint32_t iDestinationPort);
 
    void SetHandler(funcDownloadDone f1, funcAppSignal f2, funcRouteComponent f3);
 
    static void CallbackCompleteMp4(char* pPath,char *pFilename, uint32_t iPacketId, uint32_t iSeq,int32_t iSize, FLOAT_64 dDuration, void *pCtx)
    {
        CMmt* my_this = (CMmt*)pCtx;
        my_this->CallbackMp4(pPath, pFilename, iPacketId,  iSeq, iSize, dDuration);
    }
 
    int32_t GetMediaType( void );
 
private:
 
    int32_t ParseHeader(uint8_t* pData, int32_t iLen, int32_t iVer, sMpegMediaTransportHeader_t *stHeader);
 
    int32_t ParseMpu(uint8_t* pData, int32_t iLen, sMediaProcessingUnit_t*pMpu, sDataUnit_t *pDu);
 
    int32_t ParseHinttrack(uint8_t* pData, int32_t iLen, int32_t iIsTimed, sHintTrack_t* stHinttrack);
 
    int32_t ParseSignaling(uint8_t* pData, int32_t iLen, sMpegMediaTransportMsg_t* stMsg);
 
    int32_t CallbackMp4(char* pPath, char *pFilename, uint32_t iTsi, uint32_t iToi, int32_t iSize, FLOAT_64 dDuration);
 
    int32_t ParseMsg(uint8_t* pData, int32_t iDataLen, int32_t iMmtPacketId);
 
    std::list<sAssetProperties_t>m_asset_list;  
    std::map<uint32_t, CMpuBuf> mMpuFileMap;    
    sHeldElement_t mHeld;                   
    sUserServiceBundleDesc_t mUsbdDesc;     
    char mHlsDirectory[256];                
    char mBaseUrl[256];                     
    std::map<int32_t , sMpuTimeStampProperties_t> mTimestampCheckMap;   
    std::map<uint32_t,uint32_t>mMsgVersionMap;                          
    std::map<std::string, int32_t >mCodecType;                          
    CHLSMaker mHls;                                         
    std::list<sMpuTimeStampProperties_t> mTimestampList;    
    std::list<sGfdtDescriptor_t> mGfdtDescList;             
    funcDownloadDone mCbDownloadDone;       
    funcAppSignal mCbAppSignal;             
    funcRouteComponent mCbRouteComponent;   
    int32_t gfd_recv_cnt;                   
    uint32_t mServiceId;                    
    uint32_t mDestinationPort;              
    uint32_t mServiceCategory;              
    uint32_t mSourceIp;                     
    uint32_t mDestinationIp;                
    int32_t mVideoPacketId;                 
    FLOAT_64 mVideoDuration;                    
    uint32_t mDebugSeq;                     
    sMpegMediaTransportHeader_t mMMTHeader; 
};