mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-02-09 10:43:19 -05:00
e7333b420e
This is a minimal extraction of a single function, but also the only use of std::exception in util/system. The background of this commit is an ongoing effort to decouple the libbitcoinkernel library from the ArgsManager defined in system.h. Moving the function out of system.h allows including it from a separate source file without including the ArgsManager definitions from system.h.
71 lines
1.9 KiB
C++
71 lines
1.9 KiB
C++
// Copyright (c) 2014-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 <qt/initexecutor.h>
|
|
|
|
#include <interfaces/node.h>
|
|
#include <util/exception.h>
|
|
#include <util/threadnames.h>
|
|
|
|
#include <exception>
|
|
|
|
#include <QDebug>
|
|
#include <QMetaObject>
|
|
#include <QObject>
|
|
#include <QString>
|
|
#include <QThread>
|
|
|
|
InitExecutor::InitExecutor(interfaces::Node& node)
|
|
: QObject(), m_node(node)
|
|
{
|
|
m_context.moveToThread(&m_thread);
|
|
m_thread.start();
|
|
}
|
|
|
|
InitExecutor::~InitExecutor()
|
|
{
|
|
qDebug() << __func__ << ": Stopping thread";
|
|
m_thread.quit();
|
|
m_thread.wait();
|
|
qDebug() << __func__ << ": Stopped thread";
|
|
}
|
|
|
|
void InitExecutor::handleRunawayException(const std::exception* e)
|
|
{
|
|
PrintExceptionContinue(e, "Runaway exception");
|
|
Q_EMIT runawayException(QString::fromStdString(m_node.getWarnings().translated));
|
|
}
|
|
|
|
void InitExecutor::initialize()
|
|
{
|
|
QMetaObject::invokeMethod(&m_context, [this] {
|
|
try {
|
|
util::ThreadRename("qt-init");
|
|
qDebug() << "Running initialization in thread";
|
|
interfaces::BlockAndHeaderTipInfo tip_info;
|
|
bool rv = m_node.appInitMain(&tip_info);
|
|
Q_EMIT initializeResult(rv, tip_info);
|
|
} catch (const std::exception& e) {
|
|
handleRunawayException(&e);
|
|
} catch (...) {
|
|
handleRunawayException(nullptr);
|
|
}
|
|
});
|
|
}
|
|
|
|
void InitExecutor::shutdown()
|
|
{
|
|
QMetaObject::invokeMethod(&m_context, [this] {
|
|
try {
|
|
qDebug() << "Running Shutdown in thread";
|
|
m_node.appShutdown();
|
|
qDebug() << "Shutdown finished";
|
|
Q_EMIT shutdownResult();
|
|
} catch (const std::exception& e) {
|
|
handleRunawayException(&e);
|
|
} catch (...) {
|
|
handleRunawayException(nullptr);
|
|
}
|
|
});
|
|
}
|