X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fcore.h;h=c1f397aed36641aaf73b0047e6b375949ac080ec;hp=fd67fa8a76420f94fdbdd9d419695ffdaf87e5e3;hb=e049ffc61b5e260a49d73102a74c3821af827e77;hpb=48f1843a91a923784b4a58b5bbe8a25aa7d395c8;ds=sidebyside diff --git a/src/core/core.h b/src/core/core.h index fd67fa8a..c1f397ae 100644 --- a/src/core/core.h +++ b/src/core/core.h @@ -51,8 +51,8 @@ class AbstractSqlMigrationWriter; class Core : public QObject { Q_OBJECT - public: - static Core * instance(); +public: + static Core *instance(); static void destroy(); static void saveState(); @@ -382,12 +382,15 @@ class Core : public QObject { static inline QTimer &syncTimer() { return instance()->_storageSyncTimer; } + static const int AddClientEventId; + public slots: //! Make storage data persistent /** \note This method is threadsafe. */ void syncStorage(); void setupInternalClientSession(SignalProxy *proxy); + signals: //! Sent when a BufferInfo is updated in storage. void bufferInfoUpdated(UserId user, const BufferInfo &info); @@ -395,6 +398,9 @@ signals: //! Relay From CoreSession::sessionState(const QVariant &). Used for internal connection only void sessionState(const QVariant &); +protected: + virtual void customEvent(QEvent *event); + private slots: bool startListening(); void stopListening(const QString &msg = QString()); @@ -418,6 +424,7 @@ private: SessionThread *createSession(UserId userId, bool restoreState = false); void setupClientSession(QTcpSocket *socket, UserId uid); + void addClientHelper(QTcpSocket *socket, UserId uid); void processClientMessage(QTcpSocket *socket, const QVariantMap &msg); //void processCoreSetup(QTcpSocket *socket, QVariantMap &msg); QString setupCoreForInternalUsage();