X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Fidentserver.h;h=6c7340db9a6f9d2d27b98639961d701b467c72c9;hp=fac112c62df88cb4718e3b02e7337dcc2fcd29c6;hb=8bdfd0d16857c508f543298ad98f6262127f2886;hpb=e212eabe53878a8fa6ecb15909a325ed7dd63283 diff --git a/src/core/identserver.h b/src/core/identserver.h index fac112c6..6c7340db 100644 --- a/src/core/identserver.h +++ b/src/core/identserver.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2018 by the Quassel Project * + * Copyright (C) 2005-2019 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -35,31 +35,43 @@ struct Request { QPointer socket; uint16_t localPort; + uint16_t remotePort; QString query; qint64 transactionId; qint64 requestId; - friend bool operator==(const Request &a, const Request &b); + friend bool operator==(const Request& a, const Request& b); - void respondSuccess(const QString &user); - void respondError(const QString &error); -}; + void respondSuccess(const QString& user); + void respondError(const QString& error); + const static int DISCONNECTION_TIMEOUT = 500; +}; class IdentServer : public QObject { Q_OBJECT public: - IdentServer(bool strict, QObject *parent = nullptr); + IdentServer(QObject* parent = nullptr); bool startListening(); - void stopListening(const QString &msg); + void stopListening(const QString& msg); qint64 addWaitingSocket(); public slots: - void addSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort, qint64 socketId); - void removeSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort, qint64 socketId); + void addSocket(const CoreIdentity* identity, + const QHostAddress& localAddress, + quint16 localPort, + const QHostAddress& peerAddress, + quint16 peerPort, + qint64 socketId); + void removeSocket(const CoreIdentity* identity, + const QHostAddress& localAddress, + quint16 localPort, + const QHostAddress& peerAddress, + quint16 peerPort, + qint64 socketId); private slots: void incomingConnection(); @@ -76,8 +88,6 @@ private: QTcpServer _server, _v6server; - bool _strict; - QHash _connections; std::list _requestQueue; std::list _waiting;