mirror of
https://github.com/ZmnSCPxj/clboss.git
synced 2026-08-14 12:43:19 +02:00
28 lines
666 B
C++
28 lines
666 B
C++
#include"Boss/Mod/PeerJudge/Unmanager.hpp"
|
|
#include"Boss/Msg/ProvideUnmanagement.hpp"
|
|
#include"Boss/Msg/SolicitUnmanagement.hpp"
|
|
#include"Ev/Io.hpp"
|
|
#include"S/Bus.hpp"
|
|
#include<utility>
|
|
|
|
namespace Boss { namespace Mod { namespace PeerJudge {
|
|
|
|
Unmanager::Unmanager(S::Bus& bus) {
|
|
bus.subscribe<Msg::SolicitUnmanagement
|
|
> ([this, &bus](Msg::SolicitUnmanagement const& _) {
|
|
auto fun = [this](Ln::NodeId const& node, bool is_unmanaged) {
|
|
if (is_unmanaged)
|
|
unmanaged.insert(node);
|
|
else
|
|
unmanaged.erase(unmanaged.find(node));
|
|
return Ev::lift();
|
|
};
|
|
return bus.raise(Msg::ProvideUnmanagement{
|
|
"close",
|
|
std::move(fun)
|
|
});
|
|
});
|
|
}
|
|
|
|
}}}
|
|
|