1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
//===-- 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, 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;
}
|
