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 AndricQueueList::QueueList(Process *process) 17*0b57cec5SDimitry Andric : m_process(process), m_stop_id(0), m_queues(), m_mutex() {} 18*0b57cec5SDimitry Andric ~QueueList()19*0b57cec5SDimitry AndricQueueList::~QueueList() { Clear(); } 20*0b57cec5SDimitry Andric GetSize()21*0b57cec5SDimitry Andricuint32_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 Andriclldb::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 Andricvoid 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 Andricvoid 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 Andriclldb::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 Andriclldb::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 Andricstd::mutex &QueueList::GetMutex() { return m_mutex; } 70