/***************************************************************************
- * Copyright (C) 2005-09 by the Quassel Project *
+ * Copyright (C) 2005-2012 by the Quassel Project *
* devel@quassel-irc.org *
* *
* This program is free software; you can redistribute it and/or modify *
* 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 Place - Suite 330, Boston, MA 02111-1307, USA. *
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
***************************************************************************/
#include <QMutexLocker>
#include "core.h"
SessionThread::SessionThread(UserId uid, bool restoreState, QObject *parent)
- : QThread(parent),
+ : QThread(parent),
_session(0),
_user(uid),
_sessionInitialized(false),
_restoreState(restoreState)
{
- connect(this, SIGNAL(initialized()), this, SLOT(setSessionInitialized()));
+ connect(this, SIGNAL(initialized()), this, SLOT(setSessionInitialized()));
}
-SessionThread::~SessionThread() {
- // shut down thread gracefully
- quit();
- wait();
-}
-CoreSession *SessionThread::session() {
- return _session;
+SessionThread::~SessionThread()
+{
+ // shut down thread gracefully
+ quit();
+ wait();
}
-UserId SessionThread::user() {
- return _user;
-}
-bool SessionThread::isSessionInitialized() {
- return _sessionInitialized;
+CoreSession *SessionThread::session()
+{
+ return _session;
}
-void SessionThread::setSessionInitialized() {
- _sessionInitialized = true;
- foreach(QObject *peer, clientQueue) {
- addClientToSession(peer);
- }
- clientQueue.clear();
+
+UserId SessionThread::user()
+{
+ return _user;
}
-void SessionThread::addClient(QObject *peer) {
- if(isSessionInitialized()) {
- addClientToSession(peer);
- } else {
- clientQueue.append(peer);
- }
+
+bool SessionThread::isSessionInitialized()
+{
+ return _sessionInitialized;
}
-void SessionThread::addClientToSession(QObject *peer) {
- QIODevice *socket = qobject_cast<QIODevice *>(peer);
- if(socket) {
- addRemoteClientToSession(socket);
- return;
- }
- SignalProxy *proxy = qobject_cast<SignalProxy *>(peer);
- if(proxy) {
- addInternalClientToSession(proxy);
- return;
- }
+void SessionThread::setSessionInitialized()
+{
+ _sessionInitialized = true;
+ foreach(QObject *peer, clientQueue) {
+ addClientToSession(peer);
+ }
+ clientQueue.clear();
+}
+
- qWarning() << "SessionThread::addClient() received neither QIODevice nor SignalProxy as peer!" << peer;
+void SessionThread::addClient(QObject *peer)
+{
+ if (isSessionInitialized()) {
+ addClientToSession(peer);
+ }
+ else {
+ clientQueue.append(peer);
+ }
}
-void SessionThread::addRemoteClientToSession(QIODevice *socket) {
- socket->setParent(0);
- socket->moveToThread(session()->thread());
- emit addRemoteClient(socket);
+
+void SessionThread::addClientToSession(QObject *peer)
+{
+ QIODevice *socket = qobject_cast<QIODevice *>(peer);
+ if (socket) {
+ addRemoteClientToSession(socket);
+ return;
+ }
+
+ SignalProxy *proxy = qobject_cast<SignalProxy *>(peer);
+ if (proxy) {
+ addInternalClientToSession(proxy);
+ return;
+ }
+
+ qWarning() << "SessionThread::addClient() received neither QIODevice nor SignalProxy as peer!" << peer;
}
-void SessionThread::addInternalClientToSession(SignalProxy *proxy) {
- emit addInternalClient(proxy);
+
+void SessionThread::addRemoteClientToSession(QIODevice *socket)
+{
+ socket->setParent(0);
+ socket->moveToThread(session()->thread());
+ emit addRemoteClient(socket);
}
-void SessionThread::run() {
- _session = new CoreSession(user(), _restoreState);
- connect(this, SIGNAL(addRemoteClient(QIODevice *)), _session, SLOT(addClient(QIODevice *)));
- connect(this, SIGNAL(addInternalClient(SignalProxy *)), _session, SLOT(addClient(SignalProxy *)));
- connect(_session, SIGNAL(sessionState(const QVariant &)), Core::instance(), SIGNAL(sessionState(const QVariant &)));
- emit initialized();
- exec();
- delete _session;
+
+void SessionThread::addInternalClientToSession(SignalProxy *proxy)
+{
+ emit addInternalClient(proxy);
}
+
+void SessionThread::run()
+{
+ _session = new CoreSession(user(), _restoreState);
+ connect(this, SIGNAL(addRemoteClient(QIODevice *)), _session, SLOT(addClient(QIODevice *)));
+ connect(this, SIGNAL(addInternalClient(SignalProxy *)), _session, SLOT(addClient(SignalProxy *)));
+ connect(_session, SIGNAL(sessionState(const QVariant &)), Core::instance(), SIGNAL(sessionState(const QVariant &)));
+ emit initialized();
+ exec();
+ delete _session;
+}