29 connect(&m_inputMessageQueue, SIGNAL(messageEnqueued()),
this, SLOT(handleInputMessages()), Qt::QueuedConnection);
34 qDebug(
"LocalSinkThread::~LocalSinkThread");
45 qDebug(
"LocalSinkThread::startWork");
55 qDebug(
"LocalSinkThread::stopWork");
62 qDebug(
"LocalSinkThread::run: begin");
72 qDebug(
"LocalSinkThread::run: end");
91 qDebug(
"LocalSinkThread::handleInputMessages: MsgStartStop: %s", notif->
getStartStop() ?
"start" :
"stop");
void processSamples(const quint8 *data, uint count)
Message * pop()
Pop message from queue.
void push(Message *message, bool emitSignal=true)
Push message onto queue.
SampleSinkFifo * m_sampleFifo
bool getStartStop() const
uint write(const quint8 *data, uint count)
#define MESSAGE_CLASS_DEFINITION(Name, BaseClass)
QWaitCondition m_startWaiter
void startStop(bool start)
static MsgStartStop * create(bool startStop)
MessageQueue m_inputMessageQueue
static bool match(const Message *message)
void handleInputMessages()