X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcore%2Fcore.h;h=45d06072298569ad4cbdddb4900a7cbf6fb1892d;hb=fcacaaf16551524c7ebb6114254d005274cc3d63;hp=102252b6683db4aa405c03c1f134cc7aea207aab;hpb=f88bfa81380ceb2c4afce5b15f753570a1ef063d;p=quassel.git diff --git a/src/core/core.h b/src/core/core.h index 102252b6..45d06072 100644 --- a/src/core/core.h +++ b/src/core/core.h @@ -20,6 +20,8 @@ #pragma once +#include "core-export.h" + #include #include @@ -44,6 +46,7 @@ #include "message.h" #include "oidentdconfiggenerator.h" #include "sessionthread.h" +#include "singleton.h" #include "storage.h" #include "types.h" @@ -58,18 +61,22 @@ struct NetworkInfo; class AbstractSqlMigrationReader; class AbstractSqlMigrationWriter; -class Core : public QObject +class CORE_EXPORT Core : public QObject, public Singleton { Q_OBJECT public: - static Core *instance(); - Core(); ~Core() override; void init(); + /** + * Shuts down active core sessions, saves state and emits the shutdownComplete() signal afterwards. + */ + void shutdown(); + + /*** Storage access ***/ // These methods are threadsafe. @@ -556,13 +563,6 @@ public: return instance()->_storage->setBufferLastSeenMsg(user, bufferId, msgId); } - //! Get the auth username associated with a userId - /** \param user The user to retrieve the username for - * \return The username for the user - */ - static inline QString getAuthUserName(UserId user) { - return instance()->_storage->getAuthUserName(user); - } //! Get a usable sysident for the given user in oidentd-strict mode /** \param user The user to retrieve the sysident for @@ -712,6 +712,9 @@ signals: //! Emitted when a fatal error was encountered during async initialization void exitRequested(int exitCode, const QString &reason); + //! Emitted once core shutdown is complete + void shutdownComplete(); + public slots: void initAsync(); @@ -755,6 +758,8 @@ private slots: bool changeUserPass(const QString &username); + void onSessionShutdown(SessionThread *session); + private: SessionThread *sessionForUser(UserId userId, bool restoreState = false); void addClientHelper(RemotePeer *peer, UserId uid);