SDRAngel  4.11.5
Developer docs for <a href="https://github.com/f4exb/sdrangel">SDRangel<\a>, an Open Source Qt5 / OpenGL 3.0+ SDR and signal analyzer frontend to various hardware.
localsinkthread.h
Go to the documentation of this file.
1 // Copyright (C) 2019 Edouard Griffiths, F4EXB. //
3 // //
4 // This program is free software; you can redistribute it and/or modify //
5 // it under the terms of the GNU General Public License as published by //
6 // the Free Software Foundation as version 3 of the License, or //
7 // (at your option) any later version. //
8 // //
9 // This program is distributed in the hope that it will be useful, //
10 // but WITHOUT ANY WARRANTY; without even the implied warranty of //
11 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the //
12 // GNU General Public License V3 for more details. //
13 // //
14 // You should have received a copy of the GNU General Public License //
15 // along with this program. If not, see <http://www.gnu.org/licenses/>. //
17 
18 #ifndef PLUGINS_CHANNELRX_LOCALSINK_LOCALSINKTHREAD_H_
19 #define PLUGINS_CHANNELRX_LOCALSINK_LOCALSINKTHREAD_H_
20 
21 #include <QThread>
22 #include <QMutex>
23 #include <QWaitCondition>
24 
25 #include "dsp/dsptypes.h"
26 #include "util/message.h"
27 #include "util/messagequeue.h"
28 
29 class SampleSinkFifo;
30 
31 class LocalSinkThread : public QThread {
32  Q_OBJECT
33 
34 public:
35  class MsgStartStop : public Message {
37 
38  public:
39  bool getStartStop() const { return m_startStop; }
40 
41  static MsgStartStop* create(bool startStop) {
42  return new MsgStartStop(startStop);
43  }
44 
45  protected:
47 
49  Message(),
50  m_startStop(startStop)
51  { }
52  };
53 
54  LocalSinkThread(QObject* parent = 0);
56 
57  void startStop(bool start);
58  void setSampleFifo(SampleSinkFifo *sampleFifo) { m_sampleFifo = sampleFifo; }
59 
60 public slots:
61  void processSamples(const quint8* data, uint count);
62 
63 private:
65  QWaitCondition m_startWaiter;
66  volatile bool m_running;
68 
70 
71  void startWork();
72  void stopWork();
73  void run();
74 
75 private slots:
76  void handleInputMessages();
77 };
78 
79 #endif // PLUGINS_CHANNELRX_LOCALSINK_LOCALSINKTHREAD_H_
80 
void processSamples(const quint8 *data, uint count)
SampleSinkFifo * m_sampleFifo
LocalSinkThread(QObject *parent=0)
#define MESSAGE_CLASS_DECLARATION
Definition: message.h:43
QWaitCondition m_startWaiter
void startStop(bool start)
static MsgStartStop * create(bool startStop)
MessageQueue m_inputMessageQueue
void setSampleFifo(SampleSinkFifo *sampleFifo)
volatile bool m_running