lldb/source/Target/QueueItem.cpp

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