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 (),
20     m_queue_id (queue_id),
21     m_queue_name (queue_name),
22     m_enqueued_items()
23 {
24     m_process_wp = process_sp;
25     m_index_id = process_sp->AssignIndexIDToQueue (queue_id);
26 }
27 
28 Queue::~Queue ()
29 {
30 }
31 
32 queue_id_t
33 Queue::GetID ()
34 {
35     return m_queue_id;
36 }
37 
38 const char *
39 Queue::GetName ()
40 {
41     const char *result = NULL;
42     if (m_queue_name.size() > 0)
43         result = m_queue_name.c_str();
44     return result;
45 }
46 
47 uint32_t
48 Queue::GetIndexID ()
49 {
50     return m_index_id;
51 }
52 
53 std::vector<lldb::ThreadSP>
54 Queue::GetThreads ()
55 {
56     std::vector<ThreadSP> result;
57     ProcessSP process_sp = m_process_wp.lock();
58     if (process_sp.get ())
59     {
60         for (ThreadSP thread_sp : process_sp->Threads())
61         {
62             if (thread_sp->GetQueueID() == m_queue_id)
63             {
64                 result.push_back (thread_sp);
65             }
66         }
67     }
68     return result;
69 }
70