src/core/sessionthread.cpp

   1 /***************************************************************************
   2  *   Copyright (C) 2005-08 by the Quassel IRC Team                         *
   3  *   devel@quassel-irc.org                                                 *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or modify  *
   6  *   it under the terms of the GNU General Public License as published by  *
   7  *   the Free Software Foundation; either version 2 of the License, or     *
   8  *   (at your option) version 3.                                           *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  13  *   GNU General Public License for more details.                          *
  14  *                                                                         *
  15  *   You should have received a copy of the GNU General Public License     *
  16  *   along with this program; if not, write to the                         *
  17  *   Free Software Foundation, Inc.,                                       *
  18  *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
  19  ***************************************************************************/
  20
  21 #include <QMutexLocker>
  22
  23 #include "sessionthread.h"
  24 #include "signalproxy.h"
  25 #include "coresession.h"
  26
  27 SessionThread::SessionThread(UserId uid, bool restoreState, QObject *parent)
  28   : QThread(parent),
  29     _session(0),
  30     _user(uid),
  31     _sessionInitialized(false),
  32     _restoreState(restoreState)
  33 {
  34   connect(this, SIGNAL(initialized()), this, SLOT(setSessionInitialized()));
  35 }
  36
  37 SessionThread::~SessionThread() {
  38   // shut down thread gracefully
  39   quit();
  40   wait();
  41 }
  42
  43 CoreSession *SessionThread::session() {
  44   return _session;
  45 }
  46
  47 UserId SessionThread::user() {
  48   return _user;
  49 }
  50
  51 bool SessionThread::isSessionInitialized() {
  52   return _sessionInitialized;
  53 }
  54
  55 void SessionThread::setSessionInitialized() {
  56   _sessionInitialized = true;
  57   foreach(QObject *peer, clientQueue) {
  58     addClientToSession(peer);
  59   }
  60   clientQueue.clear();
  61 }
  62
  63 void SessionThread::addClient(QObject *peer) {
  64   if(isSessionInitialized()) {
  65     addClientToSession(peer);
  66   } else {
  67     clientQueue.append(peer);
  68   }
  69 }
  70
  71 void SessionThread::addClientToSession(QObject *peer) {
  72   QIODevice *socket = qobject_cast<QIODevice *>(peer);
  73   if(socket) {
  74     addRemoteClientToSession(socket);
  75     return;
  76   }
  77
  78   SignalProxy *proxy = qobject_cast<SignalProxy *>(peer);
  79   if(proxy) {
  80     addInternalClientToSession(proxy);
  81     return;
  82   }
  83
  84   qWarning() << "SessionThread::addClient() received neither QIODevice nor SignalProxy as peer!" << peer;
  85 }
  86
  87 void SessionThread::addRemoteClientToSession(QIODevice *socket) {
  88   socket->setParent(0);
  89   socket->moveToThread(session()->thread());
  90   emit addRemoteClient(socket);
  91 }
  92
  93 void SessionThread::addInternalClientToSession(SignalProxy *proxy) {
  94   emit addInternalClient(proxy);
  95 }
  96
  97 void SessionThread::run() {
  98   _session = new CoreSession(user(), _restoreState);
  99   connect(this, SIGNAL(addRemoteClient(QIODevice *)), _session, SLOT(addClient(QIODevice *)));
 100   connect(this, SIGNAL(addInternalClient(SignalProxy *)), _session, SLOT(addClient(SignalProxy *)));
 101   emit initialized();
 102   exec();
 103   delete _session;
 104 }
 105