modularization/src1/common/modulecomm/modulecomm.cpp

#include "modulecomm.h"
#include <iostream>

#include "modulecomm_shm.h"

#include "modulecomm_inter.h"
#ifdef USE_FASTRTPS
#include "modulecomm_fastrtps_shm.h"
#include "modulecomm_fastrtps_tcp.h"
#endif

namespace iv {
namespace modulecomm {

struct ModeduleInfo
{
    modulecomm_base * mphandle;
    ModuleComm_TYPE mmctype;
};


void * RegisterSend(const char *strcommname, const unsigned int nBufSize, const unsigned int nMsgBufCount)
{
    return RegisterSend(strcommname,nBufSize,nMsgBufCount,ModuleComm_SHAREMEM);
}

void *  RegisterSend(const char * strcommname,const unsigned int nBufSize,const unsigned int nMsgBufCount,
                     ModuleComm_TYPE xmctype,const unsigned short nport)
{

    iv::modulecomm::ModeduleInfo * pmi = new iv::modulecomm::ModeduleInfo;
    pmi->mmctype = xmctype;
    pmi->mphandle = 0;
    switch (xmctype) {
    case ModuleComm_SHAREMEM:
    {
        iv::modulecomm_shm * p = new iv::modulecomm_shm();
        p->RegisterSend(strcommname,nBufSize,nMsgBufCount);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;
    case ModuleComm_INTERIOR:
    {
        iv::modulecomm_inter * p = new iv::modulecomm_inter();
        p->RegisterSend(strcommname,nBufSize,nMsgBufCount);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;

#ifdef USE_FASTRTPS
    case ModuleComm_FASTRTPS:
    {
        iv::modulecomm_fastrtps_shm * p = new iv::modulecomm_fastrtps_shm();
        p->RegisterSend(strcommname,nBufSize,nMsgBufCount);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;

    case ModuleComm_FASTRTPS_TCP:
    {
        iv::modulecomm_fastrtps_tcp * p = new iv::modulecomm_fastrtps_tcp();
        p->RegisterSend(strcommname,nBufSize,nMsgBufCount,nport);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;
#endif
    default:
        break;
    }
    return pmi;
}


void * RegisterRecv(const char *strcommname, SMCallBack pCall)
{
    return RegisterRecv(strcommname,pCall,ModuleComm_SHAREMEM);
}

void  *  RegisterRecv(const char * strcommname,SMCallBack pCall,ModuleComm_TYPE xmctype,const char * strip,
                      const unsigned short nPort)
{
    iv::modulecomm::ModeduleInfo * pmi = new iv::modulecomm::ModeduleInfo;
    pmi->mmctype = xmctype;
    pmi->mphandle = 0;
    switch (xmctype) {
    case ModuleComm_SHAREMEM:
    {
        iv::modulecomm_shm * p = new iv::modulecomm_shm();
        p->RegisterRecv(strcommname,pCall);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;
    case ModuleComm_INTERIOR:
    {
        iv::modulecomm_inter * p = new iv::modulecomm_inter();
        p->RegisterRecv(strcommname,pCall);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;

#ifdef USE_FASTRTPS
    case ModuleComm_FASTRTPS:
    {
        iv::modulecomm_fastrtps_shm * p = new iv::modulecomm_fastrtps_shm();
        p->RegisterRecv(strcommname,pCall);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;

    case ModuleComm_FASTRTPS_TCP:
    {
        iv::modulecomm_fastrtps_tcp * p = new iv::modulecomm_fastrtps_tcp();
        p->RegisterRecv(strcommname,pCall,strip,nPort);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;
#endif
    default:
        break;
    }
    return pmi;
}

void * RegisterRecvPlus(const char *strcommname, ModuleFun xFun)
{
    return RegisterRecvPlus(strcommname,xFun,ModuleComm_SHAREMEM);
}

void *  RegisterRecvPlus(const char * strcommname,ModuleFun xFun,
                                                ModuleComm_TYPE xmctype,const char * strip,
                         const unsigned short nPort)
{
    iv::modulecomm::ModeduleInfo * pmi = new iv::modulecomm::ModeduleInfo;
    pmi->mmctype = xmctype;
    pmi->mphandle = 0;
    switch (xmctype) {
    case ModuleComm_SHAREMEM:
    {
        iv::modulecomm_shm * p = new iv::modulecomm_shm();
        p->RegisterRecvPlus(strcommname,xFun);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;
    case ModuleComm_INTERIOR:
    {
        iv::modulecomm_inter * p = new iv::modulecomm_inter();
        p->RegisterRecvPlus(strcommname,xFun);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;
#ifdef USE_FASTRTPS
    case ModuleComm_FASTRTPS:
    {
        iv::modulecomm_fastrtps_shm * p = new iv::modulecomm_fastrtps_shm();
        p->RegisterRecvPlus(strcommname,xFun);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;

    case ModuleComm_FASTRTPS_TCP:
    {
        iv::modulecomm_fastrtps_tcp * p = new iv::modulecomm_fastrtps_tcp();
        p->RegisterRecvPlus(strcommname,xFun,strip,nPort);
        pmi->mphandle = (iv::modulecomm_base *)p;
    }
        break;
#endif
    default:
        break;
    }
    return pmi;
}

void  ModuleSendMsg(void * pHandle,const char * strdata,const unsigned int nDataLen)
{
    iv::modulecomm::ModeduleInfo * pmi = (iv::modulecomm::ModeduleInfo  * )pHandle;
    if(pmi->mphandle == 0)
    {
        qDebug("handler error. use fastrtps but not define.");
        return;
    }
    pmi->mphandle->ModuleSendMsg(strdata,nDataLen);
}

void  Unregister(void * pHandle)
{
    iv::modulecomm::ModeduleInfo * pmi = (iv::modulecomm::ModeduleInfo  * )pHandle;
    if(pmi->mphandle == 0)
    {
        qDebug("handler error. use fastrtps but not define.");
        return;
    }
    pmi->mphandle->Unregister();
}

void PauseComm(void *pHandle)
{
    iv::modulecomm::ModeduleInfo * pmi = (iv::modulecomm::ModeduleInfo  * )pHandle;
    if(pmi->mphandle == 0)
    {
        qDebug("handler error. use fastrtps but not define.");
        return;
    }
    pmi->mphandle->PauseComm();
}

void ContintuComm(void *pHandle)
{
    iv::modulecomm::ModeduleInfo * pmi = (iv::modulecomm::ModeduleInfo  * )pHandle;
    if(pmi->mphandle == 0)
    {
        qDebug("handler error. use fastrtps but not define.");
        return;
    }
    pmi->mphandle->ContintuComm();
}

}
}