diff --git a/include/Swiften/Server/ServerStanzaChannel.cpp b/include/Swiften/Server/ServerStanzaChannel.cpp index 8150d20de6dfac12b85cac30d4943ad8a36b6649..dc3abe9b5fbb134380d036845c82dcf2fbbb6ec5 100644 --- a/include/Swiften/Server/ServerStanzaChannel.cpp +++ b/include/Swiften/Server/ServerStanzaChannel.cpp @@ -21,41 +21,41 @@ namespace { struct HasJID { HasJID(const JID& jid) : jid(jid) {} - bool operator()(const boost::shared_ptr session) const { + bool operator()(const SWIFTEN_SHRPTR_NAMESPACE::shared_ptr session) const { return session->getRemoteJID().equals(jid, JID::WithResource); } JID jid; }; } -void ServerStanzaChannel::addSession(boost::shared_ptr session) { +void ServerStanzaChannel::addSession(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr session) { sessions[session->getRemoteJID().toBare().toString()].push_back(session); session->onSessionFinished.connect(boost::bind(&ServerStanzaChannel::handleSessionFinished, this, _1, session)); session->onElementReceived.connect(boost::bind(&ServerStanzaChannel::handleElement, this, _1, session)); session->onDataRead.connect(boost::bind(&ServerStanzaChannel::handleDataRead, this, _1, session)); } -void ServerStanzaChannel::removeSession(boost::shared_ptr session) { +void ServerStanzaChannel::removeSession(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr session) { session->onSessionFinished.disconnect(boost::bind(&ServerStanzaChannel::handleSessionFinished, this, _1, session)); session->onElementReceived.disconnect(boost::bind(&ServerStanzaChannel::handleElement, this, _1, session)); session->onDataRead.disconnect(boost::bind(&ServerStanzaChannel::handleDataRead, this, _1, session)); - std::list > &lst = sessions[session->getRemoteJID().toBare().toString()]; + std::list > &lst = sessions[session->getRemoteJID().toBare().toString()]; lst.erase(std::remove(lst.begin(), lst.end(), session), lst.end()); } -void ServerStanzaChannel::sendIQ(boost::shared_ptr iq) { +void ServerStanzaChannel::sendIQ(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr iq) { send(iq); } -void ServerStanzaChannel::sendMessage(boost::shared_ptr message) { +void ServerStanzaChannel::sendMessage(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr message) { send(message); } -void ServerStanzaChannel::sendPresence(boost::shared_ptr presence) { +void ServerStanzaChannel::sendPresence(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr presence) { send(presence); } -void ServerStanzaChannel::handleDataRead(const SafeByteArray &data, const boost::shared_ptr &session) { +void ServerStanzaChannel::handleDataRead(const SafeByteArray &data, const SWIFTEN_SHRPTR_NAMESPACE::shared_ptr &session) { if (safeByteArrayToString(data).find("") != std::string::npos) { Swift::Presence::ref presence = Swift::Presence::create(); presence->setFrom(session->getRemoteJID()); @@ -64,16 +64,16 @@ void ServerStanzaChannel::handleDataRead(const SafeByteArray &data, const boost: } } #if HAVE_SWIFTEN_3 -void ServerStanzaChannel::finishSession(const JID& to, boost::shared_ptr element, bool last) { +void ServerStanzaChannel::finishSession(const JID& to, SWIFTEN_SHRPTR_NAMESPACE::shared_ptr element, bool last) { #else -void ServerStanzaChannel::finishSession(const JID& to, boost::shared_ptr element, bool last) { +void ServerStanzaChannel::finishSession(const JID& to, SWIFTEN_SHRPTR_NAMESPACE::shared_ptr element, bool last) { #endif - std::vector > candidateSessions; - for (std::list >::const_iterator i = sessions[to.toBare().toString()].begin(); i != sessions[to.toBare().toString()].end(); ++i) { + std::vector > candidateSessions; + for (std::list >::const_iterator i = sessions[to.toBare().toString()].begin(); i != sessions[to.toBare().toString()].end(); ++i) { candidateSessions.push_back(*i); } - for (std::vector >::const_iterator i = candidateSessions.begin(); i != candidateSessions.end(); ++i) { + for (std::vector >::const_iterator i = candidateSessions.begin(); i != candidateSessions.end(); ++i) { removeSession(*i); if (element) { (*i)->sendElement(element); @@ -98,7 +98,7 @@ std::string ServerStanzaChannel::getNewIQID() { return idGenerator.generateID(); } -void ServerStanzaChannel::send(boost::shared_ptr stanza) { +void ServerStanzaChannel::send(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr stanza) { JID to = stanza->getTo(); assert(to.isValid()); @@ -108,7 +108,7 @@ void ServerStanzaChannel::send(boost::shared_ptr stanza) { // For a full JID, first try to route to a session with the full JID if (!to.isBare()) { - std::list >::const_iterator i = std::find_if(sessions[stanza->getTo().toBare().toString()].begin(), sessions[stanza->getTo().toBare().toString()].end(), HasJID(to)); + std::list >::const_iterator i = std::find_if(sessions[stanza->getTo().toBare().toString()].begin(), sessions[stanza->getTo().toBare().toString()].end(), HasJID(to)); if (i != sessions[stanza->getTo().toBare().toString()].end()) { (*i)->sendElement(stanza); return; @@ -117,8 +117,8 @@ void ServerStanzaChannel::send(boost::shared_ptr stanza) { // Look for candidate sessions to = to.toBare(); - std::vector > candidateSessions; - for (std::list >::const_iterator i = sessions[stanza->getTo().toBare().toString()].begin(); i != sessions[stanza->getTo().toBare().toString()].end(); ++i) { + std::vector > candidateSessions; + for (std::list >::const_iterator i = sessions[stanza->getTo().toBare().toString()].begin(); i != sessions[stanza->getTo().toBare().toString()].end(); ++i) { if ((*i)->getRemoteJID().equals(to, JID::WithoutResource)) { candidateSessions.push_back(*i); (*i)->sendElement(stanza); @@ -134,7 +134,7 @@ void ServerStanzaChannel::send(boost::shared_ptr stanza) { return; } -void ServerStanzaChannel::handleSessionFinished(const boost::optional&, const boost::shared_ptr& session) { +void ServerStanzaChannel::handleSessionFinished(const boost::optional&, const SWIFTEN_SHRPTR_NAMESPACE::shared_ptr& session) { removeSession(session); // if (!session->initiatedFinish()) { @@ -145,8 +145,8 @@ void ServerStanzaChannel::handleSessionFinished(const boost::optional element, const boost::shared_ptr& session) { - boost::shared_ptr stanza = boost::dynamic_pointer_cast(element); +void ServerStanzaChannel::handleElement(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr element, const SWIFTEN_SHRPTR_NAMESPACE::shared_ptr& session) { + SWIFTEN_SHRPTR_NAMESPACE::shared_ptr stanza = SWIFTEN_SHRPTR_NAMESPACE::dynamic_pointer_cast(element); if (!stanza) { return; } @@ -157,19 +157,19 @@ void ServerStanzaChannel::handleElement(boost::shared_ptr element, cons return; - boost::shared_ptr message = boost::dynamic_pointer_cast(stanza); + SWIFTEN_SHRPTR_NAMESPACE::shared_ptr message = SWIFTEN_SHRPTR_NAMESPACE::dynamic_pointer_cast(stanza); if (message) { onMessageReceived(message); return; } - boost::shared_ptr presence = boost::dynamic_pointer_cast(stanza); + SWIFTEN_SHRPTR_NAMESPACE::shared_ptr presence = SWIFTEN_SHRPTR_NAMESPACE::dynamic_pointer_cast(stanza); if (presence) { onPresenceReceived(presence); return; } - boost::shared_ptr iq = boost::dynamic_pointer_cast(stanza); + SWIFTEN_SHRPTR_NAMESPACE::shared_ptr iq = SWIFTEN_SHRPTR_NAMESPACE::dynamic_pointer_cast(stanza); if (iq) { onIQReceived(iq); return;