1 //===-- Queue.cpp -----------------------------------------------*- C++ -*-===//
2 //
3 //                     The LLVM Compiler Infrastructure
4 //
5 // This file is distributed under the University of Illinois Open Source
6 // License. See LICENSE.TXT for details.
7 //
8 //===----------------------------------------------------------------------===//
9 
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 
15 using namespace lldb;
16 using namespace lldb_private;
17 
18 Queue::Queue (ProcessSP process_sp, lldb::queue_id_t queue_id, const char *queue_name) :
19     m_process_wp (process_sp),
20     m_queue_id (queue_id),
21     m_queue_name (queue_name),
22     m_enqueued_items()
23 {
24     m_index_id = process_sp->AssignIndexIDToQueue (queue_id);
25 }
26 
27 Queue::~Queue ()
28 {
29 }
30 
31 queue_id_t
32 Queue::GetID ()
33 {
34     return m_queue_id;
35 }
36 
37 const char *
38 Queue::GetName ()
39 {
40     const char *result = NULL;
41     if (m_queue_name.size() > 0)
42         result = m_queue_name.c_str();
43     return result;
44 }
45 
46 uint32_t
47 Queue::GetIndexID ()
48 {
49     return m_index_id;
50 }
51 
52 std::vector<lldb::ThreadSP>
53 Queue::GetThreads ()
54 {
55     std::vector<ThreadSP> result;
56     ProcessSP process_sp = m_process_wp.lock();
57     if (process_sp.get ())
58     {
59         for (ThreadSP thread_sp : process_sp->Threads())
60         {
61             if (thread_sp->GetQueueID() == m_queue_id)
62             {
63                 result.push_back (thread_sp);
64             }
65         }
66     }
67     return result;
68 }
69