1 //===-- Queue.cpp -----------------------------------------------*- C++ -*-===//
3 // The LLVM Compiler Infrastructure
5 // This file is distributed under the University of Illinois Open Source
6 // License. See LICENSE.TXT for details.
8 //===----------------------------------------------------------------------===//
12 // Other libraries and framework includes
14 #include "lldb/Target/Process.h"
15 #include "lldb/Target/Queue.h"
16 #include "lldb/Target/QueueList.h"
17 #include "lldb/Target/Thread.h"
18 #include "lldb/Target/SystemRuntime.h"
21 using namespace lldb_private;
23 Queue::Queue (ProcessSP process_sp, lldb::queue_id_t queue_id, const char *queue_name) :
25 m_queue_id (queue_id),
27 m_running_work_items_count(0),
28 m_pending_work_items_count(0),
30 m_dispatch_queue_t_addr(LLDB_INVALID_ADDRESS),
31 m_kind (eQueueKindUnknown)
34 m_queue_name = queue_name;
36 m_process_wp = process_sp;
39 Queue::~Queue() = default;
50 return (m_queue_name.empty() ? nullptr : m_queue_name.c_str());
59 std::vector<lldb::ThreadSP>
62 std::vector<ThreadSP> result;
63 ProcessSP process_sp = m_process_wp.lock();
66 for (ThreadSP thread_sp : process_sp->Threads())
68 if (thread_sp->GetQueueID() == m_queue_id)
70 result.push_back (thread_sp);
78 Queue::SetNumRunningWorkItems (uint32_t count)
80 m_running_work_items_count = count;
84 Queue::GetNumRunningWorkItems () const
86 return m_running_work_items_count;
90 Queue::SetNumPendingWorkItems (uint32_t count)
92 m_pending_work_items_count = count;
96 Queue::GetNumPendingWorkItems () const
98 return m_pending_work_items_count;
102 Queue::SetLibdispatchQueueAddress (addr_t dispatch_queue_t_addr)
104 m_dispatch_queue_t_addr = dispatch_queue_t_addr;
108 Queue::GetLibdispatchQueueAddress () const
110 return m_dispatch_queue_t_addr;
113 const std::vector<lldb::QueueItemSP> &
114 Queue::GetPendingItems ()
116 if (m_pending_items.empty())
118 ProcessSP process_sp = m_process_wp.lock();
119 if (process_sp && process_sp->GetSystemRuntime())
121 process_sp->GetSystemRuntime()->PopulatePendingItemsForQueue (this);
124 return m_pending_items;
134 Queue::SetKind (lldb::QueueKind kind)