@@ -89,22 +89,26 @@ struct MainSignalsInstance {
89
89
90
90
static CMainSignals g_signals;
91
91
92
- void CMainSignals::RegisterBackgroundSignalScheduler (CScheduler& scheduler) {
92
+ void CMainSignals::RegisterBackgroundSignalScheduler (CScheduler& scheduler)
93
+ {
93
94
assert (!m_internals);
94
95
m_internals.reset (new MainSignalsInstance (&scheduler));
95
96
}
96
97
97
- void CMainSignals::UnregisterBackgroundSignalScheduler () {
98
+ void CMainSignals::UnregisterBackgroundSignalScheduler ()
99
+ {
98
100
m_internals.reset (nullptr );
99
101
}
100
102
101
- void CMainSignals::FlushBackgroundCallbacks () {
103
+ void CMainSignals::FlushBackgroundCallbacks ()
104
+ {
102
105
if (m_internals) {
103
106
m_internals->m_schedulerClient .EmptyQueue ();
104
107
}
105
108
}
106
109
107
- size_t CMainSignals::CallbacksPending () {
110
+ size_t CMainSignals::CallbacksPending ()
111
+ {
108
112
if (!m_internals) return 0 ;
109
113
return m_internals->m_schedulerClient .CallbacksPending ();
110
114
}
@@ -114,10 +118,11 @@ CMainSignals& GetMainSignals()
114
118
return g_signals;
115
119
}
116
120
117
- void RegisterSharedValidationInterface (std::shared_ptr<CValidationInterface> pwalletIn) {
118
- // Each connection captures pwalletIn to ensure that each callback is
119
- // executed before pwalletIn is destroyed. For more details see #18338.
120
- g_signals.m_internals ->Register (std::move (pwalletIn));
121
+ void RegisterSharedValidationInterface (std::shared_ptr<CValidationInterface> callbacks)
122
+ {
123
+ // Each connection captures the shared_ptr to ensure that each callback is
124
+ // executed before the subscriber is destroyed. For more details see #18338.
125
+ g_signals.m_internals ->Register (std::move (callbacks));
121
126
}
122
127
123
128
void RegisterValidationInterface (CValidationInterface* callbacks)
@@ -132,24 +137,28 @@ void UnregisterSharedValidationInterface(std::shared_ptr<CValidationInterface> c
132
137
UnregisterValidationInterface (callbacks.get ());
133
138
}
134
139
135
- void UnregisterValidationInterface (CValidationInterface* pwalletIn) {
140
+ void UnregisterValidationInterface (CValidationInterface* callbacks)
141
+ {
136
142
if (g_signals.m_internals ) {
137
- g_signals.m_internals ->Unregister (pwalletIn );
143
+ g_signals.m_internals ->Unregister (callbacks );
138
144
}
139
145
}
140
146
141
- void UnregisterAllValidationInterfaces () {
147
+ void UnregisterAllValidationInterfaces ()
148
+ {
142
149
if (!g_signals.m_internals ) {
143
150
return ;
144
151
}
145
152
g_signals.m_internals ->Clear ();
146
153
}
147
154
148
- void CallFunctionInValidationInterfaceQueue (std::function<void ()> func) {
155
+ void CallFunctionInValidationInterfaceQueue (std::function<void ()> func)
156
+ {
149
157
g_signals.m_internals ->m_schedulerClient .AddToProcessQueue (std::move (func));
150
158
}
151
159
152
- void SyncWithValidationInterfaceQueue () {
160
+ void SyncWithValidationInterfaceQueue ()
161
+ {
153
162
AssertLockNotHeld (cs_main);
154
163
// Block until the validation queue drains
155
164
std::promise<void > promise;
0 commit comments