X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcore%2Fsessionthread.cpp;h=7b8bc105655bb9978345c8c22564dbbe816d51bf;hb=cdc6091a2e02b84a48937cda287a0769ceb8726a;hp=49790dfdc114142299a02bf536198d8719df0f75;hpb=0e1b154f362e13c2c9009f842e3fd6d8e7c346fc;p=quassel.git diff --git a/src/core/sessionthread.cpp b/src/core/sessionthread.cpp index 49790dfd..7b8bc105 100644 --- a/src/core/sessionthread.cpp +++ b/src/core/sessionthread.cpp @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2012 by the Quassel Project * + * Copyright (C) 2005-2018 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -20,17 +20,18 @@ #include "core.h" #include "coresession.h" -#include "internalconnection.h" -#include "remoteconnection.h" +#include "internalpeer.h" +#include "remotepeer.h" #include "sessionthread.h" #include "signalproxy.h" -SessionThread::SessionThread(UserId uid, bool restoreState, QObject *parent) +SessionThread::SessionThread(UserId uid, bool restoreState, bool strictIdentEnabled, QObject *parent) : QThread(parent), _session(0), _user(uid), _sessionInitialized(false), - _restoreState(restoreState) + _restoreState(restoreState), + _strictIdentEnabled(strictIdentEnabled) { connect(this, SIGNAL(initialized()), this, SLOT(setSessionInitialized())); } @@ -86,13 +87,13 @@ void SessionThread::addClient(QObject *peer) void SessionThread::addClientToSession(QObject *peer) { - RemoteConnection *connection = qobject_cast(peer); - if (connection) { - addRemoteClientToSession(connection); + RemotePeer *remote = qobject_cast(peer); + if (remote) { + addRemoteClientToSession(remote); return; } - InternalConnection *internal = qobject_cast(peer); + InternalPeer *internal = qobject_cast(peer); if (internal) { addInternalClientToSession(internal); return; @@ -102,28 +103,28 @@ void SessionThread::addClientToSession(QObject *peer) } -void SessionThread::addRemoteClientToSession(RemoteConnection *connection) +void SessionThread::addRemoteClientToSession(RemotePeer *remotePeer) { - connection->setParent(0); - connection->moveToThread(session()->thread()); - emit addRemoteClient(connection); + remotePeer->setParent(0); + remotePeer->moveToThread(session()->thread()); + emit addRemoteClient(remotePeer); } -void SessionThread::addInternalClientToSession(InternalConnection *connection) +void SessionThread::addInternalClientToSession(InternalPeer *internalPeer) { - connection->setParent(0); - connection->moveToThread(session()->thread()); - emit addInternalClient(connection); + internalPeer->setParent(0); + internalPeer->moveToThread(session()->thread()); + emit addInternalClient(internalPeer); } void SessionThread::run() { - _session = new CoreSession(user(), _restoreState); - connect(this, SIGNAL(addRemoteClient(RemoteConnection*)), _session, SLOT(addClient(RemoteConnection*))); - connect(this, SIGNAL(addInternalClient(InternalConnection*)), _session, SLOT(addClient(InternalConnection*))); - connect(_session, SIGNAL(sessionState(QVariant)), Core::instance(), SIGNAL(sessionState(QVariant))); + _session = new CoreSession(user(), _restoreState, _strictIdentEnabled); + connect(this, SIGNAL(addRemoteClient(RemotePeer*)), _session, SLOT(addClient(RemotePeer*))); + connect(this, SIGNAL(addInternalClient(InternalPeer*)), _session, SLOT(addClient(InternalPeer*))); + connect(_session, SIGNAL(sessionState(Protocol::SessionState)), Core::instance(), SIGNAL(sessionState(Protocol::SessionState))); emit initialized(); exec(); delete _session;