summaryrefslogtreecommitdiff
path: root/graphics/asymptote/LspCpp/src/jsonrpc/threaded_queue.cpp
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;
}