rtclient.h

Go to the documentation of this file.

//=============================================================================================================
#ifndef RTCLIENT_H
#define RTCLIENT_H
 
//=============================================================================================================
// INCLUDES
//=============================================================================================================
 
#include "../communication_global.h"
 
#include <fiff/fiff_info.h>
 
//=============================================================================================================
// QT INCLUDES
//=============================================================================================================
 
#include <QMutex>
#include <QSharedPointer>
#include <QString>
#include <QThread>
 
//=============================================================================================================
// EIGEN INCLUDES
//=============================================================================================================
 
#include <Eigen/Core>
 
//=============================================================================================================
// DEFINE NAMESPACE COMMUNICATIONLIB
//=============================================================================================================
 
namespace COMMUNICATIONLIB
{
 
//=============================================================================================================
// FORWARD DECLARATIONS
//=============================================================================================================
 
//=============================================================================================================
class COMMUNICATIONSHARED_EXPORT RtClient : public QThread
{
    Q_OBJECT
 
public:
    typedef QSharedPointer<RtClient> SPtr;               
    typedef QSharedPointer<const RtClient> ConstSPtr;    
    //=========================================================================================================
    explicit RtClient(QString p_sRtServerHostname, QString p_sClientAlias = "rtclient", QObject *parent = 0);
    
    //=========================================================================================================
    ~RtClient();
 
    //=========================================================================================================
    inline FIFFLIB::FiffInfo::SPtr& getFiffInfo();
 
    //=========================================================================================================
    bool getConnectionStatus();
 
    //=========================================================================================================
    virtual bool stop();
 
protected:
    //=========================================================================================================
    virtual void run();
 
private:
    QMutex      mutex;                      
    bool        m_bIsConnected;             
    bool        m_bIsMeasuring;             
    bool        m_bIsRunning;               
    QString     m_sClientAlias;             
    QString     m_sRtServerHostName;        
    FIFFLIB::FiffInfo::SPtr  m_pFiffInfo;   
    quint16      m_iDefaultPort;
signals:
    //=========================================================================================================
    void rawBufferReceived(Eigen::MatrixXf p_rawBuffer);
 
    //=========================================================================================================
    void connectionChanged(bool p_bStatus);
};
 
//=============================================================================================================
// INLINE DEFINITIONS
//=============================================================================================================
 
inline FIFFLIB::FiffInfo::SPtr& RtClient::getFiffInfo()
{
    return m_pFiffInfo;
}
} // NAMESPACE
 
#ifndef metatype_matrixxf
#define metatype_matrixxf
Q_DECLARE_METATYPE(Eigen::MatrixXf);    
#endif
 
#endif // RTCLIENT_H