mirror of
https://github.com/bitcoin/bitcoin.git
synced 2026-02-01 03:01:05 +00:00
0f01e1577f
a4f929696490 Merge bitcoin-core/libmultiprocess#224: doc: fix typos f4344ae87da0 Merge bitcoin-core/libmultiprocess#222: test, ci: Fix threadsanitizer errors in mptest 1434642b3804 doc: fix typos 73d22ba2e930 test: Fix tsan race in thread busy test b74e1bba014d ci: Use tsan-instrumented cap'n proto in sanitizers job c332774409ad test: Fix failing exception check in new thread busy test ca3c05d56709 test: Use KJ_LOG instead of std::cout for logging 7eb1da120ab6 ci: Use tsan-instrumented libcxx in sanitizers job ec86e4336e98 Merge bitcoin-core/libmultiprocess#220: Add log levels and advertise them to users via logging callback 515ce93ad349 Logging: Pass LogData struct to logging callback 213574ccc43d Logging: reclassify remaining log messages e4de0412b430 Logging: Break out expensive log messages and classify them as Trace 408874a78fdc Logging: Use new logging macros 67b092d835cd Logging: Disable logging if messsage level is less than the requested level d0a1ba7ebf21 Logging: add log levels to mirror Core's 463a8296d188 Logging: Disable moving or copying Logger 83a2e10c0b03 Logging: Add an EventLoop constructor to allow for user-specified log options 58cf47a7fc8c Merge bitcoin-core/libmultiprocess#221: test default PassField impl handles output parameters db03a663f514 Merge bitcoin-core/libmultiprocess#214: Fix crash on simultaneous IPC calls using the same thread afcc40b0f1e8 Merge bitcoin-core/libmultiprocess#213: util+doc: Clearer errors when attempting to run examples + polished docs 6db669628387 test In|Out parameter 29cf2ada75ea test default PassField impl handles output parameters 1238170f68e8 test: simultaneous IPC calls using same thread eb069ab75d83 Fix crash on simultaneous IPC calls using the same thread ec03a9639ab5 doc: Precision and typos 2b4348193551 doc: Where possible, remove links to ryanofsky/bitcoin/ 286fe469c9c9 util: Add helpful error message when failing to execute file git-subtree-dir: src/ipc/libmultiprocess git-subtree-split: a4f92969649018ca70f949a09148bccfeaecd99a
78 lines
2.2 KiB
C++
78 lines
2.2 KiB
C++
// Copyright (c) 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 <init.capnp.h>
|
|
#include <init.capnp.proxy.h>
|
|
|
|
#include <cstring> // IWYU pragma: keep
|
|
#include <filesystem>
|
|
#include <fstream>
|
|
#include <future>
|
|
#include <iostream>
|
|
#include <kj/async.h>
|
|
#include <kj/common.h>
|
|
#include <memory>
|
|
#include <mp/proxy-io.h>
|
|
#include <mp/util.h>
|
|
#include <stdexcept>
|
|
#include <string>
|
|
#include <thread>
|
|
#include <tuple>
|
|
#include <vector>
|
|
|
|
namespace fs = std::filesystem;
|
|
|
|
static auto Spawn(mp::EventLoop& loop, const std::string& process_argv0, const std::string& new_exe_name)
|
|
{
|
|
int pid;
|
|
const int fd = mp::SpawnProcess(pid, [&](int fd) -> std::vector<std::string> {
|
|
fs::path path = process_argv0;
|
|
path.remove_filename();
|
|
path.append(new_exe_name);
|
|
return {path.string(), std::to_string(fd)};
|
|
});
|
|
return std::make_tuple(mp::ConnectStream<InitInterface>(loop, fd), pid);
|
|
}
|
|
|
|
static void LogPrint(mp::LogMessage log_data)
|
|
{
|
|
if (log_data.level == mp::Log::Raise) throw std::runtime_error(log_data.message);
|
|
std::ofstream("debug.log", std::ios_base::app) << log_data.message << std::endl;
|
|
}
|
|
|
|
int main(int argc, char** argv)
|
|
{
|
|
if (argc != 1) {
|
|
std::cout << "Usage: mpexample\n";
|
|
return 1;
|
|
}
|
|
|
|
std::promise<mp::EventLoop*> promise;
|
|
std::thread loop_thread([&] {
|
|
mp::EventLoop loop("mpexample", LogPrint);
|
|
promise.set_value(&loop);
|
|
loop.loop();
|
|
});
|
|
mp::EventLoop* loop = promise.get_future().get();
|
|
|
|
auto [printer_init, printer_pid] = Spawn(*loop, argv[0], "mpprinter");
|
|
auto [calc_init, calc_pid] = Spawn(*loop, argv[0], "mpcalculator");
|
|
auto calc = calc_init->makeCalculator(printer_init->makePrinter());
|
|
while (true) {
|
|
std::string eqn;
|
|
std::cout << "Enter the equation, or \"exit\" to quit: ";
|
|
std::getline(std::cin, eqn);
|
|
if (eqn == "exit") break;
|
|
calc->solveEquation(eqn);
|
|
}
|
|
calc.reset();
|
|
calc_init.reset();
|
|
mp::WaitProcess(calc_pid);
|
|
printer_init.reset();
|
|
mp::WaitProcess(printer_pid);
|
|
loop_thread.join();
|
|
std::cout << "Bye!" << std::endl;
|
|
return 0;
|
|
}
|