1*0b57cec5SDimitry Andric //===-- QueueList.cpp -----------------------------------------------------===//
2*0b57cec5SDimitry Andric //
3*0b57cec5SDimitry Andric // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
4*0b57cec5SDimitry Andric // See https://llvm.org/LICENSE.txt for license information.
5*0b57cec5SDimitry Andric // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
6*0b57cec5SDimitry Andric //
7*0b57cec5SDimitry Andric //===----------------------------------------------------------------------===//
8*0b57cec5SDimitry Andric 
9*0b57cec5SDimitry Andric #include "lldb/Target/Queue.h"
10*0b57cec5SDimitry Andric #include "lldb/Target/Process.h"
11*0b57cec5SDimitry Andric #include "lldb/Target/QueueList.h"
12*0b57cec5SDimitry Andric 
13*0b57cec5SDimitry Andric using namespace lldb;
14*0b57cec5SDimitry Andric using namespace lldb_private;
15*0b57cec5SDimitry Andric 
QueueList(Process * process)16*0b57cec5SDimitry Andric QueueList::QueueList(Process *process)
17*0b57cec5SDimitry Andric     : m_process(process), m_stop_id(0), m_queues(), m_mutex() {}
18*0b57cec5SDimitry Andric 
~QueueList()19*0b57cec5SDimitry Andric QueueList::~QueueList() { Clear(); }
20*0b57cec5SDimitry Andric 
GetSize()21*0b57cec5SDimitry Andric uint32_t QueueList::GetSize() {
22*0b57cec5SDimitry Andric   std::lock_guard<std::mutex> guard(m_mutex);
23*0b57cec5SDimitry Andric   return m_queues.size();
24*0b57cec5SDimitry Andric }
25*0b57cec5SDimitry Andric 
GetQueueAtIndex(uint32_t idx)26*0b57cec5SDimitry Andric lldb::QueueSP QueueList::GetQueueAtIndex(uint32_t idx) {
27*0b57cec5SDimitry Andric   std::lock_guard<std::mutex> guard(m_mutex);
28*0b57cec5SDimitry Andric   if (idx < m_queues.size()) {
29*0b57cec5SDimitry Andric     return m_queues[idx];
30*0b57cec5SDimitry Andric   } else {
31*0b57cec5SDimitry Andric     return QueueSP();
32*0b57cec5SDimitry Andric   }
33*0b57cec5SDimitry Andric }
34*0b57cec5SDimitry Andric 
Clear()35*0b57cec5SDimitry Andric void QueueList::Clear() {
36*0b57cec5SDimitry Andric   std::lock_guard<std::mutex> guard(m_mutex);
37*0b57cec5SDimitry Andric   m_queues.clear();
38*0b57cec5SDimitry Andric }
39*0b57cec5SDimitry Andric 
AddQueue(QueueSP queue_sp)40*0b57cec5SDimitry Andric void QueueList::AddQueue(QueueSP queue_sp) {
41*0b57cec5SDimitry Andric   std::lock_guard<std::mutex> guard(m_mutex);
42*0b57cec5SDimitry Andric   if (queue_sp.get()) {
43*0b57cec5SDimitry Andric     m_queues.push_back(queue_sp);
44*0b57cec5SDimitry Andric   }
45*0b57cec5SDimitry Andric }
46*0b57cec5SDimitry Andric 
FindQueueByID(lldb::queue_id_t qid)47*0b57cec5SDimitry Andric lldb::QueueSP QueueList::FindQueueByID(lldb::queue_id_t qid) {
48*0b57cec5SDimitry Andric   QueueSP ret;
49*0b57cec5SDimitry Andric   for (QueueSP queue_sp : Queues()) {
50*0b57cec5SDimitry Andric     if (queue_sp->GetID() == qid) {
51*0b57cec5SDimitry Andric       ret = queue_sp;
52*0b57cec5SDimitry Andric       break;
53*0b57cec5SDimitry Andric     }
54*0b57cec5SDimitry Andric   }
55*0b57cec5SDimitry Andric   return ret;
56*0b57cec5SDimitry Andric }
57*0b57cec5SDimitry Andric 
FindQueueByIndexID(uint32_t index_id)58*0b57cec5SDimitry Andric lldb::QueueSP QueueList::FindQueueByIndexID(uint32_t index_id) {
59*0b57cec5SDimitry Andric   QueueSP ret;
60*0b57cec5SDimitry Andric   for (QueueSP queue_sp : Queues()) {
61*0b57cec5SDimitry Andric     if (queue_sp->GetIndexID() == index_id) {
62*0b57cec5SDimitry Andric       ret = queue_sp;
63*0b57cec5SDimitry Andric       break;
64*0b57cec5SDimitry Andric     }
65*0b57cec5SDimitry Andric   }
66*0b57cec5SDimitry Andric   return ret;
67*0b57cec5SDimitry Andric }
68*0b57cec5SDimitry Andric 
GetMutex()69*0b57cec5SDimitry Andric std::mutex &QueueList::GetMutex() { return m_mutex; }
70