1*696bd635SAlexander Shaposhnikov //===-- StreamAsynchronousIO.cpp --------------------------------*- C++ -*-===//
2969ed3d1SCaroline Tice //
3969ed3d1SCaroline Tice //                     The LLVM Compiler Infrastructure
4969ed3d1SCaroline Tice //
5969ed3d1SCaroline Tice // This file is distributed under the University of Illinois Open Source
6969ed3d1SCaroline Tice // License. See LICENSE.TXT for details.
7969ed3d1SCaroline Tice //
8969ed3d1SCaroline Tice //===----------------------------------------------------------------------===//
9969ed3d1SCaroline Tice 
104446487dSPavel Labath #include "lldb/Core/StreamAsynchronousIO.h"
11969ed3d1SCaroline Tice 
124446487dSPavel Labath #include "lldb/Core/Debugger.h"
13b9c1b51eSKate Stone #include "lldb/lldb-private.h"
14969ed3d1SCaroline Tice 
15969ed3d1SCaroline Tice using namespace lldb;
16969ed3d1SCaroline Tice using namespace lldb_private;
17969ed3d1SCaroline Tice 
18b9c1b51eSKate Stone StreamAsynchronousIO::StreamAsynchronousIO(Debugger &debugger, bool for_stdout)
19b9c1b51eSKate Stone     : Stream(0, 4, eByteOrderBig), m_debugger(debugger), m_data(),
20b9c1b51eSKate Stone       m_for_stdout(for_stdout) {}
21969ed3d1SCaroline Tice 
22b9c1b51eSKate Stone StreamAsynchronousIO::~StreamAsynchronousIO() {
2344d93782SGreg Clayton   // Flush when we destroy to make sure we display the data
2444d93782SGreg Clayton   Flush();
25969ed3d1SCaroline Tice }
26969ed3d1SCaroline Tice 
27b9c1b51eSKate Stone void StreamAsynchronousIO::Flush() {
28b9c1b51eSKate Stone   if (!m_data.empty()) {
294446487dSPavel Labath     m_debugger.PrintAsync(m_data.data(), m_data.size(), m_for_stdout);
303a29f8b9SPavel Labath     m_data = std::string();
31969ed3d1SCaroline Tice   }
32969ed3d1SCaroline Tice }
33969ed3d1SCaroline Tice 
34b9c1b51eSKate Stone size_t StreamAsynchronousIO::Write(const void *s, size_t length) {
354446487dSPavel Labath   m_data.append((const char *)s, length);
36969ed3d1SCaroline Tice   return length;
37969ed3d1SCaroline Tice }
38