Browse Source

Add an interface to get the queue depth out of CValidationInterface

pull/3/head
Matt Corallo 5 years ago
parent
commit
5a933cefcc
  1. 5
      src/scheduler.cpp
  2. 2
      src/scheduler.h
  3. 5
      src/validationinterface.cpp
  4. 2
      src/validationinterface.h

5
src/scheduler.cpp

@ -206,3 +206,8 @@ void SingleThreadedSchedulerClient::EmptyQueue() { @@ -206,3 +206,8 @@ void SingleThreadedSchedulerClient::EmptyQueue() {
should_continue = !m_callbacks_pending.empty();
}
}
size_t SingleThreadedSchedulerClient::CallbacksPending() {
LOCK(m_cs_callbacks_pending);
return m_callbacks_pending.size();
}

2
src/scheduler.h

@ -108,6 +108,8 @@ public: @@ -108,6 +108,8 @@ public:
// Processes all remaining queue members on the calling thread, blocking until queue is empty
// Must be called after the CScheduler has no remaining processing threads!
void EmptyQueue();
size_t CallbacksPending();
};
#endif

5
src/validationinterface.cpp

@ -54,6 +54,11 @@ void CMainSignals::FlushBackgroundCallbacks() { @@ -54,6 +54,11 @@ void CMainSignals::FlushBackgroundCallbacks() {
}
}
size_t CMainSignals::CallbacksPending() {
if (!m_internals) return 0;
return m_internals->m_schedulerClient.CallbacksPending();
}
void CMainSignals::RegisterWithMempoolSignals(CTxMemPool& pool) {
pool.NotifyEntryRemoved.connect(boost::bind(&CMainSignals::MempoolEntryRemoved, this, _1, _2));
}

2
src/validationinterface.h

@ -131,6 +131,8 @@ public: @@ -131,6 +131,8 @@ public:
/** Call any remaining callbacks on the calling thread */
void FlushBackgroundCallbacks();
size_t CallbacksPending();
/** Register with mempool to call TransactionRemovedFromMempool callbacks */
void RegisterWithMempoolSignals(CTxMemPool& pool);
/** Unregister with mempool */

Loading…
Cancel
Save