1 //===-- QueueItem.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/Queue.h"
11 #include "lldb/Target/Process.h"
12 #include "lldb/Target/QueueItem.h"
13 #include "lldb/Target/SystemRuntime.h"
14
15 using namespace lldb;
16 using namespace lldb_private;
17
QueueItem(QueueSP queue_sp,ProcessSP process_sp,lldb::addr_t item_ref,lldb_private::Address address)18 QueueItem::QueueItem(QueueSP queue_sp, ProcessSP process_sp,
19 lldb::addr_t item_ref, lldb_private::Address address)
20 : m_queue_wp(), m_process_wp(), m_item_ref(item_ref), m_address(address),
21 m_have_fetched_entire_item(false), m_kind(eQueueItemKindUnknown),
22 m_item_that_enqueued_this_ref(LLDB_INVALID_ADDRESS),
23 m_enqueueing_thread_id(LLDB_INVALID_THREAD_ID),
24 m_enqueueing_queue_id(LLDB_INVALID_QUEUE_ID),
25 m_target_queue_id(LLDB_INVALID_QUEUE_ID), m_stop_id(0), m_backtrace(),
26 m_thread_label(), m_queue_label(), m_target_queue_label() {
27 m_queue_wp = queue_sp;
28 m_process_wp = process_sp;
29 }
30
~QueueItem()31 QueueItem::~QueueItem() {}
32
GetKind()33 QueueItemKind QueueItem::GetKind() {
34 FetchEntireItem();
35 return m_kind;
36 }
37
SetKind(QueueItemKind item_kind)38 void QueueItem::SetKind(QueueItemKind item_kind) { m_kind = item_kind; }
39
GetAddress()40 Address &QueueItem::GetAddress() { return m_address; }
41
SetAddress(Address addr)42 void QueueItem::SetAddress(Address addr) { m_address = addr; }
43
GetExtendedBacktraceThread(ConstString type)44 ThreadSP QueueItem::GetExtendedBacktraceThread(ConstString type) {
45 FetchEntireItem();
46 ThreadSP return_thread;
47 QueueSP queue_sp = m_queue_wp.lock();
48 if (queue_sp) {
49 ProcessSP process_sp = queue_sp->GetProcess();
50 if (process_sp && process_sp->GetSystemRuntime()) {
51 return_thread =
52 process_sp->GetSystemRuntime()->GetExtendedBacktraceForQueueItem(
53 this->shared_from_this(), type);
54 }
55 }
56 return return_thread;
57 }
58
GetItemThatEnqueuedThis()59 lldb::addr_t QueueItem::GetItemThatEnqueuedThis() {
60 FetchEntireItem();
61 return m_item_that_enqueued_this_ref;
62 }
63
GetEnqueueingThreadID()64 lldb::tid_t QueueItem::GetEnqueueingThreadID() {
65 FetchEntireItem();
66 return m_enqueueing_thread_id;
67 }
68
GetEnqueueingQueueID()69 lldb::queue_id_t QueueItem::GetEnqueueingQueueID() {
70 FetchEntireItem();
71 return m_enqueueing_queue_id;
72 }
73
GetStopID()74 uint32_t QueueItem::GetStopID() {
75 FetchEntireItem();
76 return m_stop_id;
77 }
78
GetEnqueueingBacktrace()79 std::vector<lldb::addr_t> &QueueItem::GetEnqueueingBacktrace() {
80 FetchEntireItem();
81 return m_backtrace;
82 }
83
GetThreadLabel()84 std::string QueueItem::GetThreadLabel() {
85 FetchEntireItem();
86 return m_thread_label;
87 }
88
GetQueueLabel()89 std::string QueueItem::GetQueueLabel() {
90 FetchEntireItem();
91 return m_queue_label;
92 }
93
GetProcessSP()94 ProcessSP QueueItem::GetProcessSP() { return m_process_wp.lock(); }
95
FetchEntireItem()96 void QueueItem::FetchEntireItem() {
97 if (m_have_fetched_entire_item)
98 return;
99 ProcessSP process_sp = m_process_wp.lock();
100 if (process_sp) {
101 SystemRuntime *runtime = process_sp->GetSystemRuntime();
102 if (runtime) {
103 runtime->CompleteQueueItem(this, m_item_ref);
104 m_have_fetched_entire_item = true;
105 }
106 }
107 }
108