MCPcopy Create free account
hub / github.com/ElementsProject/elements / MaybeScheduleProcessQueue

Method MaybeScheduleProcessQueue

src/scheduler.cpp:136–147  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

134
135
136void SingleThreadedSchedulerClient::MaybeScheduleProcessQueue()
137{
138 {
139 LOCK(m_callbacks_mutex);
140 // Try to avoid scheduling too many copies here, but if we
141 // accidentally have two ProcessQueue's scheduled at once its
142 // not a big deal.
143 if (m_are_callbacks_running) return;
144 if (m_callbacks_pending.empty()) return;
145 }
146 m_pscheduler->schedule(std::bind(&SingleThreadedSchedulerClient::ProcessQueue, this), std::chrono::system_clock::now());
147}
148
149void SingleThreadedSchedulerClient::ProcessQueue()
150{

Callers 1

~RAIICallbacksRunningMethod · 0.80

Calls 2

scheduleMethod · 0.80
emptyMethod · 0.45

Tested by

no test coverage detected