atsc_core_streamer_demodsender.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
  *******************************************************************************/
#ifndef ATSC_CORE_STREAMER_DEMODSENDER_H_
#define ATSC_CORE_STREAMER_DEMODSENDER_H_
 
#pragma once
#include <stdio.h>
#include <time.h>
#include <netinet/in.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <thread>
#include <list>
 
#include "debug.h"
#include "atsc_core_common_ring_queue.h"
#include "atsc_core_common.h"
 
typedef struct{
    int32_t iCmd;            
    uint32_t iIp;            
    uint32_t iPort;          
    uint32_t iStreamIp;      
    uint32_t iStreamPort;    
    uint32_t iBitRate;       
    timespec stTimeContinue; 
    timespec stTimeStart;    
}sDemodClient_t;
 
typedef struct{
    int32_t iSock;           
    int32_t iDataLen;        
    uint8_t *pData;          
    sockaddr_in stAddr;      
    sIpHeader_t stIp;        
    sUdpHeader_t stUdp;      
}sDemodSend_t;
 
class CDemodSender {
public:
    CDemodSender();
 
    ~CDemodSender();
 
    void Start(int32_t iMode);
 
    void Stop();
 
    void Put(uint8_t* pData, int32_t iDatalen) {
        mMediaQueue->WriteRingQueue(pData, iDatalen);
    }
 
    void PutLLS(uint8_t* pData, int32_t iDatalen) {
        mLlsQueue->WriteRingQueue(pData, iDatalen);
    }
 
    void PutSLS(uint8_t* pData, int32_t iDatalen) {
        mSlsQueue->WriteRingQueue(pData, iDatalen);
    }
    
    int32_t PushMsg(sDemodClient_t* pClient);
 
    int32_t GetClientCount();
 
private:
    std::thread *mThread;                 
    CQueue *mMediaQueue;                  
    std::list<sDemodClient_t>mClients;    
    CQueue *mLlsQueue;                    
    CQueue *mSlsQueue;                    
    int32_t mNumOfClient;                 
    bool mRunning;                        
    bool mUseMulticast;                   
    void ThreadSender();
 
    int32_t SendLLS(sDemodSend_t sParam);
 
    int32_t SendMedia(sDemodSend_t sParam, bool multicast);
 
    int32_t SendSLS(sDemodSend_t sParam);
 
    int32_t GetSender(uint32_t iReqip, uint32_t iReqport,  uint32_t *pClientsIp, uint32_t *pClientsPort);
 
    int32_t RemoveOldClient();
};
 
#endif // ATSC_CORE_STREAMER_DEMODSENDER_H_