1 files changed, 131 insertions, 0 deletions
diff --git a/source/Core/ConnectionSharedMemory.cpp b/source/Core/ConnectionSharedMemory.cpp
new file mode 100644
index 0000000..625f17a
--- /dev/null
+++ b/source/Core/ConnectionSharedMemory.cpp
@@ -0,0 +1,131 @@
+//===-- 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;
+}
+