atsc_mw_frontend_control.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 <thread>
#include <queue>
#include <sys/time.h>
#include <functional>
 
#include "atsc_types.h"
#include "atsc_plf_frontend_hwcontrol.h"
 
#define MAX_CHANNELS    80 
 
static const unsigned iFreqTable[eRegionMax][MAX_CHANNELS] =
{
    {   //0    1    2    3    4    5    6    7    8    9
        0,   0,  57,  63,  69,  79,  85, 177, 183, 189,     //   0~  9
        195, 201, 207, 213, 473, 479, 485, 491, 497, 503,   //  10~ 19
        509, 515, 521, 527, 533, 539, 545, 551, 557, 563,   //  20~ 29
        569, 575, 581, 587, 593, 599, 605, 611, 617, 623,   //  30~ 39
        629, 635, 641, 647, 653, 659, 665, 671, 677, 683,   //  40~ 49
        689, 695, 701, 707, 713, 719, 725, 731, 737, 743,   //  50~ 59
        749, 755, 761, 767, 773, 779, 785, 791, 797, 803,   //  60~ 69
        809, 815,   0,  0,   0,    0,   0,   0,   0,   0    //  70~ 79
    },
    {   //0    1    2    3    4    5    6    7    8    9
        0,   0,  57,  63,  69,  79,  85, 177, 183, 189,     //   0~  9
        195, 201, 207, 213, 473, 479, 485, 491, 497, 503,   //  10~ 19
        509, 515, 521, 527, 533, 539, 545, 551, 557, 563,   //  20~ 29
        569, 575, 581, 587, 593, 599, 605, 611, 617, 623,   //  30~ 39
        629, 635, 641, 647, 653, 659, 665, 671, 677, 683,   //  40~ 49
        689, 695, 701, 707, 756, 762, 768, 0,    0,  0,     //  50~ 59
        0,   0,   0,   0,   0 , 0  ,  0 ,  0 ,   0,  0,     //  60~ 69
        0,   0,   0,   0,   0 , 0  ,  0 ,  0 ,   0,  0      //  70~ 79
    },
    {// 0    1    2    3    4    5    6    7    8    9
        0,   0,   0,   0,   0,   0,   0,   0,   0,   0,     //   0~  9
        0,   0,   0,   0,   0,   0,   0,   0,   0,   0,     //  10~ 19
        0,   474, 482, 490, 498, 506, 514, 522, 530, 538,   //  20~ 29
        546, 554, 562, 570, 578, 586, 594, 602, 610, 618,   //  30~ 39
        626, 634, 642, 650, 658, 666, 674, 682, 690, 698,   //  40~ 49
        706, 714, 722, 730, 738, 746, 754, 762, 770, 778,   //  50~ 59
        786, 794, 802, 810, 818, 826, 834, 842, 850,  0 ,   //  60~ 69
        0,   0,   0,   0,   0 ,  0  ,  0 ,  0 ,   0,  0     //  70~ 79
    }
};
 
typedef struct{
    int32_t iPlp;      
    int32_t iDemod;    
    int32_t iTunerId;  
    uint32_t iCh;      
    uint8_t *pData;    
    uint32_t iLength;  
    void *pParent;     
}sFeData_t;
 
 
typedef std::function<void(sFeData_t*)> FeDataCbFunc;
 
typedef std::function<void(sFeStatus_t)> FeStatusCbFunc;
 
typedef std::function<void(sFeParams_t)> FeParamsCbFunc;
 
typedef std::function<void(sFeParams_t)> SystemTime;
 
class CFeCtrl
{
public:
    CFeCtrl(int32_t iId);
 
    CFeCtrl(int32_t iId, int32_t iDemodId, int32_t iCh, int32_t iPlpId,int32_t iRegionId);
 
    ~CFeCtrl();
 
    FeDataCbFunc   mFrontendDataCb;   
    FeStatusCbFunc mFrontendStatusCb; 
    FeParamsCbFunc mFrontendParamsCb; 
    int32_t Open( void);
 
    int32_t Stop(void);
 
    int32_t GetId(void);
 
    int32_t GetCh(void);
 
    int32_t Start(void);
 
    void Join(void);
 
    sFeProp_t GetProperties(void);
 
    int32_t GetProperties(sFeProp_t * pProp);
 
    int32_t GetStatus(sFeStatus_t* pStatus);
 
    int32_t GetFrontendInfo(sFeStatus_t *pStatus);
 
    int32_t TuneToChannel(int32_t iChNum,int32_t iDemodId, int32_t iPlp);
 
    int32_t ChangeProperties(int32_t iDemodId, int32_t iChNum, int32_t iPlpId,int32_t iRegionId);
 
    void SetCallback(void* ctx, void* pInfo_func, void* pRecv_func, void *pNotify_func);
 
    void SetHandler(FeDataCbFunc data, 
                    FeStatusCbFunc status, 
                    FeParamsCbFunc notify);
 
    FLOAT_64 TimeDiff(timespec start);
 
    void PutBitrate(int32_t iBitrate){
        m_Bitrate += iBitrate;
    }
 
    int32_t GetFreq(void){
        return m_Prop.iFreq;
    }
    
    int32_t GetDemodType(void){
        return m_Prop.iDemod;
    }
 
        int32_t GetDemod(void);
 
        int32_t GetFeLock(void);
 
        int32_t GetPlpId(void);
 
    void *mCtx;                   
    bool m_Running;               
    bool m_DataSkip;              
    timespec m_DataSkipTime;      
private:
    int32_t m_Id;               
    int32_t m_Bitrate;          
    int32_t m_AvgBitrate;       
    std::thread* mThread;       
    CFeHwCtrl * m_pFeHw;        
    sFeProp_t m_Prop;           
    sFeProp_t m_NewProp;        
    void FrontendThreadHandler(void);
    int32_t GetFreqForChannel(int32_t iChNum,eRegion_t iRegionId);
 
    int32_t GetChannelForFreq(int32_t iFreq, eRegion_t iRegionId);
 
};