mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-02-11 11:16:09 -05:00
306ccd4927
-BEGIN VERIFY SCRIPT- ./contrib/devtools/copyright_header.py update ./ -END VERIFY SCRIPT- Commits of previous years: - 2021:f47dda2c58- 2020:fa0074e2d8- 2019:aaaaad6ac9
53 lines
1.6 KiB
C++
53 lines
1.6 KiB
C++
// Copyright (c) 2021-2022 The Bitcoin Core developers
|
|
// Distributed under the MIT software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#include <interfaces/echo.h>
|
|
#include <interfaces/handler.h>
|
|
|
|
#include <boost/signals2/connection.hpp>
|
|
#include <memory>
|
|
#include <utility>
|
|
|
|
namespace common {
|
|
namespace {
|
|
class CleanupHandler : public interfaces::Handler
|
|
{
|
|
public:
|
|
explicit CleanupHandler(std::function<void()> cleanup) : m_cleanup(std::move(cleanup)) {}
|
|
~CleanupHandler() override { if (!m_cleanup) return; m_cleanup(); m_cleanup = nullptr; }
|
|
void disconnect() override { if (!m_cleanup) return; m_cleanup(); m_cleanup = nullptr; }
|
|
std::function<void()> m_cleanup;
|
|
};
|
|
|
|
class SignalHandler : public interfaces::Handler
|
|
{
|
|
public:
|
|
explicit SignalHandler(boost::signals2::connection connection) : m_connection(std::move(connection)) {}
|
|
|
|
void disconnect() override { m_connection.disconnect(); }
|
|
|
|
boost::signals2::scoped_connection m_connection;
|
|
};
|
|
|
|
class EchoImpl : public interfaces::Echo
|
|
{
|
|
public:
|
|
std::string echo(const std::string& echo) override { return echo; }
|
|
};
|
|
} // namespace
|
|
} // namespace common
|
|
|
|
namespace interfaces {
|
|
std::unique_ptr<Handler> MakeCleanupHandler(std::function<void()> cleanup)
|
|
{
|
|
return std::make_unique<common::CleanupHandler>(std::move(cleanup));
|
|
}
|
|
|
|
std::unique_ptr<Handler> MakeSignalHandler(boost::signals2::connection connection)
|
|
{
|
|
return std::make_unique<common::SignalHandler>(std::move(connection));
|
|
}
|
|
|
|
std::unique_ptr<Echo> MakeEcho() { return std::make_unique<common::EchoImpl>(); }
|
|
} // namespace interfaces
|