atsc_mw_av_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 <pthread.h>
#include <mutex>
#include <unistd.h>
#include <queue>
#include <sys/time.h>
#include <functional>
 
#include "atsc_basetype.h"
 
typedef struct {
    int32_t iMediaType;     
    uint32_t iSize;         
    int32_t iSvcId;         
    int32_t iMajCh;         
    int32_t iMinCh;         
    int32_t iPhyCh;         
    uint8_t *pData;         
}sAvBuffer_t;
 
typedef struct{
    int32_t iMediaType;     
    int32_t iServiceId;     
    int32_t iMajorCh;       
    int32_t iMinorCh;       
    int32_t iPhyCh;         
    uint8_t *pAvData;       
    uint32_t iAvSize;       
}sAvData_t;
 
typedef std::function<void(sAvData_t*)> AvDataCbFunc; 
class CAvCtrl
{
public:
      CAvCtrl();
 
      ~CAvCtrl();
 
      std::thread *mAvDataThread;                   
      void AvCtrl_CbDataEvent(sAvData_t *pAvData);
 
      void AvDataHandlerThread( void );
 
      int32_t GetAvData( sAvBuffer_t *pAvData );
 
      void SetHandler( AvDataCbFunc fData );
 
      void RegisterAvEventNotify(AvDataCbFunc fParamsPtr);
 
      AvDataCbFunc mAvDataCb;               
private:
      bool mAvRunning;                      
      std::recursive_mutex mMut;            
      std::queue<sAvBuffer_t> mAvQueue;     
};