73bf5dbd16
darwin (not sure about other platforms). Modified the communication and connection classes to not require the BytesAvailable function. Now the "Read(...)" function has a timeout in microseconds. Fixed a lot of assertions that were firing off in certain cases and replaced them with error output and code that can deal with the assertion case. llvm-svn: 133224
132 lines
3.0 KiB
C++
132 lines
3.0 KiB
C++
//===-- ConnectionSharedMemory.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/ConnectionSharedMemory.h"
|
|
|
|
// C Includes
|
|
#include <errno.h>
|
|
#include <pthread.h>
|
|
#include <stdlib.h>
|
|
#include <sys/file.h>
|
|
#include <sys/mman.h>
|
|
#include <sys/stat.h>
|
|
#include <sys/types.h>
|
|
|
|
// C++ Includes
|
|
// Other libraries and framework includes
|
|
// Project includes
|
|
#include "lldb/lldb-private-log.h"
|
|
#include "lldb/Core/Communication.h"
|
|
#include "lldb/Core/Log.h"
|
|
|
|
using namespace lldb;
|
|
using namespace lldb_private;
|
|
|
|
ConnectionSharedMemory::ConnectionSharedMemory () :
|
|
Connection(),
|
|
m_name(),
|
|
m_fd (-1),
|
|
m_mmap()
|
|
{
|
|
}
|
|
|
|
ConnectionSharedMemory::~ConnectionSharedMemory ()
|
|
{
|
|
Disconnect (NULL);
|
|
}
|
|
|
|
bool
|
|
ConnectionSharedMemory::IsConnected () const
|
|
{
|
|
return m_fd >= 0;
|
|
}
|
|
|
|
ConnectionStatus
|
|
ConnectionSharedMemory::Connect (const char *s, Error *error_ptr)
|
|
{
|
|
// if (s && s[0])
|
|
// {
|
|
// if (strstr(s, "shm-create://"))
|
|
// {
|
|
// }
|
|
// else if (strstr(s, "shm-connect://"))
|
|
// {
|
|
// }
|
|
// if (error_ptr)
|
|
// error_ptr->SetErrorStringWithFormat ("unsupported connection URL: '%s'", s);
|
|
// return eConnectionStatusError;
|
|
// }
|
|
if (error_ptr)
|
|
error_ptr->SetErrorString("invalid connect arguments");
|
|
return eConnectionStatusError;
|
|
}
|
|
|
|
ConnectionStatus
|
|
ConnectionSharedMemory::Disconnect (Error *error_ptr)
|
|
{
|
|
m_mmap.Clear();
|
|
if (!m_name.empty())
|
|
{
|
|
shm_unlink (m_name.c_str());
|
|
m_name.clear();
|
|
}
|
|
return eConnectionStatusSuccess;
|
|
}
|
|
|
|
size_t
|
|
ConnectionSharedMemory::Read (void *dst,
|
|
size_t dst_len,
|
|
uint32_t timeout_usec,
|
|
ConnectionStatus &status,
|
|
Error *error_ptr)
|
|
{
|
|
status = eConnectionStatusSuccess;
|
|
return 0;
|
|
}
|
|
|
|
size_t
|
|
ConnectionSharedMemory::Write (const void *src, size_t src_len, ConnectionStatus &status, Error *error_ptr)
|
|
{
|
|
status = eConnectionStatusSuccess;
|
|
return 0;
|
|
}
|
|
|
|
ConnectionStatus
|
|
ConnectionSharedMemory::BytesAvailable (uint32_t timeout_usec, Error *error_ptr)
|
|
{
|
|
return eConnectionStatusLostConnection;
|
|
}
|
|
|
|
ConnectionStatus
|
|
ConnectionSharedMemory::Open (bool create, const char *name, size_t size, Error *error_ptr)
|
|
{
|
|
if (m_fd != -1)
|
|
{
|
|
if (error_ptr)
|
|
error_ptr->SetErrorString("already open");
|
|
return eConnectionStatusError;
|
|
}
|
|
|
|
m_name.assign (name);
|
|
int oflag = O_RDWR;
|
|
if (create)
|
|
oflag |= O_CREAT;
|
|
m_fd = ::shm_open (m_name.c_str(), oflag, S_IRUSR|S_IWUSR);
|
|
|
|
if (create)
|
|
::ftruncate (m_fd, size);
|
|
|
|
if (m_mmap.MemoryMapFromFileDescriptor(m_fd, 0, size, true, false) == size)
|
|
return eConnectionStatusSuccess;
|
|
|
|
Disconnect(NULL);
|
|
return eConnectionStatusError;
|
|
}
|
|
|