mirror of
https://github.com/Retropex/bitcoin.git
synced 2025-05-14 12:10:42 +02:00
3e33d170cc
These are currently empty structs but they will be used to pass some function and object pointers from bitcoin application code to IPC hooks that run, for example, when a remote object is created or destroyed, or a new process is created.
94 lines
2.7 KiB
C++
94 lines
2.7 KiB
C++
// Copyright (c) 2021 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/init.h>
|
|
#include <ipc/capnp/context.h>
|
|
#include <ipc/capnp/init.capnp.h>
|
|
#include <ipc/capnp/init.capnp.proxy.h>
|
|
#include <ipc/capnp/protocol.h>
|
|
#include <ipc/exception.h>
|
|
#include <ipc/protocol.h>
|
|
#include <kj/async.h>
|
|
#include <logging.h>
|
|
#include <mp/proxy-io.h>
|
|
#include <mp/proxy-types.h>
|
|
#include <mp/util.h>
|
|
#include <util/threadnames.h>
|
|
|
|
#include <assert.h>
|
|
#include <errno.h>
|
|
#include <future>
|
|
#include <memory>
|
|
#include <mutex>
|
|
#include <optional>
|
|
#include <string>
|
|
#include <thread>
|
|
|
|
namespace ipc {
|
|
namespace capnp {
|
|
namespace {
|
|
void IpcLogFn(bool raise, std::string message)
|
|
{
|
|
LogPrint(BCLog::IPC, "%s\n", message);
|
|
if (raise) throw Exception(message);
|
|
}
|
|
|
|
class CapnpProtocol : public Protocol
|
|
{
|
|
public:
|
|
~CapnpProtocol() noexcept(true)
|
|
{
|
|
if (m_loop) {
|
|
std::unique_lock<std::mutex> lock(m_loop->m_mutex);
|
|
m_loop->removeClient(lock);
|
|
}
|
|
if (m_loop_thread.joinable()) m_loop_thread.join();
|
|
assert(!m_loop);
|
|
};
|
|
std::unique_ptr<interfaces::Init> connect(int fd, const char* exe_name) override
|
|
{
|
|
startLoop(exe_name);
|
|
return mp::ConnectStream<messages::Init>(*m_loop, fd);
|
|
}
|
|
void serve(int fd, const char* exe_name, interfaces::Init& init) override
|
|
{
|
|
assert(!m_loop);
|
|
mp::g_thread_context.thread_name = mp::ThreadName(exe_name);
|
|
m_loop.emplace(exe_name, &IpcLogFn, &m_context);
|
|
mp::ServeStream<messages::Init>(*m_loop, fd, init);
|
|
m_loop->loop();
|
|
m_loop.reset();
|
|
}
|
|
void addCleanup(std::type_index type, void* iface, std::function<void()> cleanup) override
|
|
{
|
|
mp::ProxyTypeRegister::types().at(type)(iface).cleanup.emplace_back(std::move(cleanup));
|
|
}
|
|
Context& context() override { return m_context; }
|
|
void startLoop(const char* exe_name)
|
|
{
|
|
if (m_loop) return;
|
|
std::promise<void> promise;
|
|
m_loop_thread = std::thread([&] {
|
|
util::ThreadRename("capnp-loop");
|
|
m_loop.emplace(exe_name, &IpcLogFn, &m_context);
|
|
{
|
|
std::unique_lock<std::mutex> lock(m_loop->m_mutex);
|
|
m_loop->addClient(lock);
|
|
}
|
|
promise.set_value();
|
|
m_loop->loop();
|
|
m_loop.reset();
|
|
});
|
|
promise.get_future().wait();
|
|
}
|
|
Context m_context;
|
|
std::thread m_loop_thread;
|
|
std::optional<mp::EventLoop> m_loop;
|
|
};
|
|
} // namespace
|
|
|
|
std::unique_ptr<Protocol> MakeCapnpProtocol() { return std::make_unique<CapnpProtocol>(); }
|
|
} // namespace capnp
|
|
} // namespace ipc
|