mirror of
https://github.com/Gericom/teak-llvm.git
synced 2025-06-21 04:25:45 -04:00
c7bece56fa
Major fixed to allow reading files that are over 4GB. The main problems were that the DataExtractor was using 32 bit offsets as a data cursor, and since we mmap all of our object files we could run into cases where if we had a very large core file that was over 4GB, we were running into the 4GB boundary. So I defined a new "lldb::offset_t" which should be used for all file offsets. After making this change, I enabled warnings for data loss and for enexpected implicit conversions temporarily and found a ton of things that I fixed. Any functions that take an index internally, should use "size_t" for any indexes and also should return "size_t" for any sizes of collections. llvm-svn: 173463
53 lines
1.4 KiB
C++
53 lines
1.4 KiB
C++
//===-- 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 <stdio.h>
|
|
|
|
#include "lldb/lldb-private.h"
|
|
#include "lldb/Core/Broadcaster.h"
|
|
#include "lldb/Core/Event.h"
|
|
#include "lldb/Core/StreamAsynchronousIO.h"
|
|
|
|
using namespace lldb;
|
|
using namespace lldb_private;
|
|
|
|
|
|
StreamAsynchronousIO::StreamAsynchronousIO (Broadcaster &broadcaster, uint32_t broadcast_event_type) :
|
|
Stream (0, 4, eByteOrderBig),
|
|
m_broadcaster (broadcaster),
|
|
m_broadcast_event_type (broadcast_event_type),
|
|
m_accumulated_data ()
|
|
{
|
|
}
|
|
|
|
StreamAsynchronousIO::~StreamAsynchronousIO ()
|
|
{
|
|
}
|
|
|
|
void
|
|
StreamAsynchronousIO::Flush ()
|
|
{
|
|
if (m_accumulated_data.GetSize() > 0)
|
|
{
|
|
std::auto_ptr<EventDataBytes> data_bytes_ap (new EventDataBytes);
|
|
// Let's swap the bytes to avoid LARGE string copies.
|
|
data_bytes_ap->SwapBytes (m_accumulated_data.GetString());
|
|
EventSP new_event_sp (new Event (m_broadcast_event_type, data_bytes_ap.release()));
|
|
m_broadcaster.BroadcastEvent (new_event_sp);
|
|
m_accumulated_data.Clear();
|
|
}
|
|
}
|
|
|
|
size_t
|
|
StreamAsynchronousIO::Write (const void *s, size_t length)
|
|
{
|
|
m_accumulated_data.Write (s, length);
|
|
return length;
|
|
}
|