diff options
author | TheCharlatan <seb.kung@gmail.com> | 2024-01-20 09:13:35 +0100 |
---|---|---|
committer | TheCharlatan <seb.kung@gmail.com> | 2024-02-15 14:43:14 +0100 |
commit | 0d6d2b650d1017691f48c9109a6cd020ab46aa73 (patch) | |
tree | 8ec471f9287833db5ec9fbbb86731c10d2faf539 /src/validationinterface.cpp | |
parent | 4abde2c4e3fd9b66394b79874583bdc2a9132c36 (diff) | |
download | bitcoin-0d6d2b650d1017691f48c9109a6cd020ab46aa73.tar.xz |
scripted-diff: Rename SingleThreadedSchedulerClient to SerialTaskRunner
-BEGIN VERIFY SCRIPT-
s() { git grep -l "$1" src | (grep -v "$3" || cat;) | xargs sed -i "s/$1/$2/g"; }
s 'SingleThreadedSchedulerClient' 'SerialTaskRunner' ''
s 'SinglethreadedSchedulerClient' 'SerialTaskRunner' ''
s 'm_schedulerClient' 'm_task_runner' ''
s 'AddToProcessQueue' 'insert' ''
s 'EmptyQueue' 'flush' ''
s 'CallbacksPending' 'size' 'validation'
sed -i '109s/CallbacksPending/size/' src/validationinterface.cpp
-END VERIFY SCRIPT-
Co-authored-by: Russell Yanofsky <russ@yanofsky.org>
Diffstat (limited to 'src/validationinterface.cpp')
-rw-r--r-- | src/validationinterface.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/validationinterface.cpp b/src/validationinterface.cpp index c61473be0a..4ab66336da 100644 --- a/src/validationinterface.cpp +++ b/src/validationinterface.cpp @@ -45,9 +45,9 @@ public: // We are not allowed to assume the scheduler only runs in one thread, // but must ensure all callbacks happen in-order, so we end up creating // our own queue here :( - SingleThreadedSchedulerClient m_schedulerClient; + SerialTaskRunner m_task_runner; - explicit MainSignalsImpl(CScheduler& scheduler LIFETIMEBOUND) : m_schedulerClient(scheduler) {} + explicit MainSignalsImpl(CScheduler& scheduler LIFETIMEBOUND) : m_task_runner(scheduler) {} void Register(std::shared_ptr<CValidationInterface> callbacks) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex) { @@ -101,12 +101,12 @@ CMainSignals::~CMainSignals() {} void CMainSignals::FlushBackgroundCallbacks() { - m_internals->m_schedulerClient.EmptyQueue(); + m_internals->m_task_runner.flush(); } size_t CMainSignals::CallbacksPending() { - return m_internals->m_schedulerClient.CallbacksPending(); + return m_internals->m_task_runner.size(); } void CMainSignals::RegisterSharedValidationInterface(std::shared_ptr<CValidationInterface> callbacks) @@ -140,7 +140,7 @@ void CMainSignals::UnregisterAllValidationInterfaces() void CMainSignals::CallFunctionInValidationInterfaceQueue(std::function<void()> func) { - m_internals->m_schedulerClient.AddToProcessQueue(std::move(func)); + m_internals->m_task_runner.insert(std::move(func)); } void CMainSignals::SyncWithValidationInterfaceQueue() @@ -162,7 +162,7 @@ void CMainSignals::SyncWithValidationInterfaceQueue() do { \ auto local_name = (name); \ LOG_EVENT("Enqueuing " fmt, local_name, __VA_ARGS__); \ - m_internals->m_schedulerClient.AddToProcessQueue([=] { \ + m_internals->m_task_runner.insert([=] { \ LOG_EVENT(fmt, local_name, __VA_ARGS__); \ event(); \ }); \ |