1//===-- StreamBroadcast.cpp -------------------------------------*- C++ -*-===// 2// 3// The LLVM Compiler Infrastructure 4// 5// This file is distributed under the University of Illinois Open Source 6// License. See LICENSE.TXT for details. 7// 8//===----------------------------------------------------------------------===// 9 10#include <stdio.h> 11 12#include "lldb/lldb-private.h" 13#include "lldb/Core/Broadcaster.h" 14#include "lldb/Core/Event.h" 15#include "lldb/Core/StreamAsynchronousIO.h" 16 17using namespace lldb; 18using namespace lldb_private; 19 20 21StreamAsynchronousIO::StreamAsynchronousIO (Broadcaster &broadcaster, uint32_t broadcast_event_type) : 22 Stream (0, 4, eByteOrderBig), 23 m_broadcaster (broadcaster), 24 m_broadcast_event_type (broadcast_event_type), 25 m_accumulated_data () 26{ 27} 28 29StreamAsynchronousIO::~StreamAsynchronousIO () 30{ 31} 32 33void 34StreamAsynchronousIO::Flush () 35{ 36 if (m_accumulated_data.GetSize() > 0) 37 { 38 std::unique_ptr<EventDataBytes> data_bytes_ap (new EventDataBytes); 39 // Let's swap the bytes to avoid LARGE string copies. 40 data_bytes_ap->SwapBytes (m_accumulated_data.GetString()); 41 EventSP new_event_sp (new Event (m_broadcast_event_type, data_bytes_ap.release())); 42 m_broadcaster.BroadcastEvent (new_event_sp); 43 m_accumulated_data.Clear(); 44 } 45} 46 47size_t 48StreamAsynchronousIO::Write (const void *s, size_t length) 49{ 50 m_accumulated_data.Write (s, length); 51 return length; 52} 53