@@ -136,7 +136,7 @@ bool CScheduler::AreThreadsServicingQueue() const
136
136
void SingleThreadedSchedulerClient::MaybeScheduleProcessQueue ()
137
137
{
138
138
{
139
- LOCK (m_cs_callbacks_pending );
139
+ LOCK (m_callbacks_mutex );
140
140
// Try to avoid scheduling too many copies here, but if we
141
141
// accidentally have two ProcessQueue's scheduled at once its
142
142
// not a big deal.
@@ -150,7 +150,7 @@ void SingleThreadedSchedulerClient::ProcessQueue()
150
150
{
151
151
std::function<void ()> callback;
152
152
{
153
- LOCK (m_cs_callbacks_pending );
153
+ LOCK (m_callbacks_mutex );
154
154
if (m_are_callbacks_running) return ;
155
155
if (m_callbacks_pending.empty ()) return ;
156
156
m_are_callbacks_running = true ;
@@ -167,7 +167,7 @@ void SingleThreadedSchedulerClient::ProcessQueue()
167
167
~RAIICallbacksRunning ()
168
168
{
169
169
{
170
- LOCK (instance->m_cs_callbacks_pending );
170
+ LOCK (instance->m_callbacks_mutex );
171
171
instance->m_are_callbacks_running = false ;
172
172
}
173
173
instance->MaybeScheduleProcessQueue ();
@@ -182,7 +182,7 @@ void SingleThreadedSchedulerClient::AddToProcessQueue(std::function<void()> func
182
182
assert (m_pscheduler);
183
183
184
184
{
185
- LOCK (m_cs_callbacks_pending );
185
+ LOCK (m_callbacks_mutex );
186
186
m_callbacks_pending.emplace_back (std::move (func));
187
187
}
188
188
MaybeScheduleProcessQueue ();
@@ -194,13 +194,13 @@ void SingleThreadedSchedulerClient::EmptyQueue()
194
194
bool should_continue = true ;
195
195
while (should_continue) {
196
196
ProcessQueue ();
197
- LOCK (m_cs_callbacks_pending );
197
+ LOCK (m_callbacks_mutex );
198
198
should_continue = !m_callbacks_pending.empty ();
199
199
}
200
200
}
201
201
202
202
size_t SingleThreadedSchedulerClient::CallbacksPending ()
203
203
{
204
- LOCK (m_cs_callbacks_pending );
204
+ LOCK (m_callbacks_mutex );
205
205
return m_callbacks_pending.size ();
206
206
}
0 commit comments