#include "tthreadmessage.h"

#include "tthreadp.h"

#include <qthread></qthread>

QThread *MainThread = QThread::currentThread();

TThreadMessageDispatcher

    *Dispatcher;  // MUST BE CREATED  in the main thread!!!!!!

//------------------------------------------------------------------------------

bool TThread::isMainThread() { return MainThread == QThread::currentThread(); }

//------------------------------------------------------------------------------

TThreadMessageDispatcher::TThreadMessageDispatcher() {

  connect(this, SIGNAL(signaled(TThread::Message *)), this,

          SLOT(onSignal(TThread::Message *)));

  connect(this, SIGNAL(blockingSignaled(TThread::Message *)), this,

          SLOT(onSignal(TThread::Message *)), Qt::BlockingQueuedConnection);

}

//------------------------------------------------------------------------------

void TThreadMessageDispatcher::init() {

  if (!TThread::isMainThread()) return;

  if (Dispatcher == 0) Dispatcher = new TThreadMessageDispatcher();

}

//------------------------------------------------------------------------------

TThreadMessageDispatcher *TThreadMessageDispatcher::instance() {

  assert(Dispatcher);

  return Dispatcher;

}

//------------------------------------------------------------------------------

void TThreadMessageDispatcher::emitSignaled(TThread::Message *msg) {

  Q_EMIT signaled(msg);

}

//------------------------------------------------------------------------------

void TThreadMessageDispatcher::emitBlockingSignaled(TThread::Message *msg) {

  Q_EMIT blockingSignaled(msg);

}

//------------------------------------------------------------------------------

void TThreadMessageDispatcher::onSignal(TThread::Message *msg) {

  msg->onDeliver();

  delete msg;

}

//------------------------------------------------------------------------------

TThread::Message::Message() {}

//------------------------------------------------------------------------------

void TThread::Message::send() {

  if (isMainThread())

    onDeliver();

  else

    TThreadMessageDispatcher::instance()->emitSignaled(clone());

}

//------------------------------------------------------------------------------

void TThread::Message::sendBlocking() {

  if (isMainThread())

    onDeliver();

  else

    TThreadMessageDispatcher::instance()->emitBlockingSignaled(clone());

}

//------------------------------------------------------------------------------