rtnoise.h

Go to the documentation of this file.

//=============================================================================================================
 
#ifndef RTNOISE_RTPROCESSING_H
#define RTNOISE_RTPROCESSING_H
 
//=============================================================================================================
// INCLUDES
//=============================================================================================================
 
#include "rtprocessing_global.h"
 
#include <fiff/fiff_cov.h>
#include <fiff/fiff_info.h>
#include <utils/generics/circularbuffer.h>
 
//=============================================================================================================
// QT INCLUDES
//=============================================================================================================
 
#include <QThread>
#include <QMutex>
#include <QSharedPointer>
#include <QVector>
 
//=============================================================================================================
// EIGEN INCLUDES
//=============================================================================================================
 
#include <Eigen/Core>
#include <unsupported/Eigen/FFT>
 
//=============================================================================================================
// DEFINE NAMESPACE RTPROCESSINGLIB
//=============================================================================================================
 
namespace RTPROCESSINGLIB
{
 
//=============================================================================================================
class RTPROCESINGSHARED_EXPORT RtNoise : public QThread
{
    Q_OBJECT
 
public:
    typedef QSharedPointer<RtNoise> SPtr;             
    typedef QSharedPointer<const RtNoise> ConstSPtr;  
 
    //=========================================================================================================
    explicit RtNoise(qint32 p_iMaxSamples,
                     FIFFLIB::FiffInfo::SPtr p_pFiffInfo,
                     qint32 p_dataLen,
                     QObject *parent = 0);
 
    //=========================================================================================================
    ~RtNoise();
 
    //=========================================================================================================
    void append(const Eigen::MatrixXd &p_DataSegment);
 
    //=========================================================================================================
    inline bool isRunning();
 
    //=========================================================================================================
    virtual bool start();
 
    //=========================================================================================================
    virtual bool stop();
 
    QMutex ReadMutex;
 
    Eigen::MatrixXd m_matSpecData;
    bool m_bSendDataToBuffer;
 
protected:
    //=========================================================================================================
    virtual void run();
 
    QVector <float> hanning(int N, short itype);
 
    int m_iNumOfBlocks;
    int m_iBlockSize;
    int m_iSensors;
    int m_iBlockIndex;
 
    Eigen::MatrixXd m_matCircBuf;
 
private:
    QMutex      mutex;                              
 
    FIFFLIB::FiffInfo::SPtr  m_pFiffInfo;           
 
    bool        m_bIsRunning;                       
 
    QSharedPointer<UTILSLIB::CircularBuffer_Matrix_double>       m_pCircularBuffer;      
 
    QVector <float> m_fWin;
 
    double m_Fs;
 
    qint32 m_iFftLength;
    qint32 m_dataLength;
 
signals:
    //=========================================================================================================
    void SpecCalculated(Eigen::MatrixXd);
};
 
//=============================================================================================================
// INLINE DEFINITIONS
//=============================================================================================================
 
inline bool RtNoise::isRunning()
{
    return m_bIsRunning;
}
} // NAMESPACE
 
#if QT_VERSION < QT_VERSION_CHECK(6, 0, 0)
#ifndef metatype_matrix
#define metatype_matrix
Q_DECLARE_METATYPE(Eigen::MatrixXd); 
#endif
#endif
 
#endif // RTNOISE_RTPROCESSING_H