X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fcore.h;h=a2a15ae4e61c23d3f2cccddf8d1bd6c86b237c07;hp=1288ae01df6920f54d81f4835e41377341e72ecd;hb=1eb21546673535f5707aa6346e8c749b928cd772;hpb=52a7b4d0f289f075aa386445a47d876743bcb6d0 diff --git a/src/core/core.h b/src/core/core.h index 1288ae01..a2a15ae4 100644 --- a/src/core/core.h +++ b/src/core/core.h @@ -27,22 +27,22 @@ #include #include -#ifndef QT_NO_OPENSSL -#include -#include "sslserver.h" +#ifdef HAVE_SSL +# include +# include "sslserver.h" #else -#include -#include +# include +# include #endif #include "bufferinfo.h" #include "message.h" -#include "global.h" #include "sessionthread.h" #include "types.h" class CoreSession; class SessionThread; +class SignalProxy; class Storage; struct NetworkInfo; @@ -66,7 +66,7 @@ class Core : public QObject { * \param data The Value */ static void setUserSetting(UserId userId, const QString &settingName, const QVariant &data); - + //! Retrieve a persistent user setting /** * \param userId The users Id @@ -76,7 +76,7 @@ class Core : public QObject { */ static QVariant getUserSetting(UserId userId, const QString &settingName, const QVariant &data = QVariant()); - + //! Create a Network in the Storage and store it's Id in the given NetworkInfo /** \note This method is thredsafe. * @@ -85,7 +85,7 @@ class Core : public QObject { * \return true if successfull. */ static bool createNetwork(UserId user, NetworkInfo &info); - + //! Apply the changes to NetworkInfo info to the storage engine /** \note This method is thredsafe. * @@ -103,7 +103,7 @@ class Core : public QObject { * \return true if successfull. */ static bool removeNetwork(UserId user, const NetworkId &networkId); - + //! Returns a list of all NetworkInfos for the given UserId user /** \note This method is thredsafe. * @@ -186,7 +186,7 @@ class Core : public QObject { */ static BufferInfo getBufferInfo(UserId user, const BufferId &bufferId); - + //! Store a Message in the backlog. /** \note This method is threadsafe. * @@ -282,26 +282,31 @@ class Core : public QObject { */ static QHash bufferLastSeenMsgIds(UserId user); + const QDateTime &startTime() const { return _startTime; } + 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); + //! Relay From CoreSession::sessionState(const QVariant &). Used for internal connection only + void sessionState(const QVariant &); + private slots: - bool startListening(uint port = Global::defaultPort); - void stopListening(); + bool startListening(); + void stopListening(const QString &msg = QString()); void incomingConnection(); void clientHasData(); void clientDisconnected(); bool initStorage(QVariantMap dbSettings, bool setup = false); -#ifndef QT_NO_OPENSSL +#ifdef HAVE_SSL void sslErrors(const QList &errors); #endif void socketError(QAbstractSocket::SocketError); @@ -316,7 +321,8 @@ class Core : public QObject { void setupClientSession(QTcpSocket *socket, UserId uid); void processClientMessage(QTcpSocket *socket, const QVariantMap &msg); //void processCoreSetup(QTcpSocket *socket, QVariantMap &msg); - QString setupCore(const QVariant &setupData); + QString setupCoreForInternalUsage(); + QString setupCore(QVariantMap setupData); bool registerStorageBackend(Storage *); void unregisterStorageBackend(Storage *); @@ -325,18 +331,18 @@ class Core : public QObject { Storage *storage; QTimer _storageSyncTimer; -#ifndef QT_NO_OPENSSL - SslServer server; +#ifdef HAVE_SSL + SslServer _server, _v6server; #else - QTcpServer server; -#endif + QTcpServer _server, _v6server; +#endif QHash blocksizes; QHash clientInfo; QHash _storageBackends; - QDateTime startTime; + QDateTime _startTime; bool configured;