diff options
| author | Linus Jahn <lnj@kaidan.im> | 2022-03-13 01:23:33 +0100 |
|---|---|---|
| committer | Linus Jahn <lnj@kaidan.im> | 2022-03-13 02:11:14 +0100 |
| commit | 8cf5dc45bedcc2e186839b590f5e915a88c36507 (patch) | |
| tree | b8f75fc36f942d7abf23992b5d96c36a8c9afa05 /src/server | |
| parent | f80ffa643eb0336b64d83d9dbe55ecbaa559565f (diff) | |
| download | qxmpp-8cf5dc45bedcc2e186839b590f5e915a88c36507.tar.gz | |
server: Add missing emit on signals
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/QXmppIncomingClient.cpp | 12 | ||||
| -rw-r--r-- | src/server/QXmppServer.cpp | 12 |
2 files changed, 12 insertions, 12 deletions
diff --git a/src/server/QXmppIncomingClient.cpp b/src/server/QXmppIncomingClient.cpp index 227c8ca5..de27d3e2 100644 --- a/src/server/QXmppIncomingClient.cpp +++ b/src/server/QXmppIncomingClient.cpp @@ -274,7 +274,7 @@ void QXmppIncomingClient::handleStanza(const QDomElement &nodeRecv) // authentication succeeded d->jid = QString("%1@%2").arg(d->saslServer->username(), d->domain); info(QString("Authentication succeeded for '%1' from %2").arg(d->jid, d->origin())); - updateCounter("incoming-client.auth.success"); + emit updateCounter("incoming-client.auth.success"); sendPacket(QXmppSaslSuccess()); handleStart(); } else { @@ -359,7 +359,7 @@ void QXmppIncomingClient::onDigestReply() if (reply->error() == QXmppPasswordReply::TemporaryError) { warning(QString("Temporary authentication failure for '%1' from %2").arg(d->saslServer->username(), d->origin())); - updateCounter("incoming-client.auth.temporary-auth-failure"); + emit updateCounter("incoming-client.auth.temporary-auth-failure"); sendPacket(QXmppSaslFailure("temporary-auth-failure")); disconnectFromHost(); return; @@ -371,7 +371,7 @@ void QXmppIncomingClient::onDigestReply() QXmppSaslServer::Response result = d->saslServer->respond(reply->property("__sasl_raw").toByteArray(), challenge); if (result != QXmppSaslServer::Challenge) { warning(QString("Authentication failed for '%1' from %2").arg(d->saslServer->username(), d->origin())); - updateCounter("incoming-client.auth.not-authorized"); + emit updateCounter("incoming-client.auth.not-authorized"); sendPacket(QXmppSaslFailure("not-authorized")); disconnectFromHost(); return; @@ -393,19 +393,19 @@ void QXmppIncomingClient::onPasswordReply() case QXmppPasswordReply::NoError: d->jid = jid; info(QString("Authentication succeeded for '%1' from %2").arg(d->jid, d->origin())); - updateCounter("incoming-client.auth.success"); + emit updateCounter("incoming-client.auth.success"); sendPacket(QXmppSaslSuccess()); handleStart(); break; case QXmppPasswordReply::AuthorizationError: warning(QString("Authentication failed for '%1' from %2").arg(jid, d->origin())); - updateCounter("incoming-client.auth.not-authorized"); + emit updateCounter("incoming-client.auth.not-authorized"); sendPacket(QXmppSaslFailure("not-authorized")); disconnectFromHost(); break; case QXmppPasswordReply::TemporaryError: warning(QString("Temporary authentication failure for '%1' from %2").arg(jid, d->origin())); - updateCounter("incoming-client.auth.temporary-auth-failure"); + emit updateCounter("incoming-client.auth.temporary-auth-failure"); sendPacket(QXmppSaslFailure("temporary-auth-failure")); disconnectFromHost(); break; diff --git a/src/server/QXmppServer.cpp b/src/server/QXmppServer.cpp index 18cbb485..793b9b60 100644 --- a/src/server/QXmppServer.cpp +++ b/src/server/QXmppServer.cpp @@ -154,7 +154,7 @@ bool QXmppServerPrivate::routeData(const QString &to, const QByteArray &data) // add stream outgoingServers.insert(conn); - q->setGauge("outgoing-server.count", outgoingServers.size()); + emit q->setGauge("outgoing-server.count", outgoingServers.size()); // queue data and connect to remote server QMetaObject::invokeMethod(conn, "queueData", Q_ARG(QByteArray, data)); @@ -669,7 +669,7 @@ void QXmppServer::addIncomingClient(QXmppIncomingClient *stream) // add stream d->incomingClients.insert(stream); - setGauge("incoming-client.count", d->incomingClients.size()); + emit setGauge("incoming-client.count", d->incomingClients.size()); } /// Handle a new incoming TCP connection from a client. @@ -745,7 +745,7 @@ void QXmppServer::_q_clientDisconnected() emit clientDisconnected(jid); // update counter - setGauge("incoming-client.count", d->incomingClients.size()); + emit setGauge("incoming-client.count", d->incomingClients.size()); } } @@ -791,7 +791,7 @@ void QXmppServer::_q_outgoingServerDisconnected() if (d->outgoingServers.remove(outgoing)) { outgoing->deleteLater(); - setGauge("outgoing-server.count", d->outgoingServers.size()); + emit setGauge("outgoing-server.count", d->outgoingServers.size()); } } @@ -822,7 +822,7 @@ void QXmppServer::_q_serverConnection(QSslSocket *socket) // add stream d->incomingServers.insert(stream); - setGauge("incoming-server.count", d->incomingServers.size()); + emit setGauge("incoming-server.count", d->incomingServers.size()); } /// Handle a stream disconnection for an incoming server. @@ -835,7 +835,7 @@ void QXmppServer::_q_serverDisconnected() if (d->incomingServers.remove(incoming)) { incoming->deleteLater(); - setGauge("incoming-server.count", d->incomingServers.size()); + emit setGauge("incoming-server.count", d->incomingServers.size()); } } |
