Davide Pesavento
82 lines
2.3 KiB
C++
82 lines
2.3 KiB
C++
/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil -*- */
|
|
/*
|
|
* Copyright (c) 2012-2023 University of California, Los Angeles
|
|
*
|
|
* This file is part of ChronoSync, synchronization library for distributed realtime
|
|
* applications for NDN.
|
|
*
|
|
* ChronoSync is free software: you can redistribute it and/or modify it under the terms
|
|
* of the GNU General Public License as published by the Free Software Foundation, either
|
|
* version 3 of the License, or (at your option) any later version.
|
|
*
|
|
* ChronoSync is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
|
|
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
|
|
* PURPOSE. See the GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License along with
|
|
* ChronoSync, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "dummy-forwarder.hpp"
|
|
|
|
#include <boost/asio/io_context.hpp>
|
|
#include <boost/asio/post.hpp>
|
|
|
|
namespace ndn {
|
|
namespace chronosync {
|
|
|
|
DummyForwarder::DummyForwarder(boost::asio::io_context& io, KeyChain& keyChain)
|
|
: m_io(io)
|
|
, m_keyChain(keyChain)
|
|
{
|
|
}
|
|
|
|
Face&
|
|
DummyForwarder::addFace()
|
|
{
|
|
auto face = std::make_shared<DummyClientFace>(m_io, m_keyChain, DummyClientFace::Options{true, true});
|
|
DummyClientFace* self = &*face; // to prevent memory leak
|
|
|
|
face->onSendInterest.connect([this, self] (const Interest& interest) {
|
|
Interest i(interest);
|
|
for (auto& otherFace : m_faces) {
|
|
if (self == &*otherFace) {
|
|
continue;
|
|
}
|
|
boost::asio::post(m_io, [=] { otherFace->receive(i); });
|
|
}
|
|
});
|
|
|
|
face->onSendData.connect([this, self] (const Data& data) {
|
|
Data d(data);
|
|
for (auto& otherFace : m_faces) {
|
|
if (self == &*otherFace) {
|
|
continue;
|
|
}
|
|
boost::asio::post(m_io, [=] { otherFace->receive(d); });
|
|
}
|
|
});
|
|
|
|
face->onSendNack.connect([this, self] (const lp::Nack& nack) {
|
|
lp::Nack n(nack);
|
|
for (auto& otherFace : m_faces) {
|
|
if (self == &*otherFace) {
|
|
continue;
|
|
}
|
|
boost::asio::post(m_io, [=] { otherFace->receive(n); });
|
|
}
|
|
});
|
|
|
|
m_faces.push_back(face);
|
|
return *face;
|
|
}
|
|
|
|
void
|
|
DummyForwarder::removeFaces()
|
|
{
|
|
m_faces.clear();
|
|
}
|
|
|
|
} // namespace chronosync
|
|
} // namespace ndn
|