#include <GDBRemoteClientBase.h>

Inheritance diagram for lldb_private::process_gdb_remote::GDBRemoteClientBase:

[legend]

Collaboration diagram for lldb_private::process_gdb_remote::GDBRemoteClientBase:

[legend]

Classes
struct	ContinueDelegate

class	ContinueLock

class	Lock

Public Member Functions
	GDBRemoteClientBase (const char comm_name, const char listener_name)

bool	SendAsyncSignal (int signo, std::chrono::seconds interrupt_timeout)

bool	Interrupt (std::chrono::seconds interrupt_timeout)

lldb::StateType	SendContinuePacketAndWaitForResponse (ContinueDelegate &delegate, const UnixSignals &signals, llvm::StringRef payload, std::chrono::seconds interrupt_timeout, StringExtractorGDBRemote &response)

PacketResult	SendPacketAndWaitForResponse (llvm::StringRef payload, StringExtractorGDBRemote &response, std::chrono::seconds interrupt_timeout=std::chrono::seconds(0))

PacketResult	SendPacketAndReceiveResponseWithOutputSupport (llvm::StringRef payload, StringExtractorGDBRemote &response, std::chrono::seconds interrupt_timeout, llvm::function_ref< void(llvm::StringRef)> output_callback)

Public Member Functions inherited from lldb_private::process_gdb_remote::GDBRemoteCommunication
	GDBRemoteCommunication (const char comm_name, const char listener_name)

	~GDBRemoteCommunication () override

PacketResult	GetAck ()

size_t	SendAck ()

size_t	SendNack ()

char	CalculcateChecksum (llvm::StringRef payload)

PacketType	CheckForPacket (const uint8_t *src, size_t src_len, StringExtractorGDBRemote &packet)

bool	GetSendAcks ()

std::chrono::seconds	SetPacketTimeout (std::chrono::seconds packet_timeout)

std::chrono::seconds	GetPacketTimeout () const

Status	StartDebugserverProcess (const char url, Platform platform, ProcessLaunchInfo &launch_info, uint16_t port, const Args inferior_args, int pass_comm_fd)

void	DumpHistory (Stream &strm)

void	SetPacketRecorder (repro::PacketRecorder *recorder)

Public Member Functions inherited from lldb_private::Communication
	FLAGS_ANONYMOUS_ENUM ()

	Communication (const char *broadcaster_name)
	Construct the Communication object with the specified name for the Broadcaster that this object inherits from. More...

	~Communication () override
	Destructor. More...

void	Clear ()

lldb::ConnectionStatus	Connect (const char url, Status error_ptr)
	Connect using the current connection by passing url to its connect function. More...

lldb::ConnectionStatus	Disconnect (Status *error_ptr=nullptr)
	Disconnect the communications connection if one is currently connected. More...

bool	IsConnected () const
	Check if the connection is valid. More...

bool	HasConnection () const

lldb_private::Connection *	GetConnection ()

size_t	Read (void dst, size_t dst_len, const Timeout< std::micro > &timeout, lldb::ConnectionStatus &status, Status error_ptr)
	Read bytes from the current connection. More...

size_t	Write (const void src, size_t src_len, lldb::ConnectionStatus &status, Status error_ptr)
	The actual write function that attempts to write to the communications protocol. More...

size_t	WriteAll (const void src, size_t src_len, lldb::ConnectionStatus &status, Status error_ptr)
	Repeatedly attempt writing until either src_len bytes are written or a permanent failure occurs. More...

void	SetConnection (std::unique_ptr< Connection > connection)
	Sets the connection that it to be used by this class. More...

virtual bool	StartReadThread (Status *error_ptr=nullptr)
	Starts a read thread whose sole purpose it to read bytes from the current connection. More...

virtual bool	StopReadThread (Status *error_ptr=nullptr)
	Stops the read thread by cancelling it. More...

virtual bool	JoinReadThread (Status *error_ptr=nullptr)

bool	ReadThreadIsRunning ()
	Checks if there is a currently running read thread. More...

lldb::thread_result_t	ReadThread ()
	The read thread function. More...

void	SetReadThreadBytesReceivedCallback (ReadThreadBytesReceived callback, void *callback_baton)

void	SynchronizeWithReadThread ()
	Wait for the read thread to process all outstanding data. More...

bool	GetCloseOnEOF () const

void	SetCloseOnEOF (bool b)

ConstString &	GetBroadcasterClass () const override
	This needs to be filled in if you are going to register the broadcaster with the broadcaster manager and do broadcaster class matching. More...

Public Member Functions inherited from lldb_private::Broadcaster
	Broadcaster (lldb::BroadcasterManagerSP manager_sp, const char *name)
	Construct with a broadcaster with a name. More...

virtual	~Broadcaster ()
	Destructor. More...

void	CheckInWithManager ()

void	BroadcastEvent (lldb::EventSP &event_sp)
	Broadcast an event which has no associated data. More...

void	BroadcastEventIfUnique (lldb::EventSP &event_sp)

void	BroadcastEvent (uint32_t event_type, const lldb::EventDataSP &event_data_sp)

void	BroadcastEvent (uint32_t event_type, EventData *event_data=nullptr)

void	BroadcastEventIfUnique (uint32_t event_type, EventData *event_data=nullptr)

void	Clear ()

virtual void	AddInitialEventsToListener (const lldb::ListenerSP &listener_sp, uint32_t requested_events)

uint32_t	AddListener (const lldb::ListenerSP &listener_sp, uint32_t event_mask)
	Listen for any events specified by event_mask. More...

ConstString	GetBroadcasterName ()
	Get the NULL terminated C string name of this Broadcaster object. More...

bool	GetEventNames (Stream &s, const uint32_t event_mask, bool prefix_with_broadcaster_name) const
	Get the event name(s) for one or more event bits. More...

void	SetEventName (uint32_t event_mask, const char *name)
	Set the name for an event bit. More...

const char *	GetEventName (uint32_t event_mask) const

bool	EventTypeHasListeners (uint32_t event_type)

bool	RemoveListener (const lldb::ListenerSP &listener_sp, uint32_t event_mask=UINT32_MAX)
	Removes a Listener from this broadcasters list and frees the event bits specified by event_mask that were previously acquired by listener (assuming listener was listening to this object) for other listener objects to use. More...

bool	HijackBroadcaster (const lldb::ListenerSP &listener_sp, uint32_t event_mask=UINT32_MAX)
	Provides a simple mechanism to temporarily redirect events from broadcaster. More...

bool	IsHijackedForEvent (uint32_t event_mask)

void	RestoreBroadcaster ()
	Restore the state of the Broadcaster from a previous hijack attempt. More...

lldb::BroadcasterManagerSP	GetManager ()

Protected Member Functions
PacketResult	SendPacketAndWaitForResponseNoLock (llvm::StringRef payload, StringExtractorGDBRemote &response)

virtual void	OnRunPacketSent (bool first)

Protected Member Functions inherited from lldb_private::process_gdb_remote::GDBRemoteCommunication
PacketResult	SendPacketNoLock (llvm::StringRef payload)

PacketResult	SendNotificationPacketNoLock (llvm::StringRef notify_type, std::deque< std::string > &queue, llvm::StringRef payload)

PacketResult	SendRawPacketNoLock (llvm::StringRef payload, bool skip_ack=false)

PacketResult	ReadPacket (StringExtractorGDBRemote &response, Timeout< std::micro > timeout, bool sync_on_timeout)

PacketResult	ReadPacketWithOutputSupport (StringExtractorGDBRemote &response, Timeout< std::micro > timeout, bool sync_on_timeout, llvm::function_ref< void(llvm::StringRef)> output_callback)

PacketResult	WaitForPacketNoLock (StringExtractorGDBRemote &response, Timeout< std::micro > timeout, bool sync_on_timeout)

bool	CompressionIsEnabled ()

bool	DecompressPacket ()

Status	StartListenThread (const char *hostname="127.0.0.1", uint16_t port=0)

bool	JoinListenThread ()

lldb::thread_result_t	ListenThread ()

Protected Member Functions inherited from lldb_private::Communication
size_t	ReadFromConnection (void dst, size_t dst_len, const Timeout< std::micro > &timeout, lldb::ConnectionStatus &status, Status error_ptr)

virtual void	AppendBytesToCache (const uint8_t *src, size_t src_len, bool broadcast, lldb::ConnectionStatus status)
	Append new bytes that get read from the read thread into the internal object byte cache. More...

size_t	GetCachedBytes (void *dst, size_t dst_len)
	Get any available bytes from our data cache. More...

Protected Member Functions inherited from lldb_private::Broadcaster
BroadcasterImplSP	GetBroadcasterImpl ()

const char *	GetHijackingListenerName ()

Private Member Functions
bool	ShouldStop (const UnixSignals &signals, StringExtractorGDBRemote &response)

Private Attributes
std::recursive_mutex	m_async_mutex
	This handles the synchronization between individual async threads. More...


std::mutex	m_mutex
	Variables handling synchronization between the Continue thread and any other threads wishing to send packets over the connection. More...

std::condition_variable	m_cv

std::string	m_continue_packet
	Packet with which to resume after an async interrupt. More...

std::chrono::time_point< std::chrono::steady_clock >	m_interrupt_endpoint
	When was the interrupt packet sent. More...

uint32_t	m_async_count
	Number of threads interested in sending. More...

bool	m_is_running
	Whether the continue thread has control. More...

bool	m_should_stop
	Whether we should resume after a stop. More...

Additional Inherited Members
Public Types inherited from lldb_private::process_gdb_remote::GDBRemoteCommunication
enum	{ eBroadcastBitRunPacketSent = kLoUserBroadcastBit }

enum	PacketType { PacketType::Invalid = 0, PacketType::Standard, PacketType::Notify }

enum	PacketResult { PacketResult::Success = 0, PacketResult::ErrorSendFailed, PacketResult::ErrorSendAck, PacketResult::ErrorReplyFailed, PacketResult::ErrorReplyTimeout, PacketResult::ErrorReplyInvalid, PacketResult::ErrorReplyAck, PacketResult::ErrorDisconnected, PacketResult::ErrorNoSequenceLock }

Public Types inherited from lldb_private::Communication
typedef void(*	ReadThreadBytesReceived) (void baton, const void src, size_t src_len)

Static Public Member Functions inherited from lldb_private::process_gdb_remote::GDBRemoteCommunication
static llvm::Error	ConnectLocally (GDBRemoteCommunication &client, GDBRemoteCommunication &server)

static std::string	ExpandRLE (std::string)
	Expand GDB run-length encoding. More...

Static Public Member Functions inherited from lldb_private::Communication
static std::string	ConnectionStatusAsString (lldb::ConnectionStatus status)

static ConstString &	GetStaticBroadcasterClass ()

Protected Types inherited from lldb_private::Broadcaster
typedef std::shared_ptr< BroadcasterImpl >	BroadcasterImplSP

typedef std::weak_ptr< BroadcasterImpl >	BroadcasterImplWP

Protected Attributes inherited from lldb_private::process_gdb_remote::GDBRemoteCommunication
std::chrono::seconds	m_packet_timeout

uint32_t	m_echo_number

LazyBool	m_supports_qEcho

GDBRemoteCommunicationHistory	m_history

bool	m_send_acks

bool	m_is_platform

CompressionType	m_compression_type

Protected Attributes inherited from lldb_private::Communication
lldb::ConnectionSP	m_connection_sp
	The connection that is current in use by this communications class. More...

HostThread	m_read_thread
	The read thread handle in case we need to cancel the thread. More...

std::atomic< bool >	m_read_thread_enabled

std::atomic< bool >	m_read_thread_did_exit

std::string	m_bytes
	A buffer to cache bytes read in the ReadThread function. More...

std::recursive_mutex	m_bytes_mutex
	A mutex to protect multi-threaded access to the cached bytes. More...

std::mutex	m_write_mutex
	Don't let multiple threads write at the same time... More...

std::mutex	m_synchronize_mutex

ReadThreadBytesReceived	m_callback

void *	m_callback_baton

bool	m_close_on_eof

Detailed Description

Definition at line 19 of file GDBRemoteClientBase.h.

Constructor & Destructor Documentation

◆ GDBRemoteClientBase()

GDBRemoteClientBase::GDBRemoteClientBase	(	const char *	comm_name,
		const char *	listener_name
	)

Definition at line 34 of file GDBRemoteClientBase.cpp.

Member Function Documentation

◆ Interrupt()

bool GDBRemoteClientBase::Interrupt ( std::chrono::seconds interrupt_timeout )

Definition at line 173 of file GDBRemoteClientBase.cpp.

References lldb_private::process_gdb_remote::GDBRemoteClientBase::Lock::DidInterrupt(), and m_should_stop.

◆ OnRunPacketSent()

void GDBRemoteClientBase::OnRunPacketSent ( bool first )

protectedvirtual

Reimplemented in lldb_private::process_gdb_remote::GDBRemoteCommunicationClient.

Definition at line 281 of file GDBRemoteClientBase.cpp.

References lldb_private::Broadcaster::BroadcastEvent(), and lldb_private::process_gdb_remote::GDBRemoteCommunication::eBroadcastBitRunPacketSent.

Referenced by lldb_private::process_gdb_remote::GDBRemoteCommunicationClient::OnRunPacketSent(), and SendContinuePacketAndWaitForResponse().

◆ SendAsyncSignal()

bool GDBRemoteClientBase::SendAsyncSignal	(	int	signo,
		std::chrono::seconds	interrupt_timeout
	)

Definition at line 161 of file GDBRemoteClientBase.cpp.

References lldb_private::process_gdb_remote::GDBRemoteClientBase::Lock::DidInterrupt(), and m_continue_packet.

◆ SendContinuePacketAndWaitForResponse()

StateType GDBRemoteClientBase::SendContinuePacketAndWaitForResponse	(	ContinueDelegate &	delegate,
		const UnixSignals &	signals,
		llvm::StringRef	payload,
		std::chrono::seconds	interrupt_timeout,
		StringExtractorGDBRemote &	response
	)

Definition at line 39 of file GDBRemoteClientBase.cpp.

References lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueLock::Cancelled, StringExtractor::Clear(), StringExtractor::Empty(), lldb_private::process_gdb_remote::GDBRemoteCommunication::ErrorReplyTimeout, lldb::eStateExited, lldb::eStateInvalid, lldb::eStateStopped, lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueLock::Failed, StringExtractor::GetChar(), StringExtractor::GetHexByteString(), lldb_private::GetLog(), StringExtractor::GetStringRef(), lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueDelegate::HandleAsyncMisc(), lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueDelegate::HandleAsyncStdout(), lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueDelegate::HandleAsyncStructuredDataPacket(), lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueDelegate::HandleStopReply(), kWakeupInterval(), LLDB_LOGF, lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueLock::lock(), m_async_count, m_continue_packet, m_interrupt_endpoint, m_mutex, m_should_stop, OnRunPacketSent(), lldb_private::process_gdb_remote::Process, lldb_private::process_gdb_remote::GDBRemoteCommunication::ReadPacket(), StringExtractor::SetFilePos(), ShouldStop(), string(), lldb_private::process_gdb_remote::GDBRemoteCommunication::Success, lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueLock::Success, and lldb_private::process_gdb_remote::GDBRemoteClientBase::ContinueLock::unlock().

◆ SendPacketAndReceiveResponseWithOutputSupport()

GDBRemoteCommunication::PacketResult GDBRemoteClientBase::SendPacketAndReceiveResponseWithOutputSupport	(	llvm::StringRef	payload,
		StringExtractorGDBRemote &	response,
		std::chrono::seconds	interrupt_timeout,
		llvm::function_ref< void(llvm::StringRef)>	output_callback
	)

Definition at line 199 of file GDBRemoteClientBase.cpp.

References lldb_private::process_gdb_remote::GDBRemoteCommunication::ErrorSendFailed, lldb_private::GetLog(), lldb_private::process_gdb_remote::GDBRemoteCommunication::GetPacketTimeout(), LLDB_LOGF, lldb_private::process_gdb_remote::Process, lldb_private::process_gdb_remote::GDBRemoteCommunication::ReadPacketWithOutputSupport(), lldb_private::process_gdb_remote::GDBRemoteCommunication::SendPacketNoLock(), and lldb_private::process_gdb_remote::GDBRemoteCommunication::Success.

Referenced by CommandObjectProcessGDBRemotePacketMonitor::DoExecute().

◆ SendPacketAndWaitForResponse()

GDBRemoteCommunication::PacketResult GDBRemoteClientBase::SendPacketAndWaitForResponse	(	llvm::StringRef	payload,
		StringExtractorGDBRemote &	response,
		std::chrono::seconds	interrupt_timeout = `std::chrono::seconds(0)`
	)

Definition at line 182 of file GDBRemoteClientBase.cpp.

References lldb_private::process_gdb_remote::GDBRemoteCommunication::ErrorSendFailed, lldb_private::GetLog(), LLDB_LOGF, lldb_private::process_gdb_remote::Process, and SendPacketAndWaitForResponseNoLock().

◆ SendPacketAndWaitForResponseNoLock()

GDBRemoteCommunication::PacketResult GDBRemoteClientBase::SendPacketAndWaitForResponseNoLock	(	llvm::StringRef	payload,
		StringExtractorGDBRemote &	response
	)

protected

Definition at line 222 of file GDBRemoteClientBase.cpp.

References lldb_private::GetLog(), lldb_private::process_gdb_remote::GDBRemoteCommunication::GetPacketTimeout(), StringExtractor::GetStringRef(), LLDB_LOGF, lldb_private::process_gdb_remote::Packets, lldb_private::process_gdb_remote::GDBRemoteCommunication::ReadPacket(), lldb_private::process_gdb_remote::GDBRemoteCommunication::SendPacketNoLock(), lldb_private::process_gdb_remote::GDBRemoteCommunication::Success, and StringExtractorGDBRemote::ValidateResponse().

Referenced by lldb_private::process_gdb_remote::GDBRemoteCommunicationClient::GetCurrentProcessAndThreadIDs(), SendPacketAndWaitForResponse(), lldb_private::process_gdb_remote::GDBRemoteCommunicationClient::SendThreadSpecificPacketAndWaitForResponse(), and lldb_private::process_gdb_remote::GDBRemoteCommunicationClient::ServeSymbolLookups().

◆ ShouldStop()

bool GDBRemoteClientBase::ShouldStop	(	const UnixSignals &	signals,
		StringExtractorGDBRemote &	response
	)

private

Definition at line 250 of file GDBRemoteClientBase.cpp.

References StringExtractor::GetHexU8(), lldb_private::UnixSignals::GetSignalNumberFromName(), m_async_count, m_mutex, and lldb_private::process_gdb_remote::GDBRemoteCommunication::ReadPacket().

Referenced by SendContinuePacketAndWaitForResponse().

Member Data Documentation

◆ m_async_count

uint32_t lldb_private::process_gdb_remote::GDBRemoteClientBase::m_async_count

private

Number of threads interested in sending.

Definition at line 129 of file GDBRemoteClientBase.h.

Referenced by SendContinuePacketAndWaitForResponse(), and ShouldStop().

◆ m_async_mutex

std::recursive_mutex lldb_private::process_gdb_remote::GDBRemoteClientBase::m_async_mutex

private

This handles the synchronization between individual async threads.

For now they just use a simple mutex.

Definition at line 140 of file GDBRemoteClientBase.h.

◆ m_continue_packet

std::string lldb_private::process_gdb_remote::GDBRemoteClientBase::m_continue_packet

private

Packet with which to resume after an async interrupt.

Can be changed by an async thread e.g. to inject a signal.

Definition at line 122 of file GDBRemoteClientBase.h.

Referenced by SendAsyncSignal(), and SendContinuePacketAndWaitForResponse().

◆ m_cv

std::condition_variable lldb_private::process_gdb_remote::GDBRemoteClientBase::m_cv

private

Definition at line 118 of file GDBRemoteClientBase.h.

◆ m_interrupt_endpoint

std::chrono::time_point<std::chrono::steady_clock> lldb_private::process_gdb_remote::GDBRemoteClientBase::m_interrupt_endpoint

private

When was the interrupt packet sent.

Used to make sure we time out if the stub does not respond to interrupt requests.

Definition at line 126 of file GDBRemoteClientBase.h.

Referenced by SendContinuePacketAndWaitForResponse().

◆ m_is_running

bool lldb_private::process_gdb_remote::GDBRemoteClientBase::m_is_running

private

Whether the continue thread has control.

Definition at line 132 of file GDBRemoteClientBase.h.

◆ m_mutex

std::mutex lldb_private::process_gdb_remote::GDBRemoteClientBase::m_mutex

private

Variables handling synchronization between the Continue thread and any other threads wishing to send packets over the connection.

Either the continue thread has control over the connection (m_is_running == true) or the connection is free for an arbitrary number of other senders to take which indicate their interest by incrementing m_async_count.

Semantics of individual states:

m_continue_packet == false, m_async_count == 0: connection is free
m_continue_packet == true, m_async_count == 0: only continue thread is present
m_continue_packet == true, m_async_count > 0: continue thread has control, async threads should interrupt it and wait for it to set m_continue_packet to false
m_continue_packet == false, m_async_count > 0: async threads have control, continue thread needs to wait for them to finish (m_async_count goes down to 0).

Definition at line 117 of file GDBRemoteClientBase.h.

Referenced by SendContinuePacketAndWaitForResponse(), and ShouldStop().

◆ m_should_stop

bool lldb_private::process_gdb_remote::GDBRemoteClientBase::m_should_stop

private

Whether we should resume after a stop.

Definition at line 135 of file GDBRemoteClientBase.h.

Referenced by Interrupt(), and SendContinuePacketAndWaitForResponse().

The documentation for this class was generated from the following files:

Classes

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ GDBRemoteClientBase()

Member Function Documentation

◆ Interrupt()

◆ OnRunPacketSent()

◆ SendAsyncSignal()

◆ SendContinuePacketAndWaitForResponse()

◆ SendPacketAndReceiveResponseWithOutputSupport()

◆ SendPacketAndWaitForResponse()

◆ SendPacketAndWaitForResponseNoLock()

◆ ShouldStop()

Member Data Documentation

◆ m_async_count

◆ m_async_mutex

◆ m_continue_packet

◆ m_cv

◆ m_interrupt_endpoint

◆ m_is_running

◆ m_mutex

◆ m_should_stop