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 //===----------------------------------------------------------------------===//
10 #include "lldb/Target/Process.h"
11 #include "lldb/Target/Queue.h"
12 #include "lldb/Target/QueueList.h"
13 #include "lldb/Target/Thread.h"
14 #include "lldb/Target/SystemRuntime.h"
17 using namespace lldb_private;
19 Queue::Queue (ProcessSP process_sp, lldb::queue_id_t queue_id, const char *queue_name) :
21 m_queue_id (queue_id),
23 m_running_work_items_count(0),
24 m_pending_work_items_count(0),
26 m_dispatch_queue_t_addr(LLDB_INVALID_ADDRESS),
27 m_kind (eQueueKindUnknown)
30 m_queue_name = queue_name;
32 m_process_wp = process_sp;
48 const char *result = NULL;
49 if (m_queue_name.size() > 0)
50 result = m_queue_name.c_str();
60 std::vector<lldb::ThreadSP>
63 std::vector<ThreadSP> result;
64 ProcessSP process_sp = m_process_wp.lock();
65 if (process_sp.get ())
67 for (ThreadSP thread_sp : process_sp->Threads())
69 if (thread_sp->GetQueueID() == m_queue_id)
71 result.push_back (thread_sp);
79 Queue::SetNumRunningWorkItems (uint32_t count)
81 m_running_work_items_count = count;
85 Queue::GetNumRunningWorkItems () const
87 return m_running_work_items_count;
92 Queue::SetNumPendingWorkItems (uint32_t count)
94 m_pending_work_items_count = count;
98 Queue::GetNumPendingWorkItems () const
100 return m_pending_work_items_count;
104 Queue::SetLibdispatchQueueAddress (addr_t dispatch_queue_t_addr)
106 m_dispatch_queue_t_addr = dispatch_queue_t_addr;
110 Queue::GetLibdispatchQueueAddress () const
112 return m_dispatch_queue_t_addr;
116 const std::vector<lldb::QueueItemSP> &
117 Queue::GetPendingItems ()
119 if (m_pending_items.size() == 0)
121 ProcessSP process_sp = m_process_wp.lock();
122 if (process_sp && process_sp->GetSystemRuntime())
124 process_sp->GetSystemRuntime()->PopulatePendingItemsForQueue (this);
127 return m_pending_items;
137 Queue::SetKind (lldb::QueueKind kind)