PacMan.h

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2008-2010 by Matthias Nagl                              *
 *   mnagl@uni-goettingen.de                                               *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

#ifndef PACMAN_H
#define PACMAN_H

#include <QObject>
#include <QTimer>
#include <QMutex>
#include <QQueue>
#include "PacQueue.h"
#include "PropertyBranch.h"
#include "TransmittableProperty.h"

class PacStats;
class PacDigitizerThread;
class PacAnalyzerThread;
class PacNetThread;
class WaveformDataInterface;
class PacWaveformChunk;
class PacResultChunk;
class WaveformProcessingInterface;

class PacMan : public QObject, PropertyBranch
{
    Q_OBJECT
  public:
    PacMan(QObject *parent = 0);
    ~PacMan();

    static PacQueue<PacWaveformChunk> *pacdataqueue;
    static QList<PacAnalyzerThread*> analyzerthreads;
    static PacQueue<const long long> droppedChunks;
    static PacQueue<PacWaveformChunk> *wfrecyclingqueue;
    static PacStats *pacstats;
    void forwardConfirmationData(const TransmittablePropertyData *d) const;
    void forwardNewProperty(const TransmittableProperty *p) const;
    void childPropertyChanged(TransmittableProperty *);
    static const WaveformProcessingInterface * getAnalyzer() { return procif; };

  public slots:
    void startRecording();
    void stopRecording();
    void recordingFinished();
    void getThreadStatus(QString s);
    void sendAllProperties();
    void changedPropertyReceived(QByteArray data);

  private slots:
    void sendAnalyzerStats();
    void sendConfirmationProperties();

  signals:
    void start_recording();
    void stop_recording();
    void allThreadsReady();
    void analyzerStats(int dataqueuewfin, int dataqueuewfdrop, int resultqueuein, int resultqueuedrop);
    void lastSeqNum(qlonglong l);
    void numAnalyzerThreads(unsigned int newnum);
    void forwardWaveformTeaser(WaveformDataInterface *w);
    void waitingForOffsetSignal();
    void foundOffsetSignal();
    void startSynchronization();
    void setAnalyzerPlugin(QObject * waveformtemplate);
    void sendPropertyToNode(QByteArray data) const;
    void sendConfirmationToNode(QByteArray data);

  private:
    virtual void propertyChanged(TransmittableProperty *);
    void updatePerformanceProperties();
    void updatePluginProperty();
    void initializePluginList();
    QMutex mutex;
    PacDigitizerThread* digithread;
    int numanalyzerthreads;
    PacNetThread *netthread;
    bool netthreadready, digithreadready;
    int analyzerthreadsready;
    QTimer *stattimer;
    QTimer *confirmationtimer;
    mutable QQueue<const TransmittablePropertyData*> confirmationqueue;
    mutable QMutex confirmationmutex;
    PropertyBranch b_performance;
    TransmittableProperty p_analyzerthreads, p_wfqueuelength, p_wfrecyclingqueuelength, p_resultqueuelength, p_plugin;
    bool recording;
    static WaveformProcessingInterface *procif;
    QMap<int, QString> pluginIdToName;
    QMap<int, WaveformProcessingInterface*> pluginIdToObject;
};

#endif