| //===-- StreamBroadcast.cpp -------------------------------------*- C++ -*-===// |
| // |
| // The LLVM Compiler Infrastructure |
| // |
| // This file is distributed under the University of Illinois Open Source |
| // License. See LICENSE.TXT for details. |
| // |
| //===----------------------------------------------------------------------===// |
| |
| #include "lldb/Core/StreamAsynchronousIO.h" |
| |
| #include "lldb/lldb-private.h" |
| #include "lldb/Core/Debugger.h" |
| |
| using namespace lldb; |
| using namespace lldb_private; |
| |
| |
| StreamAsynchronousIO::StreamAsynchronousIO (Debugger &debugger, bool for_stdout) : |
| Stream (0, 4, eByteOrderBig), |
| m_debugger (debugger), |
| m_data (), |
| m_for_stdout (for_stdout) |
| { |
| } |
| |
| StreamAsynchronousIO::~StreamAsynchronousIO () |
| { |
| // Flush when we destroy to make sure we display the data |
| Flush(); |
| } |
| |
| void |
| StreamAsynchronousIO::Flush () |
| { |
| if (!m_data.empty()) |
| { |
| m_debugger.PrintAsync (m_data.data(), m_data.size(), m_for_stdout); |
| m_data = std::string(); |
| } |
| } |
| |
| size_t |
| StreamAsynchronousIO::Write (const void *s, size_t length) |
| { |
| m_data.append ((const char *)s, length); |
| return length; |
| } |