File indexing completed on 2024-05-12 17:15:12

0001 /*
0002    Copyright (C) 2013 Andreas Hartmetz <ahartmetz@gmail.com>
0003 
0004    This library is free software; you can redistribute it and/or
0005    modify it under the terms of the GNU Library General Public
0006    License as published by the Free Software Foundation; either
0007    version 2 of the License, or (at your option) any later version.
0008 
0009    This library is distributed in the hope that it will be useful,
0010    but WITHOUT ANY WARRANTY; without even the implied warranty of
0011    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
0012    Library General Public License for more details.
0013 
0014    You should have received a copy of the GNU Library General Public License
0015    along with this library; see the file COPYING.LGPL.  If not, write to
0016    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
0017    Boston, MA 02110-1301, USA.
0018 
0019    Alternatively, this file is available under the Mozilla Public License
0020    Version 1.1.  You may obtain a copy of the License at
0021    http://www.mozilla.org/MPL/
0022 */
0023 
0024 #ifndef EAVESDROPPERTHREAD_H
0025 #define EAVESDROPPERTHREAD_H
0026 
0027 #include "imessagereceiver.h"
0028 
0029 #include <QElapsedTimer>
0030 #include <QThread>
0031 
0032 class EavesdropperModel;
0033 class EventDispatcher;
0034 class Message;
0035 class Connection;
0036 
0037 // This is a separate thread mainly for accurate timestamps. If this was running in the main
0038 // thread, GUI and other processing would delay the calls to messageReceived() and therefore
0039 // QDateTime::currentDateTime().
0040 
0041 class EavesdropperThread : public QObject, public IMessageReceiver
0042 {
0043 Q_OBJECT
0044 public:
0045     EavesdropperThread(EavesdropperModel *model);
0046     ~EavesdropperThread() override;
0047 
0048     // reimplemented IMessageReceiver method
0049     void handleSpontaneousMessageReceived(Message message, Connection *) override;
0050 
0051 signals:
0052     void messageReceived(Message *message, qint64 timestamp);
0053 
0054 private slots:
0055     void run();
0056 
0057 private:
0058     QThread m_thread;
0059     QElapsedTimer m_timer;
0060     EventDispatcher *m_dispatcher;
0061     Connection *m_connection;
0062 };
0063 
0064 #endif // EAVESDROPPERTHREAD_H