VFS_pulse.cpp

Go to the documentation of this file.

 
#include <QTime>
#include <QJsonObject>
 
#include "VFS.h"
#include "VFS_pulse.h"
 
VFS_pulse::VFS_pulse(int interval)
: VFS_node()
, _interval(interval)
, _timerID(-1)
{
        connect( this, SIGNAL(mounted()), this, SLOT(startPulse()) );
        connect( this, SIGNAL(unmounted(VFS_node*)), this, SLOT(stopPulse()) );
        connect( VFS::root(), SIGNAL(initialized()), this, SLOT(startPulse()) );
}
 
VFS_pulse::~VFS_pulse()
{
        stopPulse();
}
 
bool VFS_pulse::isContainer()
{
        return false;
}
 
void VFS_pulse::startPulse()
{
        if (_timerID == -1)
        {
                _timerID = startTimer(_interval);
                //emit timerEvent(0);                           //pulse when starting, rather than waiting for a full cycle.
 
                VFS::LOG( QString("%1 started pulse timer at an interval of %2ms").arg(className()).arg(_interval) );
        }
}
 
void VFS_pulse::stopPulse()
{
        if (_timerID != -1)
        {
                killTimer(_timerID);
                _timerID = -1;
 
                VFS::LOG( QString("%1 stopped pulse timer").arg(className()) );
        }
}
 
void VFS_pulse::read(VFS_request *r)
{
        QString now = QTime::currentTime().toString();
 
        QJsonObject o;
        o["data"] = now;
 
        r->_data.setObject(o);
 
        r->_success = true;
}
 
void VFS_pulse::timerEvent(QTimerEvent *event)
{
        if (event->timerId() == _timerID)
        {
                //QByteArray now = (QString("%1").arg((quintptr)this)+" "+QTime::currentTime().toString()).toAscii();
                QString now = QTime::currentTime().toString();
 
                VFS::LOG( QString("Pulse: %1").arg(now), 9, className() );
 
                QJsonObject o;
                o["data"] = now;
                QJsonDocument d(o);
 
                VFS_request *r = createRequest(VFS_request::diff,"","pulse",d);
 
                emit diff(this,r);
 
                delete r;               //Don't leak memory
        }
        else
                VFS::ERROR("Received timer event from bad _timerID",0,className());
}