Skip to content

Commit

Permalink
qt: Add BitcoinCore::m_thread member
Browse files Browse the repository at this point in the history
This change makes BitcoinCore self-contained to improve its
re-usability.

BitcoinApplication::coreThread member is now unused, and removed.
  • Loading branch information
hebasto committed Jul 14, 2021
1 parent 531c2b7 commit 19a1d00
Show file tree
Hide file tree
Showing 2 changed files with 26 additions and 26 deletions.
41 changes: 18 additions & 23 deletions src/qt/bitcoin.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -158,6 +158,16 @@ void DebugMessageHandler(QtMsgType type, const QMessageLogContext& context, cons
BitcoinCore::BitcoinCore(interfaces::Node& node) :
QObject(), m_node(node)
{
this->moveToThread(&m_thread);
m_thread.start();
}

BitcoinCore::~BitcoinCore()
{
qDebug() << __func__ << ": Stopping thread";
m_thread.quit();
m_thread.wait();
qDebug() << __func__ << ": Stopped thread";
}

void BitcoinCore::handleRunawayException(const std::exception *e)
Expand Down Expand Up @@ -202,7 +212,6 @@ static const char* qt_argv = "bitcoin-qt";

BitcoinApplication::BitcoinApplication():
QApplication(qt_argc, const_cast<char **>(&qt_argv)),
coreThread(nullptr),
optionsModel(nullptr),
clientModel(nullptr),
window(nullptr),
Expand Down Expand Up @@ -230,13 +239,7 @@ void BitcoinApplication::setupPlatformStyle()

BitcoinApplication::~BitcoinApplication()
{
if(coreThread)
{
qDebug() << __func__ << ": Stopping thread";
coreThread->quit();
coreThread->wait();
qDebug() << __func__ << ": Stopped thread";
}
m_executor.reset();

delete window;
window = nullptr;
Expand Down Expand Up @@ -291,22 +294,15 @@ bool BitcoinApplication::baseInitialize()

void BitcoinApplication::startThread()
{
if(coreThread)
return;
coreThread = new QThread(this);
BitcoinCore *executor = new BitcoinCore(node());
executor->moveToThread(coreThread);
assert(!m_executor);
m_executor.emplace(node());

/* communication to and from thread */
connect(executor, &BitcoinCore::initializeResult, this, &BitcoinApplication::initializeResult);
connect(executor, &BitcoinCore::shutdownResult, this, &BitcoinApplication::shutdownResult);
connect(executor, &BitcoinCore::runawayException, this, &BitcoinApplication::handleRunawayException);
connect(this, &BitcoinApplication::requestedInitialize, executor, &BitcoinCore::initialize);
connect(this, &BitcoinApplication::requestedShutdown, executor, &BitcoinCore::shutdown);
/* make sure executor object is deleted in its own thread */
connect(coreThread, &QThread::finished, executor, &QObject::deleteLater);

coreThread->start();
connect(&m_executor.value(), &BitcoinCore::initializeResult, this, &BitcoinApplication::initializeResult);
connect(&m_executor.value(), &BitcoinCore::shutdownResult, this, &BitcoinApplication::shutdownResult);
connect(&m_executor.value(), &BitcoinCore::runawayException, this, &BitcoinApplication::handleRunawayException);
connect(this, &BitcoinApplication::requestedInitialize, &m_executor.value(), &BitcoinCore::initialize);
connect(this, &BitcoinApplication::requestedShutdown, &m_executor.value(), &BitcoinCore::shutdown);
}

void BitcoinApplication::parameterSetup()
Expand Down Expand Up @@ -339,7 +335,6 @@ void BitcoinApplication::requestShutdown()
shutdownWindow.reset(ShutdownWindow::showShutdownWindow(window));

qDebug() << __func__ << ": Requesting shutdown";
startThread();
window->hide();
// Must disconnect node signals otherwise current thread can deadlock since
// no event loop is running.
Expand Down
11 changes: 8 additions & 3 deletions src/qt/bitcoin.h
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,14 @@
#include <config/bitcoin-config.h>
#endif

#include <QApplication>
#include <interfaces/node.h>

#include <assert.h>
#include <memory>
#include <optional>

#include <interfaces/node.h>
#include <QApplication>
#include <QThread>

class BitcoinGUI;
class ClientModel;
Expand All @@ -34,6 +37,7 @@ class BitcoinCore: public QObject
Q_OBJECT
public:
explicit BitcoinCore(interfaces::Node& node);
~BitcoinCore();

public Q_SLOTS:
void initialize();
Expand All @@ -49,6 +53,7 @@ public Q_SLOTS:
void handleRunawayException(const std::exception *e);

interfaces::Node& m_node;
QThread m_thread;
};

/** Main Bitcoin application object */
Expand Down Expand Up @@ -112,7 +117,7 @@ public Q_SLOTS:
void windowShown(BitcoinGUI* window);

private:
QThread *coreThread;
std::optional<BitcoinCore> m_executor;
OptionsModel *optionsModel;
ClientModel *clientModel;
BitcoinGUI *window;
Expand Down

0 comments on commit 19a1d00

Please sign in to comment.