PacCoincidenceSearchThread.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 PACCOINCIDENCESEARCHTHREAD_H
#define PACCOINCIDENCESEARCHTHREAD_H

#include <QThread>
#include <QMutex>
#include <QPair>
#include "PacKnockoutSettings.h"
#include "pacCoincidenceDefinitions.h"

class PrivateEvent; 
class PacCoincidenceInput;
class PacProgressDialog;
class PacDataReader;

class PacCoincidenceSearchThread : public QThread
{
    Q_OBJECT
  public:
    PacCoincidenceSearchThread(quint8 numdetectors, PacDataReader *reader, QObject *parent = 0);
    ~PacCoincidenceSearchThread();
    void setInput(const PacCoincidenceInput *input, bool addendum = false);

  signals:
    void results(
      const PacCoincidenceInput *input,
      const PacCoincidenceSearchResults &spectra,
      bool addendum,
      bool stillwritten,
      quint64 nextcppointerpos
      );
    void progress(int p);

  private slots:
    void cancelThread();
    void stopThreadAndSave();

  private:
    enum StopMode {
      DontStop = 0,
      Cancel,
      StopAndSave
    };
    QAtomicInt stopthread;

    void run();
    void saveCorrelation(const PrivateEvent *start, const PrivateEvent *stop);

    const PacCoincidenceInput *input;
    PacDataReader *reader;

    PacProgressDialog *pdialog;

    unsigned int channels;
    QMutex mutex;
    QPair<qreal,qreal> startwindow, stopwindow;
    qreal minclength; // in ns
    qreal maxclength; // in ns
    qulonglong minclps; // in ps
    qulonglong maxclps; // in ps
    PacCoincidenceSearchResults spectra;
    quint8 numdetectors;
    qint32 bytebuffersize; 
    static const quint64 emitprogressafter; 
    quint32 progresscounter; 
    PacKnockoutSettings kosettings;
    quint32 delayedevents;

    void readEvent(PrivateEvent *target);
    void findBuddies(int starteventpointer);
    void findCoincidences(int starteventpointer);
    static const qint32 initialbuffersize = 100;
    QList<PrivateEvent*> ebuffer; 
    int buffersize;  
    int bufferfront; 
    int bufferback;  
    quint64 previoustimestamp; 
    bool addendum;
};

#endif