aboutsummaryrefslogtreecommitdiff
path: root/src/base/QXmppStreamManagement.cpp
diff options
context:
space:
mode:
authorLinus Jahn <lnj@kaidan.im>2022-08-16 21:00:15 +0200
committerLinus Jahn <lnj@kaidan.im>2023-01-03 22:05:54 +0100
commitb17284ee7d674416e0d11f1699f73fcc606262d4 (patch)
tree86597f2bc2a1ed2d257e0cbf8e7de1ca54080c08 /src/base/QXmppStreamManagement.cpp
parent3271c6642439d4d3c0d8c634e2b3f4cf17b908a0 (diff)
downloadqxmpp-b17284ee7d674416e0d11f1699f73fcc606262d4.tar.gz
Introduce QXmppTask & QXmppPromise
Closes #502. Co-authored-by: Jonah BrĂ¼chert <jbb@kaidan.im>
Diffstat (limited to 'src/base/QXmppStreamManagement.cpp')
-rw-r--r--src/base/QXmppStreamManagement.cpp13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/base/QXmppStreamManagement.cpp b/src/base/QXmppStreamManagement.cpp
index 853327f9..f3b183e1 100644
--- a/src/base/QXmppStreamManagement.cpp
+++ b/src/base/QXmppStreamManagement.cpp
@@ -353,13 +353,12 @@ void QXmppStreamManager::handlePacketSent(QXmppPacket &packet, bool sentData)
sendAcknowledgementRequest();
} else {
if (sentData) {
- packet.reportResult(QXmpp::SendSuccess { false });
+ packet.reportFinished(QXmpp::SendSuccess { false });
} else {
- packet.reportResult(QXmppError {
+ packet.reportFinished(QXmppError {
QStringLiteral("Couldn't write data to socket. No stream management enabled."),
QXmpp::SendError::SocketWriteError });
}
- packet.reportFinished();
}
}
@@ -418,8 +417,7 @@ void QXmppStreamManager::setAcknowledgedSequenceNumber(unsigned int sequenceNumb
{
for (auto it = m_unacknowledgedStanzas.begin(); it != m_unacknowledgedStanzas.end();) {
if (it.key() <= sequenceNumber) {
- it->reportResult(QXmpp::SendSuccess { true });
- it->reportFinished();
+ it->reportFinished(QXmpp::SendSuccess { true });
it = m_unacknowledgedStanzas.erase(it);
} else {
break;
@@ -472,8 +470,9 @@ void QXmppStreamManager::sendAcknowledgementRequest()
void QXmppStreamManager::resetCache()
{
for (auto &packet : m_unacknowledgedStanzas) {
- packet.reportResult(QXmppError { QStringLiteral("Disconnected"), QXmpp::SendError::Disconnected });
- packet.reportFinished();
+ packet.reportFinished(QXmppError {
+ QStringLiteral("Disconnected"),
+ QXmpp::SendError::Disconnected });
}
m_unacknowledgedStanzas.clear();