1 //===-- StreamCallback.cpp -------------------------------------*- C++ -*-===//
3 // The LLVM Compiler Infrastructure
5 // This file is distributed under the University of Illinois Open Source
6 // License. See LICENSE.TXT for details.
8 //===----------------------------------------------------------------------===//
12 #include "lldb/lldb-private.h"
13 #include "lldb/Core/Broadcaster.h"
14 #include "lldb/Core/Event.h"
15 #include "lldb/Core/StreamCallback.h"
16 #include "lldb/Host/Host.h"
19 using namespace lldb_private;
22 StreamCallback::StreamCallback (lldb::LogOutputCallback callback, void *baton) :
23 Stream (0, 4, eByteOrderBig),
24 m_callback (callback),
26 m_accumulated_data (),
31 StreamCallback::~StreamCallback ()
36 StreamCallback::FindStreamForThread(lldb::tid_t cur_tid)
38 Mutex::Locker locker(m_collection_mutex);
39 collection::iterator iter = m_accumulated_data.find (cur_tid);
40 if (iter == m_accumulated_data.end())
42 std::pair<collection::iterator, bool> ret;
43 ret = m_accumulated_data.insert(std::pair<lldb::tid_t,StreamString>(cur_tid, StreamString()));
46 return (*iter).second;
50 StreamCallback::Flush ()
52 lldb::tid_t cur_tid = Host::GetCurrentThreadID();
53 StreamString &out_stream = FindStreamForThread(cur_tid);
54 m_callback (out_stream.GetData(), m_baton);
59 StreamCallback::Write (const void *s, size_t length)
61 lldb::tid_t cur_tid = Host::GetCurrentThreadID();
62 FindStreamForThread(cur_tid).Write (s, length);