[lldb] Synchronize access to m_statusline in the Debugger (#134759)
Eliminate the potential for a race between the main thread, the default
event handler thread and the signal handling thread, when accessing the
m_statusline member.
diff --git a/lldb/include/lldb/Core/Debugger.h b/lldb/include/lldb/Core/Debugger.h
index 448e8d6..f36202e 100644
--- a/lldb/include/lldb/Core/Debugger.h
+++ b/lldb/include/lldb/Core/Debugger.h
@@ -752,6 +752,8 @@
IOHandlerStack m_io_handler_stack;
std::recursive_mutex m_io_handler_synchronous_mutex;
+ /// Mutex protecting the m_statusline member.
+ std::mutex m_statusline_mutex;
std::optional<Statusline> m_statusline;
llvm::StringMap<std::weak_ptr<LogHandler>> m_stream_handlers;
diff --git a/lldb/source/Core/Debugger.cpp b/lldb/source/Core/Debugger.cpp
index e65d71d..ce6fb6e 100644
--- a/lldb/source/Core/Debugger.cpp
+++ b/lldb/source/Core/Debugger.cpp
@@ -251,6 +251,7 @@
g_debugger_properties[ePropertyShowStatusline].name) {
// Statusline setting changed. If we have a statusline instance, update it
// now. Otherwise it will get created in the default event handler.
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
if (StatuslineSupported())
m_statusline.emplace(*this);
else
@@ -391,8 +392,12 @@
if (auto handler_sp = m_io_handler_stack.Top())
handler_sp->TerminalSizeChanged();
- if (m_statusline)
- m_statusline->TerminalSizeChanged();
+
+ {
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
+ if (m_statusline)
+ m_statusline->TerminalSizeChanged();
+ }
return success;
}
@@ -409,8 +414,12 @@
if (auto handler_sp = m_io_handler_stack.Top())
handler_sp->TerminalSizeChanged();
- if (m_statusline)
- m_statusline->TerminalSizeChanged();
+
+ {
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
+ if (m_statusline)
+ m_statusline->TerminalSizeChanged();
+ }
return success;
}
@@ -1148,8 +1157,11 @@
}
void Debugger::SaveInputTerminalState() {
- if (m_statusline)
- m_statusline->Disable();
+ {
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
+ if (m_statusline)
+ m_statusline->Disable();
+ }
int fd = GetInputFile().GetDescriptor();
if (fd != File::kInvalidDescriptor)
m_terminal_state.Save(fd, true);
@@ -1157,11 +1169,15 @@
void Debugger::RestoreInputTerminalState() {
m_terminal_state.Restore();
- if (m_statusline)
- m_statusline->Enable();
+ {
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
+ if (m_statusline)
+ m_statusline->Enable();
+ }
}
void Debugger::RedrawStatusline(bool update) {
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
if (m_statusline)
m_statusline->Redraw(update);
}
@@ -2039,8 +2055,11 @@
// are now listening to all required events so no events get missed
m_sync_broadcaster.BroadcastEvent(eBroadcastBitEventThreadIsListening);
- if (!m_statusline && StatuslineSupported())
- m_statusline.emplace(*this);
+ if (StatuslineSupported()) {
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
+ if (!m_statusline)
+ m_statusline.emplace(*this);
+ }
bool done = false;
while (!done) {
@@ -2101,8 +2120,11 @@
}
}
- if (m_statusline)
- m_statusline.reset();
+ {
+ std::lock_guard<std::mutex> guard(m_statusline_mutex);
+ if (m_statusline)
+ m_statusline.reset();
+ }
return {};
}