blob: 1f9a02ac0dc2b21a72523255108a039ae4353392 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
#include "LibLsp/JsonRpc/threaded_queue.h"
// static
bool MultiQueueWaiter::HasState(
std::initializer_list<BaseThreadQueue*> queues) {
for (BaseThreadQueue* queue : queues) {
if (!queue->IsEmpty())
return true;
}
return false;
}
bool MultiQueueWaiter::ValidateWaiter(
std::initializer_list<BaseThreadQueue*> queues) {
for (BaseThreadQueue* queue : queues) {
if (queue->waiter.get() != this)
return false;
}
return true;
}
|