Replace direct uses of the Debugger's output stream with
uses of the asynchronous stream.
git-svn-id: https://llvm.org/svn/llvm-project/llvdb/trunk@133076 91177308-0d34-0410-b5e6-96231b3b80d8
diff --git a/source/Commands/CommandObjectCommands.cpp b/source/Commands/CommandObjectCommands.cpp
index a8c1631..e8d4377 100644
--- a/source/Commands/CommandObjectCommands.cpp
+++ b/source/Commands/CommandObjectCommands.cpp
@@ -929,7 +929,11 @@
switch (notification)
{
case eInputReaderActivate:
- reader.GetDebugger().GetOutputStream().Printf("%s\n", "Enter regular expressions in the form 's/<regex>/<subst>/' and terminate with an empty line:");
+ {
+ StreamSP out_stream = reader.GetDebugger().GetAsyncOutputStream ();
+ out_stream->Printf("%s\n", "Enter regular expressions in the form 's/<regex>/<subst>/' and terminate with an empty line:");
+ out_stream->Flush();
+ }
break;
case eInputReaderReactivate:
break;
@@ -951,7 +955,9 @@
Error error (add_regex_cmd->AppendRegexSubstitution (bytes_strref));
if (error.Fail())
{
- reader.GetDebugger().GetOutputStream().Printf("error: %s\n", error.AsCString());
+ StreamSP out_stream = reader.GetDebugger().GetAsyncOutputStream();
+ out_stream->Printf("error: %s\n", error.AsCString());
+ out_stream->Flush();
add_regex_cmd->InputReaderDidCancel ();
reader.SetIsDone (true);
}
@@ -959,9 +965,13 @@
break;
case eInputReaderInterrupt:
- reader.SetIsDone (true);
- reader.GetDebugger().GetOutputStream().PutCString("Regular expression command creations was cancelled.\n");
- add_regex_cmd->InputReaderDidCancel ();
+ {
+ reader.SetIsDone (true);
+ StreamSP out_stream = reader.GetDebugger().GetAsyncOutputStream();
+ out_stream->PutCString("Regular expression command creations was cancelled.\n");
+ out_stream->Flush();
+ add_regex_cmd->InputReaderDidCancel ();
+ }
break;
case eInputReaderEndOfFile:
diff --git a/source/Commands/CommandObjectExpression.cpp b/source/Commands/CommandObjectExpression.cpp
index e43e9bf..9f2e79e 100644
--- a/source/Commands/CommandObjectExpression.cpp
+++ b/source/Commands/CommandObjectExpression.cpp
@@ -195,11 +195,13 @@
switch (notification)
{
case eInputReaderActivate:
- reader.GetDebugger().GetOutputStream().Printf("%s\n", "Enter expressions, then terminate with an empty line to evaluate:");
+ {
+ StreamSP out_stream = reader.GetDebugger().GetAsyncOutputStream();
+ out_stream->Printf("%s\n", "Enter expressions, then terminate with an empty line to evaluate:");
+ out_stream->Flush();
+ }
// Fall through
case eInputReaderReactivate:
- //if (out_fh)
- // reader.GetDebugger().GetOutputStream().Printf ("%3u: ", cmd_object_expr->m_expr_line_count);
break;
case eInputReaderDeactivate:
@@ -217,14 +219,16 @@
if (bytes_len == 0)
reader.SetIsDone(true);
- //else if (out_fh && !reader->IsDone())
- // ::fprintf (out_fh, "%3u: ", cmd_object_expr->m_expr_line_count);
break;
case eInputReaderInterrupt:
cmd_object_expr->m_expr_lines.clear();
reader.SetIsDone (true);
- reader.GetDebugger().GetOutputStream().Printf("%s\n", "Expression evaluation cancelled.");
+ {
+ StreamSP out_stream = reader.GetDebugger().GetAsyncOutputStream();
+ out_stream->Printf("%s\n", "Expression evaluation cancelled.");
+ out_stream->Flush();
+ }
break;
case eInputReaderEndOfFile:
diff --git a/source/Target/ThreadPlanTracer.cpp b/source/Target/ThreadPlanTracer.cpp
index a7003dd..5a5c8b2 100644
--- a/source/Target/ThreadPlanTracer.cpp
+++ b/source/Target/ThreadPlanTracer.cpp
@@ -55,7 +55,7 @@
if (m_stream_sp.get())
return m_stream_sp.get();
else
- return &(m_thread.GetProcess().GetTarget().GetDebugger().GetOutputStream());
+ return m_thread.GetProcess().GetTarget().GetDebugger().GetAsyncOutputStream().get();
}
void
@@ -65,8 +65,11 @@
bool show_frame_index = false;
bool show_fullpaths = false;
- m_thread.GetStackFrameAtIndex(0)->Dump (GetLogStream(), show_frame_index, show_fullpaths);
- GetLogStream()->Printf("\n");
+ Stream *stream = GetLogStream();
+ m_thread.GetStackFrameAtIndex(0)->Dump (stream, show_frame_index, show_fullpaths);
+ stream->Printf("\n");
+ stream->Flush();
+
}
bool
@@ -259,4 +262,5 @@
}
}
stream->EOL();
+ stream->Flush();
}