atsc_plf_frontend_hwcontrol.h

Go to the documentation of this file.

#ifndef ATSC_PLF_FRONTEND_HWCONTROL_H_
#define ATSC_PLF_FRONTEND_HWCONTROL_H_
 
#include <stdbool.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h>
#include <termios.h>
#include <fcntl.h>
#include <thread>
#include <poll.h>
 
#include "atsc_basetype.h"
 
#define FRONTEND_MODE_ATSC_10          0
 
#define FRONTEND_MODE_ATSC_30          1
 
#define FRONTEND_MAX_DEVICES           2
 
typedef void(*DataCallback)(void *pParentInst,int32_t iPacketType,
                            int32_t iPlpID,uint8_t *pData,
                            int32_t iLen, uint32_t iHdrLen);
 
 
class CFeHwCtrl
{
public:
    CFeHwCtrl(int iDevId);
 
    ~CFeHwCtrl( );
 
    int32_t StopInput(void);
 
    int32_t StartInput(void);
 
    int32_t SetCallback(void *pParent,DataCallback dataCB);
 
    int32_t GetStatus(int32_t *pSnr,int32_t *pRssi, int32_t *pEas,int32_t *pLock);  
 
    int32_t SetProperties(int32_t iMode,uint32_t iFreq,int32_t iBandwidth, int32_t iPlp);
 
    int32_t GetProperty(int32_t *pMode,uint32_t *pFreq,int *pBandwidth, int32_t *pPlp);
    
protected:
 
#define FRONTEND_TRANS_SIZE         (65536)
 
#define FRONTEND_ARRAY_SIZE         128
 
#define FRONTEND_MAX_ALP_DATA_SIZE  2048
 
#define FRONTEND_DATA_BUFFER_SIZE       (188*170)
 
pthread_t           mCaptureThread; 
pthread_mutex_t     mCaptureMutex;  
typedef struct
{
      bool bLock;       
      int32_t iSnr;     
      int32_t iRssi;    
      int32_t iEas;     
}   sFeHwStatus_t;
 
typedef struct
{
    int32_t iFd;            
    int32_t iFreq;          
    int32_t iPlpid;         
    int32_t iDevId;         
    int32_t iSystem;        
    int32_t iDemuxFd;       
    int32_t iIsLocked;      
    int32_t iIsOpened;      
    int32_t iBandwidth;     
    int32_t iIsRunning;     
    int32_t iIsInitialised; 
    pollfd stPfd;           
} sFeHw_t;
 
sFeHw_t hDevice;        
void* mpParent;         
DataCallback pCallbackHandler;  
int32_t m_Mode;             
int32_t m_State;            
int32_t m_CurPlp;           
int32_t m_BitCount;         
int32_t m_CurIndex;         
int32_t m_TSRemain;         
int32_t m_RecvState;        
int32_t m_SyncPoint;        
int32_t m_AlpRemain;        
uint8_t * m_pData;          
uint8_t * m_pAlpData;       
uint8_t * m_pResData;       
uint8_t * m_pInputBuf;      
uint8_t * m_pRemainData;    
int32_t mBitrate;       
int32_t mAvgBitrate;    
static void * DataReadInput(void* a_pParam);
 
void DataDeInit( void );
 
void SetByteAlign( void );
 
uint32_t GetBitCount(void );
 
void SkipData(int iBitCount);
 
int32_t SendData(sFeHw_t * pHan);
 
int32_t StopDemux (sFeHw_t * pHan);
 
int32_t StartDemux (sFeHw_t * pHan);
 
void * CaptureThreadHandler(void);
 
uint32_t  GetData(int32_t iBitSize);
 
int32_t InitFrontend (sFeHw_t * pHan);
 
int32_t CloseFrontend (sFeHw_t * pHan);
 
void DataInit(unsigned char *pData);
 
int32_t  SetFrontendParams(sFeHw_t * pHan);
 
void CancelReaderThread(sFeHw_t * pHan);
 
void ThreadCleanUp(void * pCleanHandle);
 
int32_t  ProcessInput(unsigned char *pTsData);
 
void ProcessALP(unsigned char *pDataBuf,int32_t iLen);
 
int32_t ProcessTS(unsigned char * pDataBuf, int32_t iLen);
 
int32_t ProcessAlpData(unsigned char * pDataBuf ,int32_t iLen);
 
int32_t CheckFrontend (sFeHw_t * pHan,sFeHwStatus_t *pTunerProp);
};
 
#endif /* ATSC_PLF_FRONTEND_HWCONTROL_H_ */