summaryrefslogtreecommitdiffstats
path: root/contrib/llvm/tools/lldb/source/Target/ThreadList.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'contrib/llvm/tools/lldb/source/Target/ThreadList.cpp')
-rw-r--r--contrib/llvm/tools/lldb/source/Target/ThreadList.cpp1357
1 files changed, 625 insertions, 732 deletions
diff --git a/contrib/llvm/tools/lldb/source/Target/ThreadList.cpp b/contrib/llvm/tools/lldb/source/Target/ThreadList.cpp
index 23e9f78..1e47451 100644
--- a/contrib/llvm/tools/lldb/source/Target/ThreadList.cpp
+++ b/contrib/llvm/tools/lldb/source/Target/ThreadList.cpp
@@ -17,856 +17,749 @@
// Project includes
#include "lldb/Core/Log.h"
#include "lldb/Core/State.h"
+#include "lldb/Target/Process.h"
#include "lldb/Target/RegisterContext.h"
-#include "lldb/Target/ThreadList.h"
#include "lldb/Target/Thread.h"
+#include "lldb/Target/ThreadList.h"
#include "lldb/Target/ThreadPlan.h"
-#include "lldb/Target/Process.h"
#include "lldb/Utility/ConvertEnum.h"
#include "lldb/Utility/LLDBAssert.h"
using namespace lldb;
using namespace lldb_private;
-ThreadList::ThreadList (Process *process) :
- ThreadCollection(),
- m_process (process),
- m_stop_id (0),
- m_selected_tid (LLDB_INVALID_THREAD_ID)
-{
-}
-
-ThreadList::ThreadList (const ThreadList &rhs) :
- ThreadCollection(),
- m_process (rhs.m_process),
- m_stop_id (rhs.m_stop_id),
- m_selected_tid ()
-{
- // Use the assignment operator since it uses the mutex
- *this = rhs;
-}
-
-const ThreadList&
-ThreadList::operator = (const ThreadList& rhs)
-{
- if (this != &rhs)
- {
- // Lock both mutexes to make sure neither side changes anyone on us
- // while the assignment occurs
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
-
- m_process = rhs.m_process;
- m_stop_id = rhs.m_stop_id;
- m_threads = rhs.m_threads;
- m_selected_tid = rhs.m_selected_tid;
- }
- return *this;
+ThreadList::ThreadList(Process *process)
+ : ThreadCollection(), m_process(process), m_stop_id(0),
+ m_selected_tid(LLDB_INVALID_THREAD_ID) {}
+
+ThreadList::ThreadList(const ThreadList &rhs)
+ : ThreadCollection(), m_process(rhs.m_process), m_stop_id(rhs.m_stop_id),
+ m_selected_tid() {
+ // Use the assignment operator since it uses the mutex
+ *this = rhs;
}
+const ThreadList &ThreadList::operator=(const ThreadList &rhs) {
+ if (this != &rhs) {
+ // Lock both mutexes to make sure neither side changes anyone on us
+ // while the assignment occurs
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ std::lock_guard<std::recursive_mutex> rhs_guard(rhs.GetMutex());
-ThreadList::~ThreadList()
-{
- // Clear the thread list. Clear will take the mutex lock
- // which will ensure that if anyone is using the list
- // they won't get it removed while using it.
- Clear();
+ m_process = rhs.m_process;
+ m_stop_id = rhs.m_stop_id;
+ m_threads = rhs.m_threads;
+ m_selected_tid = rhs.m_selected_tid;
+ }
+ return *this;
}
-lldb::ThreadSP
-ThreadList::GetExpressionExecutionThread()
-{
- if (m_expression_tid_stack.empty())
- return GetSelectedThread();
- ThreadSP expr_thread_sp = FindThreadByID(m_expression_tid_stack.back());
- if (expr_thread_sp)
- return expr_thread_sp;
- else
- return GetSelectedThread();
+ThreadList::~ThreadList() {
+ // Clear the thread list. Clear will take the mutex lock
+ // which will ensure that if anyone is using the list
+ // they won't get it removed while using it.
+ Clear();
}
-void
-ThreadList::PushExpressionExecutionThread(lldb::tid_t tid)
-{
- m_expression_tid_stack.push_back(tid);
+lldb::ThreadSP ThreadList::GetExpressionExecutionThread() {
+ if (m_expression_tid_stack.empty())
+ return GetSelectedThread();
+ ThreadSP expr_thread_sp = FindThreadByID(m_expression_tid_stack.back());
+ if (expr_thread_sp)
+ return expr_thread_sp;
+ else
+ return GetSelectedThread();
}
-
-void
-ThreadList::PopExpressionExecutionThread(lldb::tid_t tid)
-{
- assert(m_expression_tid_stack.back() == tid);
- m_expression_tid_stack.pop_back();
+
+void ThreadList::PushExpressionExecutionThread(lldb::tid_t tid) {
+ m_expression_tid_stack.push_back(tid);
}
-uint32_t
-ThreadList::GetStopID () const
-{
- return m_stop_id;
+void ThreadList::PopExpressionExecutionThread(lldb::tid_t tid) {
+ assert(m_expression_tid_stack.back() == tid);
+ m_expression_tid_stack.pop_back();
}
-void
-ThreadList::SetStopID (uint32_t stop_id)
-{
- m_stop_id = stop_id;
+uint32_t ThreadList::GetStopID() const { return m_stop_id; }
+
+void ThreadList::SetStopID(uint32_t stop_id) { m_stop_id = stop_id; }
+
+uint32_t ThreadList::GetSize(bool can_update) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+
+ if (can_update)
+ m_process->UpdateThreadListIfNeeded();
+ return m_threads.size();
}
-uint32_t
-ThreadList::GetSize (bool can_update)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ThreadSP ThreadList::GetThreadAtIndex(uint32_t idx, bool can_update) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- if (can_update)
- m_process->UpdateThreadListIfNeeded();
- return m_threads.size();
+ if (can_update)
+ m_process->UpdateThreadListIfNeeded();
+
+ ThreadSP thread_sp;
+ if (idx < m_threads.size())
+ thread_sp = m_threads[idx];
+ return thread_sp;
}
-ThreadSP
-ThreadList::GetThreadAtIndex (uint32_t idx, bool can_update)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ThreadSP ThreadList::FindThreadByID(lldb::tid_t tid, bool can_update) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- if (can_update)
- m_process->UpdateThreadListIfNeeded();
+ if (can_update)
+ m_process->UpdateThreadListIfNeeded();
- ThreadSP thread_sp;
- if (idx < m_threads.size())
- thread_sp = m_threads[idx];
- return thread_sp;
+ ThreadSP thread_sp;
+ uint32_t idx = 0;
+ const uint32_t num_threads = m_threads.size();
+ for (idx = 0; idx < num_threads; ++idx) {
+ if (m_threads[idx]->GetID() == tid) {
+ thread_sp = m_threads[idx];
+ break;
+ }
+ }
+ return thread_sp;
}
-ThreadSP
-ThreadList::FindThreadByID (lldb::tid_t tid, bool can_update)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ThreadSP ThreadList::FindThreadByProtocolID(lldb::tid_t tid, bool can_update) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- if (can_update)
- m_process->UpdateThreadListIfNeeded();
+ if (can_update)
+ m_process->UpdateThreadListIfNeeded();
- ThreadSP thread_sp;
- uint32_t idx = 0;
- const uint32_t num_threads = m_threads.size();
- for (idx = 0; idx < num_threads; ++idx)
- {
- if (m_threads[idx]->GetID() == tid)
- {
- thread_sp = m_threads[idx];
- break;
- }
+ ThreadSP thread_sp;
+ uint32_t idx = 0;
+ const uint32_t num_threads = m_threads.size();
+ for (idx = 0; idx < num_threads; ++idx) {
+ if (m_threads[idx]->GetProtocolID() == tid) {
+ thread_sp = m_threads[idx];
+ break;
}
- return thread_sp;
+ }
+ return thread_sp;
}
-ThreadSP
-ThreadList::FindThreadByProtocolID (lldb::tid_t tid, bool can_update)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ThreadSP ThreadList::RemoveThreadByID(lldb::tid_t tid, bool can_update) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- if (can_update)
- m_process->UpdateThreadListIfNeeded();
-
- ThreadSP thread_sp;
- uint32_t idx = 0;
- const uint32_t num_threads = m_threads.size();
- for (idx = 0; idx < num_threads; ++idx)
- {
- if (m_threads[idx]->GetProtocolID() == tid)
- {
- thread_sp = m_threads[idx];
- break;
- }
+ if (can_update)
+ m_process->UpdateThreadListIfNeeded();
+
+ ThreadSP thread_sp;
+ uint32_t idx = 0;
+ const uint32_t num_threads = m_threads.size();
+ for (idx = 0; idx < num_threads; ++idx) {
+ if (m_threads[idx]->GetID() == tid) {
+ thread_sp = m_threads[idx];
+ m_threads.erase(m_threads.begin() + idx);
+ break;
}
- return thread_sp;
+ }
+ return thread_sp;
}
+ThreadSP ThreadList::RemoveThreadByProtocolID(lldb::tid_t tid,
+ bool can_update) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
-ThreadSP
-ThreadList::RemoveThreadByID (lldb::tid_t tid, bool can_update)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ if (can_update)
+ m_process->UpdateThreadListIfNeeded();
- if (can_update)
- m_process->UpdateThreadListIfNeeded();
-
- ThreadSP thread_sp;
- uint32_t idx = 0;
- const uint32_t num_threads = m_threads.size();
- for (idx = 0; idx < num_threads; ++idx)
- {
- if (m_threads[idx]->GetID() == tid)
- {
- thread_sp = m_threads[idx];
- m_threads.erase(m_threads.begin()+idx);
- break;
- }
+ ThreadSP thread_sp;
+ uint32_t idx = 0;
+ const uint32_t num_threads = m_threads.size();
+ for (idx = 0; idx < num_threads; ++idx) {
+ if (m_threads[idx]->GetProtocolID() == tid) {
+ thread_sp = m_threads[idx];
+ m_threads.erase(m_threads.begin() + idx);
+ break;
}
- return thread_sp;
+ }
+ return thread_sp;
}
-ThreadSP
-ThreadList::RemoveThreadByProtocolID (lldb::tid_t tid, bool can_update)
-{
+ThreadSP ThreadList::GetThreadSPForThreadPtr(Thread *thread_ptr) {
+ ThreadSP thread_sp;
+ if (thread_ptr) {
std::lock_guard<std::recursive_mutex> guard(GetMutex());
- if (can_update)
- m_process->UpdateThreadListIfNeeded();
-
- ThreadSP thread_sp;
uint32_t idx = 0;
const uint32_t num_threads = m_threads.size();
- for (idx = 0; idx < num_threads; ++idx)
- {
- if (m_threads[idx]->GetProtocolID() == tid)
- {
- thread_sp = m_threads[idx];
- m_threads.erase(m_threads.begin()+idx);
- break;
- }
+ for (idx = 0; idx < num_threads; ++idx) {
+ if (m_threads[idx].get() == thread_ptr) {
+ thread_sp = m_threads[idx];
+ break;
+ }
}
- return thread_sp;
-}
-
-ThreadSP
-ThreadList::GetThreadSPForThreadPtr (Thread *thread_ptr)
-{
- ThreadSP thread_sp;
- if (thread_ptr)
- {
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
-
- uint32_t idx = 0;
- const uint32_t num_threads = m_threads.size();
- for (idx = 0; idx < num_threads; ++idx)
- {
- if (m_threads[idx].get() == thread_ptr)
- {
- thread_sp = m_threads[idx];
- break;
- }
- }
+ }
+ return thread_sp;
+}
+
+ThreadSP ThreadList::FindThreadByIndexID(uint32_t index_id, bool can_update) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+
+ if (can_update)
+ m_process->UpdateThreadListIfNeeded();
+
+ ThreadSP thread_sp;
+ const uint32_t num_threads = m_threads.size();
+ for (uint32_t idx = 0; idx < num_threads; ++idx) {
+ if (m_threads[idx]->GetIndexID() == index_id) {
+ thread_sp = m_threads[idx];
+ break;
}
- return thread_sp;
+ }
+ return thread_sp;
}
+bool ThreadList::ShouldStop(Event *event_ptr) {
+ // Running events should never stop, obviously...
+ Log *log(lldb_private::GetLogIfAllCategoriesSet(LIBLLDB_LOG_STEP));
-ThreadSP
-ThreadList::FindThreadByIndexID (uint32_t index_id, bool can_update)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ // The ShouldStop method of the threads can do a whole lot of work,
+ // figuring out whether the thread plan conditions are met. So we don't want
+ // to keep the ThreadList locked the whole time we are doing this.
+ // FIXME: It is possible that running code could cause new threads
+ // to be created. If that happens, we will miss asking them whether
+ // they should stop. This is not a big deal since we haven't had
+ // a chance to hang any interesting operations on those threads yet.
- if (can_update)
- m_process->UpdateThreadListIfNeeded();
+ collection threads_copy;
+ {
+ // Scope for locker
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- ThreadSP thread_sp;
- const uint32_t num_threads = m_threads.size();
- for (uint32_t idx = 0; idx < num_threads; ++idx)
- {
- if (m_threads[idx]->GetIndexID() == index_id)
- {
- thread_sp = m_threads[idx];
- break;
- }
+ m_process->UpdateThreadListIfNeeded();
+ for (lldb::ThreadSP thread_sp : m_threads) {
+ // This is an optimization... If we didn't let a thread run in between
+ // the previous stop and this
+ // one, we shouldn't have to consult it for ShouldStop. So just leave it
+ // off the list we are going to
+ // inspect.
+ // On Linux, if a thread-specific conditional breakpoint was hit, it won't
+ // necessarily be the thread
+ // that hit the breakpoint itself that evaluates the conditional
+ // expression, so the thread that hit
+ // the breakpoint could still be asked to stop, even though it hasn't been
+ // allowed to run since the
+ // previous stop.
+ if (thread_sp->GetTemporaryResumeState() != eStateSuspended ||
+ thread_sp->IsStillAtLastBreakpointHit())
+ threads_copy.push_back(thread_sp);
}
- return thread_sp;
-}
-
-bool
-ThreadList::ShouldStop (Event *event_ptr)
-{
- // Running events should never stop, obviously...
-
- Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_STEP));
-
- // The ShouldStop method of the threads can do a whole lot of work,
- // figuring out whether the thread plan conditions are met. So we don't want
- // to keep the ThreadList locked the whole time we are doing this.
- // FIXME: It is possible that running code could cause new threads
- // to be created. If that happens, we will miss asking them whether
- // they should stop. This is not a big deal since we haven't had
- // a chance to hang any interesting operations on those threads yet.
-
- collection threads_copy;
- {
- // Scope for locker
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
-
- m_process->UpdateThreadListIfNeeded();
- for (lldb::ThreadSP thread_sp : m_threads)
- {
- // This is an optimization... If we didn't let a thread run in between the previous stop and this
- // one, we shouldn't have to consult it for ShouldStop. So just leave it off the list we are going to
- // inspect.
- // On Linux, if a thread-specific conditional breakpoint was hit, it won't necessarily be the thread
- // that hit the breakpoint itself that evaluates the conditional expression, so the thread that hit
- // the breakpoint could still be asked to stop, even though it hasn't been allowed to run since the
- // previous stop.
- if (thread_sp->GetTemporaryResumeState () != eStateSuspended || thread_sp->IsStillAtLastBreakpointHit())
- threads_copy.push_back(thread_sp);
- }
- // It is possible the threads we were allowing to run all exited and then maybe the user interrupted
- // or something, then fall back on looking at all threads:
+ // It is possible the threads we were allowing to run all exited and then
+ // maybe the user interrupted
+ // or something, then fall back on looking at all threads:
- if (threads_copy.size() == 0)
- threads_copy = m_threads;
- }
+ if (threads_copy.size() == 0)
+ threads_copy = m_threads;
+ }
+
+ collection::iterator pos, end = threads_copy.end();
- collection::iterator pos, end = threads_copy.end();
+ if (log) {
+ log->PutCString("");
+ log->Printf("ThreadList::%s: %" PRIu64 " threads, %" PRIu64
+ " unsuspended threads",
+ __FUNCTION__, (uint64_t)m_threads.size(),
+ (uint64_t)threads_copy.size());
+ }
+ bool did_anybody_stop_for_a_reason = false;
+
+ // If the event is an Interrupt event, then we're going to stop no matter
+ // what. Otherwise, presume we won't stop.
+ bool should_stop = false;
+ if (Process::ProcessEventData::GetInterruptedFromEvent(event_ptr)) {
if (log)
- {
- log->PutCString("");
- log->Printf ("ThreadList::%s: %" PRIu64 " threads, %" PRIu64 " unsuspended threads",
- __FUNCTION__,
- (uint64_t)m_threads.size(),
- (uint64_t)threads_copy.size());
- }
+ log->Printf(
+ "ThreadList::%s handling interrupt event, should stop set to true",
+ __FUNCTION__);
+
+ should_stop = true;
+ }
+
+ // Now we run through all the threads and get their stop info's. We want to
+ // make sure to do this first before
+ // we start running the ShouldStop, because one thread's ShouldStop could
+ // destroy information (like deleting a
+ // thread specific breakpoint another thread had stopped at) which could lead
+ // us to compute the StopInfo incorrectly.
+ // We don't need to use it here, we just want to make sure it gets computed.
+
+ for (pos = threads_copy.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+ thread_sp->GetStopInfo();
+ }
+
+ for (pos = threads_copy.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+
+ // We should never get a stop for which no thread had a stop reason, but
+ // sometimes we do see this -
+ // for instance when we first connect to a remote stub. In that case we
+ // should stop, since we can't figure out
+ // the right thing to do and stopping gives the user control over what to do
+ // in this instance.
+ //
+ // Note, this causes a problem when you have a thread specific breakpoint,
+ // and a bunch of threads hit the breakpoint,
+ // but not the thread which we are waiting for. All the threads that are
+ // not "supposed" to hit the breakpoint
+ // are marked as having no stop reason, which is right, they should not show
+ // a stop reason. But that triggers this
+ // code and causes us to stop seemingly for no reason.
+ //
+ // Since the only way we ever saw this error was on first attach, I'm only
+ // going to trigger set did_anybody_stop_for_a_reason
+ // to true unless this is the first stop.
+ //
+ // If this becomes a problem, we'll have to have another StopReason like
+ // "StopInfoHidden" which will look invalid
+ // everywhere but at this check.
+
+ if (thread_sp->GetProcess()->GetStopID() > 1)
+ did_anybody_stop_for_a_reason = true;
+ else
+ did_anybody_stop_for_a_reason |= thread_sp->ThreadStoppedForAReason();
- bool did_anybody_stop_for_a_reason = false;
-
- // If the event is an Interrupt event, then we're going to stop no matter what. Otherwise, presume we won't stop.
- bool should_stop = false;
- if (Process::ProcessEventData::GetInterruptedFromEvent(event_ptr))
- {
- if (log)
- log->Printf("ThreadList::%s handling interrupt event, should stop set to true", __FUNCTION__);
-
- should_stop = true;
- }
-
- // Now we run through all the threads and get their stop info's. We want to make sure to do this first before
- // we start running the ShouldStop, because one thread's ShouldStop could destroy information (like deleting a
- // thread specific breakpoint another thread had stopped at) which could lead us to compute the StopInfo incorrectly.
- // We don't need to use it here, we just want to make sure it gets computed.
-
- for (pos = threads_copy.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
- thread_sp->GetStopInfo();
- }
-
- for (pos = threads_copy.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
-
- // We should never get a stop for which no thread had a stop reason, but sometimes we do see this -
- // for instance when we first connect to a remote stub. In that case we should stop, since we can't figure out
- // the right thing to do and stopping gives the user control over what to do in this instance.
- //
- // Note, this causes a problem when you have a thread specific breakpoint, and a bunch of threads hit the breakpoint,
- // but not the thread which we are waiting for. All the threads that are not "supposed" to hit the breakpoint
- // are marked as having no stop reason, which is right, they should not show a stop reason. But that triggers this
- // code and causes us to stop seemingly for no reason.
- //
- // Since the only way we ever saw this error was on first attach, I'm only going to trigger set did_anybody_stop_for_a_reason
- // to true unless this is the first stop.
- //
- // If this becomes a problem, we'll have to have another StopReason like "StopInfoHidden" which will look invalid
- // everywhere but at this check.
-
- if (thread_sp->GetProcess()->GetStopID() > 1)
- did_anybody_stop_for_a_reason = true;
- else
- did_anybody_stop_for_a_reason |= thread_sp->ThreadStoppedForAReason();
-
- const bool thread_should_stop = thread_sp->ShouldStop(event_ptr);
- if (thread_should_stop)
- should_stop |= true;
- }
+ const bool thread_should_stop = thread_sp->ShouldStop(event_ptr);
+ if (thread_should_stop)
+ should_stop |= true;
+ }
- if (!should_stop && !did_anybody_stop_for_a_reason)
- {
- should_stop = true;
- if (log)
- log->Printf ("ThreadList::%s we stopped but no threads had a stop reason, overriding should_stop and stopping.", __FUNCTION__);
- }
-
+ if (!should_stop && !did_anybody_stop_for_a_reason) {
+ should_stop = true;
if (log)
- log->Printf ("ThreadList::%s overall should_stop = %i", __FUNCTION__, should_stop);
-
- if (should_stop)
- {
- for (pos = threads_copy.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
- thread_sp->WillStop ();
- }
+ log->Printf("ThreadList::%s we stopped but no threads had a stop reason, "
+ "overriding should_stop and stopping.",
+ __FUNCTION__);
+ }
+
+ if (log)
+ log->Printf("ThreadList::%s overall should_stop = %i", __FUNCTION__,
+ should_stop);
+
+ if (should_stop) {
+ for (pos = threads_copy.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+ thread_sp->WillStop();
}
+ }
- return should_stop;
+ return should_stop;
}
-Vote
-ThreadList::ShouldReportStop (Event *event_ptr)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+Vote ThreadList::ShouldReportStop(Event *event_ptr) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- Vote result = eVoteNoOpinion;
- m_process->UpdateThreadListIfNeeded();
- collection::iterator pos, end = m_threads.end();
+ Vote result = eVoteNoOpinion;
+ m_process->UpdateThreadListIfNeeded();
+ collection::iterator pos, end = m_threads.end();
- Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_STEP));
+ Log *log(lldb_private::GetLogIfAllCategoriesSet(LIBLLDB_LOG_STEP));
- if (log)
- log->Printf ("ThreadList::%s %" PRIu64 " threads", __FUNCTION__, (uint64_t)m_threads.size());
-
- // Run through the threads and ask whether we should report this event.
- // For stopping, a YES vote wins over everything. A NO vote wins over NO opinion.
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
- const Vote vote = thread_sp->ShouldReportStop (event_ptr);
- switch (vote)
- {
- case eVoteNoOpinion:
- continue;
-
- case eVoteYes:
- result = eVoteYes;
- break;
-
- case eVoteNo:
- if (result == eVoteNoOpinion)
- {
- result = eVoteNo;
- }
- else
- {
- if (log)
- log->Printf ("ThreadList::%s thread 0x%4.4" PRIx64 ": voted %s, but lost out because result was %s",
- __FUNCTION__,
- thread_sp->GetID (),
- GetVoteAsCString (vote),
- GetVoteAsCString (result));
- }
- break;
- }
+ if (log)
+ log->Printf("ThreadList::%s %" PRIu64 " threads", __FUNCTION__,
+ (uint64_t)m_threads.size());
+
+ // Run through the threads and ask whether we should report this event.
+ // For stopping, a YES vote wins over everything. A NO vote wins over NO
+ // opinion.
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+ const Vote vote = thread_sp->ShouldReportStop(event_ptr);
+ switch (vote) {
+ case eVoteNoOpinion:
+ continue;
+
+ case eVoteYes:
+ result = eVoteYes;
+ break;
+
+ case eVoteNo:
+ if (result == eVoteNoOpinion) {
+ result = eVoteNo;
+ } else {
+ if (log)
+ log->Printf("ThreadList::%s thread 0x%4.4" PRIx64
+ ": voted %s, but lost out because result was %s",
+ __FUNCTION__, thread_sp->GetID(), GetVoteAsCString(vote),
+ GetVoteAsCString(result));
+ }
+ break;
}
- if (log)
- log->Printf ("ThreadList::%s returning %s", __FUNCTION__, GetVoteAsCString (result));
- return result;
+ }
+ if (log)
+ log->Printf("ThreadList::%s returning %s", __FUNCTION__,
+ GetVoteAsCString(result));
+ return result;
}
-void
-ThreadList::SetShouldReportStop (Vote vote)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+void ThreadList::SetShouldReportStop(Vote vote) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- m_process->UpdateThreadListIfNeeded();
- collection::iterator pos, end = m_threads.end();
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
- thread_sp->SetShouldReportStop (vote);
- }
+ m_process->UpdateThreadListIfNeeded();
+ collection::iterator pos, end = m_threads.end();
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+ thread_sp->SetShouldReportStop(vote);
+ }
}
-Vote
-ThreadList::ShouldReportRun (Event *event_ptr)
-{
+Vote ThreadList::ShouldReportRun(Event *event_ptr) {
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- Vote result = eVoteNoOpinion;
- m_process->UpdateThreadListIfNeeded();
- collection::iterator pos, end = m_threads.end();
-
- // Run through the threads and ask whether we should report this event.
- // The rule is NO vote wins over everything, a YES vote wins over no opinion.
-
- Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_STEP));
-
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- if ((*pos)->GetResumeState () != eStateSuspended)
- {
- switch ((*pos)->ShouldReportRun (event_ptr))
- {
- case eVoteNoOpinion:
- continue;
- case eVoteYes:
- if (result == eVoteNoOpinion)
- result = eVoteYes;
- break;
- case eVoteNo:
- if (log)
- log->Printf ("ThreadList::ShouldReportRun() thread %d (0x%4.4" PRIx64 ") says don't report.",
- (*pos)->GetIndexID(),
- (*pos)->GetID());
- result = eVoteNo;
- break;
- }
- }
+ Vote result = eVoteNoOpinion;
+ m_process->UpdateThreadListIfNeeded();
+ collection::iterator pos, end = m_threads.end();
+
+ // Run through the threads and ask whether we should report this event.
+ // The rule is NO vote wins over everything, a YES vote wins over no opinion.
+
+ Log *log(lldb_private::GetLogIfAllCategoriesSet(LIBLLDB_LOG_STEP));
+
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ if ((*pos)->GetResumeState() != eStateSuspended) {
+ switch ((*pos)->ShouldReportRun(event_ptr)) {
+ case eVoteNoOpinion:
+ continue;
+ case eVoteYes:
+ if (result == eVoteNoOpinion)
+ result = eVoteYes;
+ break;
+ case eVoteNo:
+ if (log)
+ log->Printf("ThreadList::ShouldReportRun() thread %d (0x%4.4" PRIx64
+ ") says don't report.",
+ (*pos)->GetIndexID(), (*pos)->GetID());
+ result = eVoteNo;
+ break;
+ }
}
- return result;
+ }
+ return result;
}
-void
-ThreadList::Clear()
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- m_stop_id = 0;
- m_threads.clear();
- m_selected_tid = LLDB_INVALID_THREAD_ID;
+void ThreadList::Clear() {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ m_stop_id = 0;
+ m_threads.clear();
+ m_selected_tid = LLDB_INVALID_THREAD_ID;
}
-void
-ThreadList::Destroy()
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- const uint32_t num_threads = m_threads.size();
- for (uint32_t idx = 0; idx < num_threads; ++idx)
- {
- m_threads[idx]->DestroyThread();
- }
+void ThreadList::Destroy() {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ const uint32_t num_threads = m_threads.size();
+ for (uint32_t idx = 0; idx < num_threads; ++idx) {
+ m_threads[idx]->DestroyThread();
+ }
}
-void
-ThreadList::RefreshStateAfterStop ()
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+void ThreadList::RefreshStateAfterStop() {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
- m_process->UpdateThreadListIfNeeded();
-
- Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_STEP));
- if (log && log->GetVerbose())
- log->Printf ("Turning off notification of new threads while single stepping a thread.");
+ m_process->UpdateThreadListIfNeeded();
- collection::iterator pos, end = m_threads.end();
- for (pos = m_threads.begin(); pos != end; ++pos)
- (*pos)->RefreshStateAfterStop ();
-}
+ Log *log(lldb_private::GetLogIfAllCategoriesSet(LIBLLDB_LOG_STEP));
+ if (log && log->GetVerbose())
+ log->Printf("Turning off notification of new threads while single stepping "
+ "a thread.");
-void
-ThreadList::DiscardThreadPlans ()
-{
- // You don't need to update the thread list here, because only threads
- // that you currently know about have any thread plans.
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ collection::iterator pos, end = m_threads.end();
+ for (pos = m_threads.begin(); pos != end; ++pos)
+ (*pos)->RefreshStateAfterStop();
+}
- collection::iterator pos, end = m_threads.end();
- for (pos = m_threads.begin(); pos != end; ++pos)
- (*pos)->DiscardThreadPlans (true);
+void ThreadList::DiscardThreadPlans() {
+ // You don't need to update the thread list here, because only threads
+ // that you currently know about have any thread plans.
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ collection::iterator pos, end = m_threads.end();
+ for (pos = m_threads.begin(); pos != end; ++pos)
+ (*pos)->DiscardThreadPlans(true);
}
-bool
-ThreadList::WillResume ()
-{
- // Run through the threads and perform their momentary actions.
- // But we only do this for threads that are running, user suspended
- // threads stay where they are.
+bool ThreadList::WillResume() {
+ // Run through the threads and perform their momentary actions.
+ // But we only do this for threads that are running, user suspended
+ // threads stay where they are.
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- m_process->UpdateThreadListIfNeeded();
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ m_process->UpdateThreadListIfNeeded();
- collection::iterator pos, end = m_threads.end();
-
- // See if any thread wants to run stopping others. If it does, then we won't
- // setup the other threads for resume, since they aren't going to get a chance
- // to run. This is necessary because the SetupForResume might add "StopOthers"
- // plans which would then get to be part of the who-gets-to-run negotiation, but
- // they're coming in after the fact, and the threads that are already set up should
- // take priority.
-
- bool wants_solo_run = false;
-
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- lldbassert((*pos)->GetCurrentPlan() && "thread should not have null thread plan");
- if ((*pos)->GetResumeState() != eStateSuspended &&
- (*pos)->GetCurrentPlan()->StopOthers())
- {
- if ((*pos)->IsOperatingSystemPluginThread() && !(*pos)->GetBackingThread())
- continue;
- wants_solo_run = true;
- break;
- }
- }
-
- if (wants_solo_run)
- {
- Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_STEP));
- if (log && log->GetVerbose())
- log->Printf ("Turning on notification of new threads while single stepping a thread.");
- m_process->StartNoticingNewThreads();
- }
- else
- {
- Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_STEP));
- if (log && log->GetVerbose())
- log->Printf ("Turning off notification of new threads while single stepping a thread.");
- m_process->StopNoticingNewThreads();
- }
-
- // Give all the threads that are likely to run a last chance to set up their state before we
- // negotiate who is actually going to get a chance to run...
- // Don't set to resume suspended threads, and if any thread wanted to stop others, only
- // call setup on the threads that request StopOthers...
-
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- if ((*pos)->GetResumeState() != eStateSuspended
- && (!wants_solo_run || (*pos)->GetCurrentPlan()->StopOthers()))
- {
- if ((*pos)->IsOperatingSystemPluginThread() && !(*pos)->GetBackingThread())
- continue;
- (*pos)->SetupForResume ();
- }
- }
+ collection::iterator pos, end = m_threads.end();
- // Now go through the threads and see if any thread wants to run just itself.
- // if so then pick one and run it.
-
- ThreadList run_me_only_list (m_process);
-
- run_me_only_list.SetStopID(m_process->GetStopID());
-
- bool run_only_current_thread = false;
-
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
- if (thread_sp->GetResumeState() != eStateSuspended &&
- thread_sp->GetCurrentPlan()->StopOthers())
- {
- if ((*pos)->IsOperatingSystemPluginThread() && !(*pos)->GetBackingThread())
- continue;
-
- // You can't say "stop others" and also want yourself to be suspended.
- assert (thread_sp->GetCurrentPlan()->RunState() != eStateSuspended);
-
- if (thread_sp == GetSelectedThread())
- {
- // If the currently selected thread wants to run on its own, always let it.
- run_only_current_thread = true;
- run_me_only_list.Clear();
- run_me_only_list.AddThread (thread_sp);
- break;
- }
-
- run_me_only_list.AddThread (thread_sp);
- }
+ // See if any thread wants to run stopping others. If it does, then we won't
+ // setup the other threads for resume, since they aren't going to get a chance
+ // to run. This is necessary because the SetupForResume might add
+ // "StopOthers"
+ // plans which would then get to be part of the who-gets-to-run negotiation,
+ // but
+ // they're coming in after the fact, and the threads that are already set up
+ // should
+ // take priority.
+
+ bool wants_solo_run = false;
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ lldbassert((*pos)->GetCurrentPlan() &&
+ "thread should not have null thread plan");
+ if ((*pos)->GetResumeState() != eStateSuspended &&
+ (*pos)->GetCurrentPlan()->StopOthers()) {
+ if ((*pos)->IsOperatingSystemPluginThread() &&
+ !(*pos)->GetBackingThread())
+ continue;
+ wants_solo_run = true;
+ break;
}
+ }
- bool need_to_resume = true;
-
- if (run_me_only_list.GetSize (false) == 0)
- {
- // Everybody runs as they wish:
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
- StateType run_state;
- if (thread_sp->GetResumeState() != eStateSuspended)
- run_state = thread_sp->GetCurrentPlan()->RunState();
- else
- run_state = eStateSuspended;
- if (!thread_sp->ShouldResume(run_state))
- need_to_resume = false;
- }
+ if (wants_solo_run) {
+ Log *log(lldb_private::GetLogIfAllCategoriesSet(LIBLLDB_LOG_STEP));
+ if (log && log->GetVerbose())
+ log->Printf("Turning on notification of new threads while single "
+ "stepping a thread.");
+ m_process->StartNoticingNewThreads();
+ } else {
+ Log *log(lldb_private::GetLogIfAllCategoriesSet(LIBLLDB_LOG_STEP));
+ if (log && log->GetVerbose())
+ log->Printf("Turning off notification of new threads while single "
+ "stepping a thread.");
+ m_process->StopNoticingNewThreads();
+ }
+
+ // Give all the threads that are likely to run a last chance to set up their
+ // state before we
+ // negotiate who is actually going to get a chance to run...
+ // Don't set to resume suspended threads, and if any thread wanted to stop
+ // others, only
+ // call setup on the threads that request StopOthers...
+
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ if ((*pos)->GetResumeState() != eStateSuspended &&
+ (!wants_solo_run || (*pos)->GetCurrentPlan()->StopOthers())) {
+ if ((*pos)->IsOperatingSystemPluginThread() &&
+ !(*pos)->GetBackingThread())
+ continue;
+ (*pos)->SetupForResume();
}
- else
- {
- ThreadSP thread_to_run;
+ }
- if (run_only_current_thread)
- {
- thread_to_run = GetSelectedThread();
- }
- else if (run_me_only_list.GetSize (false) == 1)
- {
- thread_to_run = run_me_only_list.GetThreadAtIndex (0);
- }
- else
- {
- int random_thread = (int)
- ((run_me_only_list.GetSize (false) * (double) rand ()) / (RAND_MAX + 1.0));
- thread_to_run = run_me_only_list.GetThreadAtIndex (random_thread);
- }
+ // Now go through the threads and see if any thread wants to run just itself.
+ // if so then pick one and run it.
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- ThreadSP thread_sp(*pos);
- if (thread_sp == thread_to_run)
- {
- if (!thread_sp->ShouldResume(thread_sp->GetCurrentPlan()->RunState()))
- need_to_resume = false;
- }
- else
- thread_sp->ShouldResume (eStateSuspended);
- }
- }
+ ThreadList run_me_only_list(m_process);
- return need_to_resume;
-}
+ run_me_only_list.SetStopID(m_process->GetStopID());
-void
-ThreadList::DidResume ()
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- collection::iterator pos, end = m_threads.end();
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- // Don't clear out threads that aren't going to get a chance to run, rather
- // leave their state for the next time around.
- ThreadSP thread_sp(*pos);
- if (thread_sp->GetResumeState() != eStateSuspended)
- thread_sp->DidResume ();
- }
-}
+ bool run_only_current_thread = false;
-void
-ThreadList::DidStop ()
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- collection::iterator pos, end = m_threads.end();
- for (pos = m_threads.begin(); pos != end; ++pos)
- {
- // Notify threads that the process just stopped.
- // Note, this currently assumes that all threads in the list
- // stop when the process stops. In the future we will want to support
- // a debugging model where some threads continue to run while others
- // are stopped. We either need to handle that somehow here or
- // create a special thread list containing only threads which will
- // stop in the code that calls this method (currently
- // Process::SetPrivateState).
- ThreadSP thread_sp(*pos);
- if (StateIsRunningState(thread_sp->GetState()))
- thread_sp->DidStop ();
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+ if (thread_sp->GetResumeState() != eStateSuspended &&
+ thread_sp->GetCurrentPlan()->StopOthers()) {
+ if ((*pos)->IsOperatingSystemPluginThread() &&
+ !(*pos)->GetBackingThread())
+ continue;
+
+ // You can't say "stop others" and also want yourself to be suspended.
+ assert(thread_sp->GetCurrentPlan()->RunState() != eStateSuspended);
+
+ if (thread_sp == GetSelectedThread()) {
+ // If the currently selected thread wants to run on its own, always let
+ // it.
+ run_only_current_thread = true;
+ run_me_only_list.Clear();
+ run_me_only_list.AddThread(thread_sp);
+ break;
+ }
+
+ run_me_only_list.AddThread(thread_sp);
+ }
+ }
+
+ bool need_to_resume = true;
+
+ if (run_me_only_list.GetSize(false) == 0) {
+ // Everybody runs as they wish:
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+ StateType run_state;
+ if (thread_sp->GetResumeState() != eStateSuspended)
+ run_state = thread_sp->GetCurrentPlan()->RunState();
+ else
+ run_state = eStateSuspended;
+ if (!thread_sp->ShouldResume(run_state))
+ need_to_resume = false;
+ }
+ } else {
+ ThreadSP thread_to_run;
+
+ if (run_only_current_thread) {
+ thread_to_run = GetSelectedThread();
+ } else if (run_me_only_list.GetSize(false) == 1) {
+ thread_to_run = run_me_only_list.GetThreadAtIndex(0);
+ } else {
+ int random_thread =
+ (int)((run_me_only_list.GetSize(false) * (double)rand()) /
+ (RAND_MAX + 1.0));
+ thread_to_run = run_me_only_list.GetThreadAtIndex(random_thread);
}
-}
-ThreadSP
-ThreadList::GetSelectedThread ()
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- ThreadSP thread_sp = FindThreadByID(m_selected_tid);
- if (!thread_sp.get())
- {
- if (m_threads.size() == 0)
- return thread_sp;
- m_selected_tid = m_threads[0]->GetID();
- thread_sp = m_threads[0];
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ ThreadSP thread_sp(*pos);
+ if (thread_sp == thread_to_run) {
+ if (!thread_sp->ShouldResume(thread_sp->GetCurrentPlan()->RunState()))
+ need_to_resume = false;
+ } else
+ thread_sp->ShouldResume(eStateSuspended);
}
- return thread_sp;
+ }
+
+ return need_to_resume;
+}
+
+void ThreadList::DidResume() {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ collection::iterator pos, end = m_threads.end();
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ // Don't clear out threads that aren't going to get a chance to run, rather
+ // leave their state for the next time around.
+ ThreadSP thread_sp(*pos);
+ if (thread_sp->GetResumeState() != eStateSuspended)
+ thread_sp->DidResume();
+ }
+}
+
+void ThreadList::DidStop() {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ collection::iterator pos, end = m_threads.end();
+ for (pos = m_threads.begin(); pos != end; ++pos) {
+ // Notify threads that the process just stopped.
+ // Note, this currently assumes that all threads in the list
+ // stop when the process stops. In the future we will want to support
+ // a debugging model where some threads continue to run while others
+ // are stopped. We either need to handle that somehow here or
+ // create a special thread list containing only threads which will
+ // stop in the code that calls this method (currently
+ // Process::SetPrivateState).
+ ThreadSP thread_sp(*pos);
+ if (StateIsRunningState(thread_sp->GetState()))
+ thread_sp->DidStop();
+ }
+}
+
+ThreadSP ThreadList::GetSelectedThread() {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ ThreadSP thread_sp = FindThreadByID(m_selected_tid);
+ if (!thread_sp.get()) {
+ if (m_threads.size() == 0)
+ return thread_sp;
+ m_selected_tid = m_threads[0]->GetID();
+ thread_sp = m_threads[0];
+ }
+ return thread_sp;
+}
+
+bool ThreadList::SetSelectedThreadByID(lldb::tid_t tid, bool notify) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ ThreadSP selected_thread_sp(FindThreadByID(tid));
+ if (selected_thread_sp) {
+ m_selected_tid = tid;
+ selected_thread_sp->SetDefaultFileAndLineToSelectedFrame();
+ } else
+ m_selected_tid = LLDB_INVALID_THREAD_ID;
+
+ if (notify)
+ NotifySelectedThreadChanged(m_selected_tid);
+
+ return m_selected_tid != LLDB_INVALID_THREAD_ID;
}
-bool
-ThreadList::SetSelectedThreadByID (lldb::tid_t tid, bool notify)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- ThreadSP selected_thread_sp(FindThreadByID(tid));
- if (selected_thread_sp)
- {
- m_selected_tid = tid;
- selected_thread_sp->SetDefaultFileAndLineToSelectedFrame();
- }
- else
- m_selected_tid = LLDB_INVALID_THREAD_ID;
+bool ThreadList::SetSelectedThreadByIndexID(uint32_t index_id, bool notify) {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ ThreadSP selected_thread_sp(FindThreadByIndexID(index_id));
+ if (selected_thread_sp.get()) {
+ m_selected_tid = selected_thread_sp->GetID();
+ selected_thread_sp->SetDefaultFileAndLineToSelectedFrame();
+ } else
+ m_selected_tid = LLDB_INVALID_THREAD_ID;
+
+ if (notify)
+ NotifySelectedThreadChanged(m_selected_tid);
- if (notify)
- NotifySelectedThreadChanged(m_selected_tid);
-
- return m_selected_tid != LLDB_INVALID_THREAD_ID;
+ return m_selected_tid != LLDB_INVALID_THREAD_ID;
}
-bool
-ThreadList::SetSelectedThreadByIndexID (uint32_t index_id, bool notify)
-{
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
- ThreadSP selected_thread_sp (FindThreadByIndexID(index_id));
- if (selected_thread_sp.get())
- {
- m_selected_tid = selected_thread_sp->GetID();
- selected_thread_sp->SetDefaultFileAndLineToSelectedFrame();
- }
- else
- m_selected_tid = LLDB_INVALID_THREAD_ID;
-
- if (notify)
- NotifySelectedThreadChanged(m_selected_tid);
-
- return m_selected_tid != LLDB_INVALID_THREAD_ID;
-}
-
-void
-ThreadList::NotifySelectedThreadChanged (lldb::tid_t tid)
-{
- ThreadSP selected_thread_sp (FindThreadByID(tid));
- if (selected_thread_sp->EventTypeHasListeners(Thread::eBroadcastBitThreadSelected))
- selected_thread_sp->BroadcastEvent(Thread::eBroadcastBitThreadSelected,
- new Thread::ThreadEventData(selected_thread_sp));
-}
-
-void
-ThreadList::Update (ThreadList &rhs)
-{
- if (this != &rhs)
- {
- // Lock both mutexes to make sure neither side changes anyone on us
- // while the assignment occurs
- std::lock_guard<std::recursive_mutex> guard(GetMutex());
-
- m_process = rhs.m_process;
- m_stop_id = rhs.m_stop_id;
- m_threads.swap(rhs.m_threads);
- m_selected_tid = rhs.m_selected_tid;
-
-
- // Now we look for threads that we are done with and
- // make sure to clear them up as much as possible so
- // anyone with a shared pointer will still have a reference,
- // but the thread won't be of much use. Using std::weak_ptr
- // for all backward references (such as a thread to a process)
- // will eventually solve this issue for us, but for now, we
- // need to work around the issue
- collection::iterator rhs_pos, rhs_end = rhs.m_threads.end();
- for (rhs_pos = rhs.m_threads.begin(); rhs_pos != rhs_end; ++rhs_pos)
- {
- const lldb::tid_t tid = (*rhs_pos)->GetID();
- bool thread_is_alive = false;
- const uint32_t num_threads = m_threads.size();
- for (uint32_t idx = 0; idx < num_threads; ++idx)
- {
- ThreadSP backing_thread = m_threads[idx]->GetBackingThread();
- if (m_threads[idx]->GetID() == tid || (backing_thread && backing_thread->GetID() == tid))
- {
- thread_is_alive = true;
- break;
- }
- }
- if (!thread_is_alive)
- (*rhs_pos)->DestroyThread();
- }
- }
+void ThreadList::NotifySelectedThreadChanged(lldb::tid_t tid) {
+ ThreadSP selected_thread_sp(FindThreadByID(tid));
+ if (selected_thread_sp->EventTypeHasListeners(
+ Thread::eBroadcastBitThreadSelected))
+ selected_thread_sp->BroadcastEvent(
+ Thread::eBroadcastBitThreadSelected,
+ new Thread::ThreadEventData(selected_thread_sp));
}
-void
-ThreadList::Flush ()
-{
+void ThreadList::Update(ThreadList &rhs) {
+ if (this != &rhs) {
+ // Lock both mutexes to make sure neither side changes anyone on us
+ // while the assignment occurs
std::lock_guard<std::recursive_mutex> guard(GetMutex());
- collection::iterator pos, end = m_threads.end();
- for (pos = m_threads.begin(); pos != end; ++pos)
- (*pos)->Flush ();
-}
-
-std::recursive_mutex &
-ThreadList::GetMutex()
-{
- return m_process->m_thread_mutex;
-}
-
-ThreadList::ExpressionExecutionThreadPusher::ExpressionExecutionThreadPusher (lldb::ThreadSP thread_sp) :
- m_thread_list(nullptr),
- m_tid(LLDB_INVALID_THREAD_ID)
-{
- if (thread_sp)
- {
- m_tid = thread_sp->GetID();
- m_thread_list = &thread_sp->GetProcess()->GetThreadList();
- m_thread_list->PushExpressionExecutionThread(m_tid);
+
+ m_process = rhs.m_process;
+ m_stop_id = rhs.m_stop_id;
+ m_threads.swap(rhs.m_threads);
+ m_selected_tid = rhs.m_selected_tid;
+
+ // Now we look for threads that we are done with and
+ // make sure to clear them up as much as possible so
+ // anyone with a shared pointer will still have a reference,
+ // but the thread won't be of much use. Using std::weak_ptr
+ // for all backward references (such as a thread to a process)
+ // will eventually solve this issue for us, but for now, we
+ // need to work around the issue
+ collection::iterator rhs_pos, rhs_end = rhs.m_threads.end();
+ for (rhs_pos = rhs.m_threads.begin(); rhs_pos != rhs_end; ++rhs_pos) {
+ const lldb::tid_t tid = (*rhs_pos)->GetID();
+ bool thread_is_alive = false;
+ const uint32_t num_threads = m_threads.size();
+ for (uint32_t idx = 0; idx < num_threads; ++idx) {
+ ThreadSP backing_thread = m_threads[idx]->GetBackingThread();
+ if (m_threads[idx]->GetID() == tid ||
+ (backing_thread && backing_thread->GetID() == tid)) {
+ thread_is_alive = true;
+ break;
+ }
+ }
+ if (!thread_is_alive)
+ (*rhs_pos)->DestroyThread();
}
+ }
}
+void ThreadList::Flush() {
+ std::lock_guard<std::recursive_mutex> guard(GetMutex());
+ collection::iterator pos, end = m_threads.end();
+ for (pos = m_threads.begin(); pos != end; ++pos)
+ (*pos)->Flush();
+}
+
+std::recursive_mutex &ThreadList::GetMutex() const {
+ return m_process->m_thread_mutex;
+}
+ThreadList::ExpressionExecutionThreadPusher::ExpressionExecutionThreadPusher(
+ lldb::ThreadSP thread_sp)
+ : m_thread_list(nullptr), m_tid(LLDB_INVALID_THREAD_ID) {
+ if (thread_sp) {
+ m_tid = thread_sp->GetID();
+ m_thread_list = &thread_sp->GetProcess()->GetThreadList();
+ m_thread_list->PushExpressionExecutionThread(m_tid);
+ }
+}
OpenPOWER on IntegriCloud