diff options
| author | JBB <jbb.prv@gmx.de> | 2020-01-20 00:19:38 +0100 |
|---|---|---|
| committer | LNJ <lnj@kaidan.im> | 2020-01-20 00:19:38 +0100 |
| commit | 8557bc3a605e5d2b1a7dae5999501b19c1c99b58 (patch) | |
| tree | f17fefa61a26e01c99884c7d3e458b8ea70b181b /src/server | |
| parent | cccb7675e0eb9d411c736d1ff3f189fb75ef33dd (diff) | |
Port majority of old-style connects (#237)
This provides more type safety and is future-proof.
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/QXmppIncomingClient.cpp | 22 | ||||
| -rw-r--r-- | src/server/QXmppIncomingServer.cpp | 13 | ||||
| -rw-r--r-- | src/server/QXmppOutgoingServer.cpp | 26 | ||||
| -rw-r--r-- | src/server/QXmppPasswordChecker.cpp | 2 | ||||
| -rw-r--r-- | src/server/QXmppServer.cpp | 69 |
5 files changed, 49 insertions, 83 deletions
diff --git a/src/server/QXmppIncomingClient.cpp b/src/server/QXmppIncomingClient.cpp index d3cd5cd9..c7da7bfd 100644 --- a/src/server/QXmppIncomingClient.cpp +++ b/src/server/QXmppIncomingClient.cpp @@ -77,14 +77,14 @@ void QXmppIncomingClientPrivate::checkCredentials(const QByteArray &response) QXmppPasswordReply *reply = passwordChecker->checkPassword(request); reply->setParent(q); reply->setProperty("__sasl_raw", response); - QObject::connect(reply, SIGNAL(finished()), - q, SLOT(onPasswordReply())); + QObject::connect(reply, &QXmppPasswordReply::finished, + q, &QXmppIncomingClient::onPasswordReply); } else if (saslServer->mechanism() == "DIGEST-MD5") { QXmppPasswordReply *reply = passwordChecker->getDigest(request); reply->setParent(q); reply->setProperty("__sasl_raw", response); - QObject::connect(reply, SIGNAL(finished()), - q, SLOT(onDigestReply())); + QObject::connect(reply, &QXmppPasswordReply::finished, + q, &QXmppIncomingClient::onDigestReply); } } @@ -107,16 +107,13 @@ QString QXmppIncomingClientPrivate::origin() const QXmppIncomingClient::QXmppIncomingClient(QSslSocket *socket, const QString &domain, QObject *parent) : QXmppStream(parent) { - bool check; - Q_UNUSED(check); d = new QXmppIncomingClientPrivate(this); d->domain = domain; if (socket) { - check = connect(socket, SIGNAL(disconnected()), - this, SLOT(onSocketDisconnected())); - Q_ASSERT(check); + connect(socket, &QAbstractSocket::disconnected, + this, &QXmppIncomingClient::onSocketDisconnected); setSocket(socket); } @@ -126,9 +123,8 @@ QXmppIncomingClient::QXmppIncomingClient(QSslSocket *socket, const QString &doma // create inactivity timer d->idleTimer = new QTimer(this); d->idleTimer->setSingleShot(true); - check = connect(d->idleTimer, SIGNAL(timeout()), - this, SLOT(onTimeout())); - Q_ASSERT(check); + connect(d->idleTimer, &QTimer::timeout, + this, &QXmppIncomingClient::onTimeout); } /// Destroys the current stream. @@ -465,7 +461,7 @@ void QXmppIncomingClient::onTimeout() disconnectFromHost(); // make sure disconnected() gets emitted no matter what - QTimer::singleShot(30, this, SIGNAL(disconnected())); + QTimer::singleShot(30, this, &QXmppStream::disconnected); } diff --git a/src/server/QXmppIncomingServer.cpp b/src/server/QXmppIncomingServer.cpp index 1963221b..f121e479 100644 --- a/src/server/QXmppIncomingServer.cpp +++ b/src/server/QXmppIncomingServer.cpp @@ -71,16 +71,13 @@ QString QXmppIncomingServerPrivate::origin() const QXmppIncomingServer::QXmppIncomingServer(QSslSocket *socket, const QString &domain, QObject *parent) : QXmppStream(parent) { - bool check; - Q_UNUSED(check); d = new QXmppIncomingServerPrivate(this); d->domain = domain; if (socket) { - check = connect(socket, SIGNAL(disconnected()), - this, SLOT(slotSocketDisconnected())); - Q_ASSERT(check); + connect(socket, &QAbstractSocket::disconnected, + this, &QXmppIncomingServer::slotSocketDisconnected); setSocket(socket); } @@ -160,10 +157,8 @@ void QXmppIncomingServer::handleStanza(const QDomElement &stanza) // establish dialback connection auto *stream = new QXmppOutgoingServer(d->domain, this); - bool check = connect(stream, SIGNAL(dialbackResponseReceived(QXmppDialback)), - this, SLOT(slotDialbackResponseReceived(QXmppDialback))); - Q_ASSERT(check); - Q_UNUSED(check); + connect(stream, &QXmppOutgoingServer::dialbackResponseReceived, + this, &QXmppIncomingServer::slotDialbackResponseReceived); stream->setVerify(d->localStreamId, request.key()); stream->connectToHost(domain); } diff --git a/src/server/QXmppOutgoingServer.cpp b/src/server/QXmppOutgoingServer.cpp index 4e2e274c..aec5018a 100644 --- a/src/server/QXmppOutgoingServer.cpp +++ b/src/server/QXmppOutgoingServer.cpp @@ -22,8 +22,10 @@ */ #include <QDomElement> +#include <QSslError> #include <QSslKey> #include <QSslSocket> +#include <QList> #include <QTimer> #include <QDnsLookup> @@ -57,39 +59,25 @@ QXmppOutgoingServer::QXmppOutgoingServer(const QString &domain, QObject *parent) : QXmppStream(parent), d(new QXmppOutgoingServerPrivate) { - bool check; - Q_UNUSED(check); - // socket initialisation auto *socket = new QSslSocket(this); setSocket(socket); - check = connect(socket, SIGNAL(disconnected()), - this, SLOT(_q_socketDisconnected())); - Q_ASSERT(check); - - check = connect(socket, SIGNAL(error(QAbstractSocket::SocketError)), - this, SLOT(socketError(QAbstractSocket::SocketError))); - Q_ASSERT(check); + connect(socket, &QAbstractSocket::disconnected, this, &QXmppOutgoingServer::_q_socketDisconnected); + connect(socket, QOverload<QAbstractSocket::SocketError>::of(&QSslSocket::error), this, &QXmppOutgoingServer::socketError); // DNS lookups - check = connect(&d->dns, SIGNAL(finished()), - this, SLOT(_q_dnsLookupFinished())); - Q_ASSERT(check); + connect(&d->dns, &QDnsLookup::finished, this, &QXmppOutgoingServer::_q_dnsLookupFinished); d->dialbackTimer = new QTimer(this); d->dialbackTimer->setInterval(5000); d->dialbackTimer->setSingleShot(true); - check = connect(d->dialbackTimer, SIGNAL(timeout()), - this, SLOT(sendDialback())); - Q_ASSERT(check); + connect(d->dialbackTimer, &QTimer::timeout, this, &QXmppOutgoingServer::sendDialback); d->localDomain = domain; d->ready = false; - check = connect(socket, SIGNAL(sslErrors(QList<QSslError>)), - this, SLOT(slotSslErrors(QList<QSslError>))); - Q_ASSERT(check); + connect(socket, QOverload<const QList<QSslError> &>::of(&QSslSocket::sslErrors), this, &QXmppOutgoingServer::slotSslErrors); } /// Destroys the stream. diff --git a/src/server/QXmppPasswordChecker.cpp b/src/server/QXmppPasswordChecker.cpp index 45ce4604..70bfad83 100644 --- a/src/server/QXmppPasswordChecker.cpp +++ b/src/server/QXmppPasswordChecker.cpp @@ -128,7 +128,7 @@ void QXmppPasswordReply::finish() void QXmppPasswordReply::finishLater() { - QTimer::singleShot(0, this, SLOT(finish())); + QTimer::singleShot(0, this, &QXmppPasswordReply::finish); } /// Returns true when the reply has finished. diff --git a/src/server/QXmppServer.cpp b/src/server/QXmppServer.cpp index 71a55181..2cf25362 100644 --- a/src/server/QXmppServer.cpp +++ b/src/server/QXmppServer.cpp @@ -152,8 +152,6 @@ bool QXmppServerPrivate::routeData(const QString &to, const QByteArray &data) } else if (!serversForServers.isEmpty()) { - bool check; - Q_UNUSED(check); // look for an outgoing S2S connection for (auto *conn : qAsConst(outgoingServers)) { @@ -171,9 +169,8 @@ bool QXmppServerPrivate::routeData(const QString &to, const QByteArray &data) conn->moveToThread(q->thread()); conn->setParent(q); - check = QObject::connect(conn, SIGNAL(disconnected()), - q, SLOT(_q_outgoingServerDisconnected())); - Q_UNUSED(check); + QObject::connect(conn, &QXmppStream::disconnected, + q, &QXmppServer::_q_outgoingServerDisconnected); // add stream outgoingServers.insert(conn); @@ -387,22 +384,22 @@ void QXmppServer::setLogger(QXmppLogger *logger) { if (logger != d->logger) { if (d->logger) { - disconnect(this, SIGNAL(logMessage(QXmppLogger::MessageType,QString)), - d->logger, SLOT(log(QXmppLogger::MessageType,QString))); - disconnect(this, SIGNAL(setGauge(QString,double)), - d->logger, SLOT(setGauge(QString,double))); - disconnect(this, SIGNAL(updateCounter(QString,qint64)), - d->logger, SLOT(updateCounter(QString,qint64))); + disconnect(this, &QXmppLoggable::logMessage, + d->logger, &QXmppLogger::log); + disconnect(this, &QXmppLoggable::setGauge, + d->logger, &QXmppLogger::setGauge); + disconnect(this, &QXmppLoggable::updateCounter, + d->logger, &QXmppLogger::updateCounter); } d->logger = logger; if (d->logger) { - connect(this, SIGNAL(logMessage(QXmppLogger::MessageType,QString)), - d->logger, SLOT(log(QXmppLogger::MessageType,QString))); - connect(this, SIGNAL(setGauge(QString,double)), - d->logger, SLOT(setGauge(QString,double))); - connect(this, SIGNAL(updateCounter(QString,qint64)), - d->logger, SLOT(updateCounter(QString,qint64))); + connect(this, &QXmppLoggable::logMessage, + d->logger, &QXmppLogger::log); + connect(this, &QXmppLoggable::setGauge, + d->logger, &QXmppLogger::setGauge); + connect(this, &QXmppLoggable::updateCounter, + d->logger, &QXmppLogger::updateCounter); } emit loggerChanged(d->logger); @@ -540,7 +537,7 @@ void QXmppServer::setPrivateKey(const QSslKey &key) bool QXmppServer::listenForClients(const QHostAddress &address, quint16 port) { bool check; - Q_UNUSED(check); + Q_UNUSED(check) if (d->domain.isEmpty()) { d->warning("No domain was specified!"); @@ -604,7 +601,7 @@ void QXmppServer::close() bool QXmppServer::listenForServers(const QHostAddress &address, quint16 port) { bool check; - Q_UNUSED(check); + Q_UNUSED(check) if (d->domain.isEmpty()) { d->warning("No domain was specified!"); @@ -672,22 +669,17 @@ bool QXmppServer::sendPacket(const QXmppStanza &packet) void QXmppServer::addIncomingClient(QXmppIncomingClient *stream) { - bool check; - Q_UNUSED(check); stream->setPasswordChecker(d->passwordChecker); - check = connect(stream, SIGNAL(connected()), - this, SLOT(_q_clientConnected())); - Q_ASSERT(check); + connect(stream, &QXmppStream::connected, + this, &QXmppServer::_q_clientConnected); - check = connect(stream, SIGNAL(disconnected()), - this, SLOT(_q_clientDisconnected())); - Q_ASSERT(check); + connect(stream, &QXmppStream::disconnected, + this, &QXmppServer::_q_clientDisconnected); - check = connect(stream, SIGNAL(elementReceived(QDomElement)), - this, SLOT(handleElement(QDomElement))); - Q_ASSERT(check); + connect(stream, &QXmppIncomingClient::elementReceived, + this, &QXmppServer::handleElement); // add stream d->incomingClients.insert(stream); @@ -824,8 +816,6 @@ void QXmppServer::_q_outgoingServerDisconnected() void QXmppServer::_q_serverConnection(QSslSocket *socket) { - bool check; - Q_UNUSED(check); // check the socket didn't die since the signal was emitted if (socket->state() != QAbstractSocket::ConnectedState) { @@ -836,17 +826,14 @@ void QXmppServer::_q_serverConnection(QSslSocket *socket) auto *stream = new QXmppIncomingServer(socket, d->domain, this); socket->setParent(stream); - check = connect(stream, SIGNAL(disconnected()), - this, SLOT(_q_serverDisconnected())); - Q_ASSERT(check); + connect(stream, &QXmppStream::disconnected, + this, &QXmppServer::_q_serverDisconnected); - check = connect(stream, SIGNAL(dialbackRequestReceived(QXmppDialback)), - this, SLOT(_q_dialbackRequestReceived(QXmppDialback))); - Q_ASSERT(check); + connect(stream, &QXmppIncomingServer::dialbackRequestReceived, + this, &QXmppServer::_q_dialbackRequestReceived); - check = connect(stream, SIGNAL(elementReceived(QDomElement)), - this, SLOT(handleElement(QDomElement))); - Q_ASSERT(check); + connect(stream, &QXmppIncomingServer::elementReceived, + this, &QXmppServer::handleElement); // add stream d->incomingServers.insert(stream); |
