1 //===-- SBCommunication.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 //===----------------------------------------------------------------------===//
10 #include "lldb/API/SBCommunication.h"
11 #include "lldb/API/SBBroadcaster.h"
12 #include "lldb/Core/Communication.h"
13 #include "lldb/Core/ConnectionFileDescriptor.h"
14 #include "lldb/Core/Log.h"
17 using namespace lldb_private;
21 SBCommunication::SBCommunication() :
23 m_opaque_owned (false)
27 SBCommunication::SBCommunication(const char * broadcaster_name) :
28 m_opaque (new Communication (broadcaster_name)),
31 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
34 log->Printf ("SBCommunication::SBCommunication (broadcaster_name=\"%s\") => "
35 "SBCommunication(%p)", broadcaster_name, m_opaque);
38 SBCommunication::~SBCommunication()
40 if (m_opaque && m_opaque_owned)
43 m_opaque_owned = false;
47 SBCommunication::IsValid () const
49 return m_opaque != NULL;
53 SBCommunication::GetCloseOnEOF ()
56 return m_opaque->GetCloseOnEOF ();
61 SBCommunication::SetCloseOnEOF (bool b)
64 m_opaque->SetCloseOnEOF (b);
68 SBCommunication::Connect (const char *url)
72 if (!m_opaque->HasConnection ())
73 m_opaque->SetConnection (new ConnectionFileDescriptor());
74 return m_opaque->Connect (url, NULL);
76 return eConnectionStatusNoConnection;
80 SBCommunication::AdoptFileDesriptor (int fd, bool owns_fd)
82 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
84 ConnectionStatus status = eConnectionStatusNoConnection;
87 if (m_opaque->HasConnection ())
89 if (m_opaque->IsConnected())
90 m_opaque->Disconnect();
92 m_opaque->SetConnection (new ConnectionFileDescriptor (fd, owns_fd));
93 if (m_opaque->IsConnected())
94 status = eConnectionStatusSuccess;
96 status = eConnectionStatusLostConnection;
100 log->Printf ("SBCommunication(%p)::AdoptFileDescriptor (fd=%d, ownd_fd=%i) => %s",
101 m_opaque, fd, owns_fd, Communication::ConnectionStatusAsCString (status));
108 SBCommunication::Disconnect ()
110 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
112 ConnectionStatus status= eConnectionStatusNoConnection;
114 status = m_opaque->Disconnect ();
117 log->Printf ("SBCommunication(%p)::Disconnect () => %s", m_opaque,
118 Communication::ConnectionStatusAsCString (status));
124 SBCommunication::IsConnected () const
126 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
129 result = m_opaque->IsConnected ();
132 log->Printf ("SBCommunication(%p)::IsConnected () => %i", m_opaque, result);
138 SBCommunication::Read (void *dst, size_t dst_len, uint32_t timeout_usec, ConnectionStatus &status)
140 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
142 log->Printf ("SBCommunication(%p)::Read (dst=%p, dst_len=%" PRIu64 ", timeout_usec=%u, &status)...",
147 size_t bytes_read = 0;
149 bytes_read = m_opaque->Read (dst, dst_len, timeout_usec, status, NULL);
151 status = eConnectionStatusNoConnection;
154 log->Printf ("SBCommunication(%p)::Read (dst=%p, dst_len=%" PRIu64 ", timeout_usec=%u, &status=%s) => %" PRIu64,
159 Communication::ConnectionStatusAsCString (status),
160 (uint64_t)bytes_read);
166 SBCommunication::Write (const void *src, size_t src_len, ConnectionStatus &status)
168 size_t bytes_written = 0;
170 bytes_written = m_opaque->Write (src, src_len, status, NULL);
172 status = eConnectionStatusNoConnection;
174 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
176 log->Printf ("SBCommunication(%p)::Write (src=%p, src_len=%" PRIu64 ", &status=%s) => %" PRIu64,
177 m_opaque, src, (uint64_t)src_len, Communication::ConnectionStatusAsCString (status), (uint64_t)bytes_written);
183 SBCommunication::ReadThreadStart ()
185 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
187 bool success = false;
189 success = m_opaque->StartReadThread ();
192 log->Printf ("SBCommunication(%p)::ReadThreadStart () => %i", m_opaque, success);
199 SBCommunication::ReadThreadStop ()
201 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
203 log->Printf ("SBCommunication(%p)::ReadThreadStop ()...", m_opaque);
205 bool success = false;
207 success = m_opaque->StopReadThread ();
210 log->Printf ("SBCommunication(%p)::ReadThreadStop () => %i", m_opaque, success);
216 SBCommunication::ReadThreadIsRunning ()
220 result = m_opaque->ReadThreadIsRunning ();
221 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
223 log->Printf ("SBCommunication(%p)::ReadThreadIsRunning () => %i", m_opaque, result);
228 SBCommunication::SetReadThreadBytesReceivedCallback
230 ReadThreadBytesReceived callback,
234 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
239 m_opaque->SetReadThreadBytesReceivedCallback (callback, callback_baton);
244 log->Printf ("SBCommunication(%p)::SetReadThreadBytesReceivedCallback (callback=%p, baton=%p) => %i",
245 m_opaque, callback, callback_baton, result);
251 SBCommunication::GetBroadcaster ()
253 SBBroadcaster broadcaster (m_opaque, false);
255 Log *log(lldb_private::GetLogIfAllCategoriesSet (LIBLLDB_LOG_API));
258 log->Printf ("SBCommunication(%p)::GetBroadcaster () => SBBroadcaster (%p)",
259 m_opaque, broadcaster.get());
265 SBCommunication::GetBroadcasterClass ()
267 return Communication::GetStaticBroadcasterClass().AsCString();
272 //SBCommunication::CreateIfNeeded ()
274 // if (m_opaque == NULL)
276 // static uint32_t g_broadcaster_num;
277 // char broadcaster_name[256];
278 // ::snprintf (name, broadcaster_name, "%p SBCommunication", this);
279 // m_opaque = new Communication (broadcaster_name);
280 // m_opaque_owned = true;
282 // assert (m_opaque);