modularization/src1/common/modulecomm_fastrtps_tcp/modulecomm_fastrtps_tcp.h

#ifndef MODULECOMM_FASTRTPS_TCP_H
#define MODULECOMM_FASTRTPS_TCP_H

#include <QtCore/qglobal.h>
#include <QDateTime>

#include <functional>

#if defined(MODULECOMM_FASTRTPS_TCP_LIBRARY)
#  define MODULECOMMFASTRTPSTCPSHARED_EXPORT Q_DECL_EXPORT
#else
#  define MODULECOMMFASTRTPSTCPSHARED_EXPORT Q_DECL_IMPORT
#endif



//#include <iostream>
//#include <thread>

#ifndef IV_MODULE_FUN

typedef std::function<void(const char * ,const unsigned int , const unsigned int , QDateTime * ,const char *)> ModuleFun;
typedef void (* SMCallBack)(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
#define IV_MODULE_FUN
#endif


namespace iv {
namespace modulecomm_fastrtps_tcp {
void * MODULECOMMFASTRTPSTCPSHARED_EXPORT RegisterSend(const char * strcommname,const unsigned int nBufSize,const unsigned int nMsgBufCount,unsigned int nListenPort);
void * MODULECOMMFASTRTPSTCPSHARED_EXPORT RegisterRecv(const char * strcommname,SMCallBack pCall,const char * strpubip,unsigned int nListenPort);
void * MODULECOMMFASTRTPSTCPSHARED_EXPORT RegisterRecvPlus(const char * strcommname,ModuleFun xFun,const char * strpubip,unsigned int nListenPort);
void MODULECOMMFASTRTPSTCPSHARED_EXPORT ModuleSendMsg(void * pHandle,const char * strdata,const unsigned int nDataLen);
void MODULECOMMFASTRTPSTCPSHARED_EXPORT Unregister(void * pHandle);
void MODULECOMMFASTRTPSTCPSHARED_EXPORT PauseComm(void * pHandle);
void MODULECOMMFASTRTPSTCPSHARED_EXPORT ContintuComm(void * pHandle);

}

}



#endif