rt_client.h

Go to the documentation of this file.

//=============================================================================================================
 
#ifndef RTCLIENT_H
#define RTCLIENT_H
 
//=============================================================================================================
// INCLUDES
//=============================================================================================================
 
#include "../com_global.h"
 
#include <fiff/fiff_info.h>
 
//=============================================================================================================
// QT INCLUDES
//=============================================================================================================
 
#include <QMutex>
#include <QSharedPointer>
#include <QString>
#include <QThread>
 
//=============================================================================================================
// EIGEN INCLUDES
//=============================================================================================================
 
#include <Eigen/Core>
 
//=============================================================================================================
// DEFINE NAMESPACE COMLIB
//=============================================================================================================
 
namespace COMLIB
{
 
//=============================================================================================================
// FORWARD DECLARATIONS
//=============================================================================================================
 
//=============================================================================================================
class COMSHARED_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