Swiftdiff options
| author | Remko Tronçon <git@el-tramo.be> | 2010-08-29 12:51:45 (GMT) |
|---|---|---|
| committer | Remko Tronçon <git@el-tramo.be> | 2010-08-29 13:30:18 (GMT) |
| commit | 0091fcc571758791442f82ece2a72444b6fe79cf (patch) | |
| tree | 807f20a4047604a87f56d247d8ad7180489fe82b /Swiften/StreamManagement/StanzaAckRequester.cpp | |
| parent | 901f620b6ccabde19ef460368028fa0464aa56c5 (diff) | |
| download | swift-0091fcc571758791442f82ece2a72444b6fe79cf.zip swift-0091fcc571758791442f82ece2a72444b6fe79cf.tar.bz2 | |
Added Stanza Ack Requester & Responder.
Diffstat (limited to 'Swiften/StreamManagement/StanzaAckRequester.cpp')
| -rw-r--r-- | Swiften/StreamManagement/StanzaAckRequester.cpp | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/Swiften/StreamManagement/StanzaAckRequester.cpp b/Swiften/StreamManagement/StanzaAckRequester.cpp new file mode 100644 index 0000000..b007675 --- /dev/null +++ b/Swiften/StreamManagement/StanzaAckRequester.cpp @@ -0,0 +1,39 @@ +/* + * Copyright (c) 2010 Remko Tronçon + * Licensed under the GNU General Public License v3. + * See Documentation/Licenses/GPLv3.txt for more information. + */ + +#include "Swiften/StreamManagement/StanzaAckRequester.h" + +#include <boost/numeric/conversion/cast.hpp> + +namespace Swift { + +static const unsigned int MAX_HANDLED_STANZA_COUNT = boost::numeric_cast<unsigned int>((1ULL<<32) - 1); + +StanzaAckRequester::StanzaAckRequester() : lastHandledStanzasCount(0) { + +} + +void StanzaAckRequester::handleStanzaSent(boost::shared_ptr<Stanza> stanza) { + unackedStanzas.push_back(stanza); + onRequestAck(); +} + +void StanzaAckRequester::handleAckReceived(unsigned int handledStanzasCount) { + unsigned int i = lastHandledStanzasCount; + while (i != handledStanzasCount) { + if (unackedStanzas.size() == 0) { + std::cerr << "Warning: Server acked more stanzas than we sent" << std::endl; + break; + } + boost::shared_ptr<Stanza> ackedStanza = unackedStanzas.front(); + unackedStanzas.pop_front(); + onStanzaAcked(ackedStanza); + i = (i == MAX_HANDLED_STANZA_COUNT ? 0 : i + 1); + } + lastHandledStanzasCount = handledStanzasCount; +} + +} |