29 connect(&m_inputMessageQueue, SIGNAL(messageEnqueued()),
this, SLOT(handleInputMessages()), Qt::QueuedConnection);
34 qDebug(
"LocalSourceThread::~LocalSourceThread");
50 SampleVector::iterator beginRead;
57 qDebug(
"LocalSourceThread::startWork");
70 qDebug(
"LocalSourceThread::stopWork");
77 qDebug(
"LocalSinkThread::run: begin");
87 qDebug(
"LocalSinkThread::run: end");
99 qDebug(
"LocalSourceThread::handleInputMessages: MsgStartStop: %s", notif->
getStartStop() ?
"start" :
"stop");
Message * pop()
Pop message from queue.
bool getStartStop() const
void pullSamples(unsigned int count)
void push(Message *message, bool emitSignal=true)
Push message onto queue.
static MsgStartStop * create(bool startStop)
int getIteratorOffset(const SampleVector::iterator &iterator)
MessageQueue m_inputMessageQueue
void startStop(bool start)
void setSampleFifo(SampleSourceFifo *sampleFifo)
#define MESSAGE_CLASS_DEFINITION(Name, BaseClass)
QWaitCondition m_startWaiter
void handleInputMessages()
static bool match(const Message *message)
void readAdvance(SampleVector::iterator &readUntil, unsigned int nbSamples)
SampleSourceFifo * m_sampleFifo
void samplesAvailable(int offset)