aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorLinus Jahn <lnj@kaidan.im>2022-03-13 01:23:33 +0100
committerLinus Jahn <lnj@kaidan.im>2022-03-13 02:11:14 +0100
commit8cf5dc45bedcc2e186839b590f5e915a88c36507 (patch)
treeb8f75fc36f942d7abf23992b5d96c36a8c9afa05 /src
parentf80ffa643eb0336b64d83d9dbe55ecbaa559565f (diff)
downloadqxmpp-8cf5dc45bedcc2e186839b590f5e915a88c36507.tar.gz
server: Add missing emit on signals
Diffstat (limited to 'src')
-rw-r--r--src/server/QXmppIncomingClient.cpp12
-rw-r--r--src/server/QXmppServer.cpp12
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());
}
}