MSThread.cpp

/*
 *  This file is part of the AiBO+ project
 *
 *  Copyright (C) 2005-2016 Csaba Kertész (csaba.kertesz@gmail.com)
 *
 *  AiBO+ is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  AiBO+ is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Street #330, Boston, MA 02111-1307, USA.
 *
 */

#include "MSThread.hpp"

#include <MCLog.hpp>

void MSThread::run()
{
  exec();
  RemoveObjects();
}


void MSThread::AddObject(QObject& object)
{
  MC_LOG("this: %p obj: %p obj thread: %p", this, &object, object.thread());
  if (ObjectThreads.contains(&object))
  {
    MC_WARNING("The object has been moved to this thread already!");
    return;
  }
  ObjectThreads[&object] = object.thread();
  object.moveToThread(this);
}


void MSThread::RemoveObjects()
{
  if (!ObjectThreads.isEmpty())
  {
    for (auto iter = ObjectThreads.begin(); iter != ObjectThreads.end(); ++iter)
    {
      MC_LOG("Move object (%p) to its original thread (%p -> %p)",
             iter.key(), this, iter.value());
      iter.key()->moveToThread(iter.value());
    }
    ObjectThreads.clear();
  } else {
    MC_WARNING("No object is registered to move back to its original thread.");
  }
}


bool MSThread::IsEmpty()
{
  return ObjectThreads.isEmpty();
}