#include <UdpDataLink.h>

Inheritance diagram for OpenDDS::DCPS::UdpDataLink:

[legend]

Collaboration diagram for OpenDDS::DCPS::UdpDataLink:

[legend]

Public Member Functions
	UdpDataLink (const UdpTransport_rch &transport, Priority priority, const ReactorTask_rch &reactor_task, bool active)

bool	active () const

ReactorTask_rch	reactor_task ()

ACE_Reactor *	get_reactor ()

ACE_INET_Addr &	remote_address ()

ACE_SOCK_Dgram &	socket ()

bool	open (const ACE_INET_Addr &remote_address)

void	control_received (ReceivedDataSample &sample, const ACE_INET_Addr &remote_address)

Public Member Functions inherited from OpenDDS::DCPS::DataLink
	DataLink (const TransportImpl_rch &impl, Priority priority, bool is_loopback, bool is_active)
	Only called by our TransportImpl object. More...

virtual	~DataLink ()

int	handle_exception (ACE_HANDLE)
	Reactor invokes this after being notified in schedule_stop or cancel_release. More...

void	schedule_stop (const MonotonicTimePoint &schedule_to_stop_at)

void	stop ()
	The stop method is used to stop the DataLink prior to shutdown. More...

void	resume_send ()

virtual int	make_reservation (const GUID_t &remote_subscription_id, const GUID_t &local_publication_id, const TransportSendListener_wrch &send_listener, bool reliable)

virtual int	make_reservation (const GUID_t &remote_publication_id, const GUID_t &local_subscription_id, const TransportReceiveListener_wrch &receive_listener, bool reliable)

void	release_reservations (GUID_t remote_id, GUID_t local_id, DataLinkSetMap &released_locals)

void	schedule_delayed_release ()

const TimeDuration &	datalink_release_delay () const

void	remove_listener (const GUID_t &local_id)

void	send_start ()

void	send (TransportQueueElement *element)

void	send_stop (GUID_t repoId)

virtual RemoveResult	remove_sample (const DataSampleElement *sample)

virtual void	remove_all_msgs (const GUID_t &pub_id)

int	data_received (ReceivedDataSample &sample, const GUID_t &readerId=GUID_UNKNOWN)

void	data_received_include (ReceivedDataSample &sample, const RepoIdSet &incl)

DataLinkIdType	id () const
	Obtain a unique identifier for this DataLink object. More...

void	transport_shutdown ()

void	notify (ConnectionNotice notice)

virtual void	pre_stop_i ()

void	release_resources ()

void	terminate_send ()

void	terminate_send_if_suspended ()

bool	is_target (const GUID_t &remote_id)

void	clear_associations ()

int	handle_timeout (const ACE_Time_Value &tv, const void *arg)

int	handle_close (ACE_HANDLE h, ACE_Reactor_Mask m)

void	set_dscp_codepoint (int cp, ACE_SOCK &socket)

Priority &	transport_priority ()

Priority	transport_priority () const

bool &	is_loopback ()

bool	is_loopback () const

bool &	is_active ()

bool	is_active () const

bool	cancel_release ()

ACE_Message_Block *	create_control (char submessage_id, DataSampleHeader &header, Message_Block_Ptr data)

SendControlStatus	send_control (const DataSampleHeader &header, Message_Block_Ptr data)

GUIDSeq *	target_intersection (const GUID_t &pub_id, const GUIDSeq &in, size_t &n_subs)

TransportImpl_rch	impl () const

void	default_listener (const TransportReceiveListener_wrch &trl)

TransportReceiveListener_wrch	default_listener () const

bool	add_on_start_callback (const TransportClient_wrch &client, const GUID_t &remote)

void	remove_on_start_callback (const TransportClient_wrch &client, const GUID_t &remote)

void	invoke_on_start_callbacks (bool success)

bool	invoke_on_start_callbacks (const GUID_t &local, const GUID_t &remote, bool success)

void	remove_startup_callbacks (const GUID_t &local, const GUID_t &remote)

void	set_scheduling_release (bool scheduling_release)

virtual void	send_final_acks (const GUID_t &readerid)

virtual WeakRcHandle< ICE::Endpoint >	get_ice_endpoint () const

virtual bool	is_leading (const GUID_t &, const GUID_t &) const

Public Member Functions inherited from OpenDDS::DCPS::RcEventHandler
	RcEventHandler ()

ACE_Event_Handler::Reference_Count	add_reference ()

ACE_Event_Handler::Reference_Count	remove_reference ()

Public Member Functions inherited from ACE_Event_Handler
virtual	~ACE_Event_Handler (void)

virtual ACE_HANDLE	get_handle (void) const

virtual void	set_handle (ACE_HANDLE)

virtual int	priority (void) const

virtual void	priority (int priority)

virtual int	handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_exit (ACE_Process *)

virtual int	handle_signal (int signum, siginfo_t =0, ucontext_t =0)

virtual int	resume_handler (void)

virtual int	handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual int	handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual void	reactor (ACE_Reactor *reactor)

virtual ACE_Reactor *	reactor (void) const

virtual ACE_Reactor_Timer_Interface *	reactor_timer_interface (void) const

Reference_Counting_Policy &	reference_counting_policy (void)

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Protected Member Functions
virtual void	stop_i ()

Protected Member Functions inherited from OpenDDS::DCPS::DataLink
int	start (const TransportSendStrategy_rch &send_strategy, const TransportStrategy_rch &receive_strategy, bool invoke_all=true)

void	send_start_i ()

virtual void	send_i (TransportQueueElement *element, bool relink=true)

void	send_stop_i (GUID_t repoId)

GUIDSeq *	peer_ids (const GUID_t &local_id) const

void	network_change () const

void	replay_durable_data (const GUID_t &local_pub_id, const GUID_t &remote_sub_id) const

TransportSendStrategy_rch	get_send_strategy ()

typedef	OPENDDS_MAP_CMP (GUID_t, TransportClient_wrch, GUID_tKeyLessThan) RepoToClientMap

typedef	OPENDDS_MAP_CMP (GUID_t, RepoToClientMap, GUID_tKeyLessThan) OnStartCallbackMap

typedef	OPENDDS_MAP_CMP (GUID_t, RepoIdSet, GUID_tKeyLessThan) PendingOnStartsMap

Protected Member Functions inherited from ACE_Event_Handler
	ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Protected Attributes
bool	active_

ReactorTask_rch	reactor_task_

UdpSendStrategy_rch	send_strategy_

UdpReceiveStrategy_rch	recv_strategy_

Protected Attributes inherited from OpenDDS::DCPS::DataLink
TransportStrategy_rch	receive_strategy_
	The transport receive strategy object for this DataLink. More...

TransportSendStrategy_rch	send_strategy_
	The transport send strategy object for this DataLink. More...

LockType	strategy_lock_

OnStartCallbackMap	on_start_callbacks_

PendingOnStartsMap	pending_on_starts_

TimeDuration	datalink_release_delay_

unique_ptr< MessageBlockAllocator >	mb_allocator_

unique_ptr< DataBlockAllocator >	db_allocator_

bool	is_loopback_
	Is remote attached to same transport ? More...

bool	is_active_
	Is pub or sub ? More...

bool	started_

SendResponseListener	send_response_listener_
	Listener for TransportSendControlElements created in send_control. More...

Interceptor	interceptor_

Protected Attributes inherited from ACE_Event_Handler
Atomic_Reference_Count	reference_count_

Private Attributes
ACE_INET_Addr	remote_address_

ACE_SOCK_Dgram	socket_

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::DataLink
enum	ConnectionNotice { DISCONNECTED, RECONNECTED, LOST }

typedef WeakRcHandle< TransportClient >	TransportClient_wrch

typedef std::pair< TransportClient_wrch, GUID_t >	OnStartCallback

Public Types inherited from ACE_Event_Handler
typedef long	Reference_Count

Static Public Member Functions inherited from ACE_Event_Handler
static ACE_THR_FUNC_RETURN	read_adapter (void *event_handler)

static int	register_stdin_handler (ACE_Event_Handler eh, ACE_Reactor reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)

static int	remove_stdin_handler (ACE_Reactor reactor, ACE_Thread_Manager thr_mgr)

Public Attributes inherited from ACE_Event_Handler
	LO_PRIORITY

	HI_PRIORITY

	NULL_MASK

	READ_MASK

	WRITE_MASK

	EXCEPT_MASK

	ACCEPT_MASK

	CONNECT_MASK

	TIMER_MASK

	QOS_MASK

	GROUP_QOS_MASK

	SIGNAL_MASK

	ALL_EVENTS_MASK

	RWE_MASK

	DONT_CALL

	ACE_EVENT_HANDLER_NOT_RESUMED

	ACE_REACTOR_RESUMES_HANDLER

	ACE_APPLICATION_RESUMES_HANDLER

Protected Types inherited from OpenDDS::DCPS::DataLink
typedef ACE_Guard< LockType >	GuardType

Protected Types inherited from ACE_Event_Handler
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_Count >	Atomic_Reference_Count

Static Protected Member Functions inherited from OpenDDS::DCPS::DataLink
static ACE_UINT64	get_next_datalink_id ()
	Used to provide unique Ids to all DataLink methods. More...

Detailed Description

Definition at line 35 of file UdpDataLink.h.

Constructor & Destructor Documentation

◆ UdpDataLink()

OpenDDS::DCPS::UdpDataLink::UdpDataLink	(	const UdpTransport_rch &	transport,
		Priority	priority,
		const ReactorTask_rch &	reactor_task,
		bool	active
	)

Definition at line 30 of file UdpDataLink.cpp.

   : DataLink(transport,
              priority,
              false, // is_loopback,
              active),// is_active
     active_(active),
     reactor_task_(reactor_task),
     send_strategy_(make_rch<UdpSendStrategy>(this)),
     recv_strategy_(make_rch<UdpReceiveStrategy>(this))
 {
 }

Member Function Documentation

◆ active()

ACE_INLINE bool OpenDDS::DCPS::UdpDataLink::active ( void ) const

Definition at line 14 of file UdpDataLink.inl.

References ACE_INLINE, and active_.

 {
   return this->active_;
 }

◆ control_received()

void OpenDDS::DCPS::UdpDataLink::control_received	(	ReceivedDataSample &	sample,
		const ACE_INET_Addr &	remote_address
	)

Definition at line 276 of file UdpDataLink.cpp.

References OpenDDS::DCPS::DataLink::impl(), and OPENDDS_TEST_AND_CALL.

Referenced by OpenDDS::DCPS::UdpReceiveStrategy::deliver_sample().

 {
   // At this time, the TRANSPORT_CONTROL messages in Udp are only used for
   // the connection handshaking, so receiving one is an indication of the
   // passive_connection event.  In the future the submessage_id_ could be used
   // to allow different types of messages here.
   OPENDDS_TEST_AND_CALL(UdpTransport_rch, dynamic_rchandle_cast<UdpTransport>(impl()), passive_connection(remote_address, sample));
 }

◆ get_reactor()

ACE_INLINE ACE_Reactor * OpenDDS::DCPS::UdpDataLink::get_reactor ( void )

Definition at line 27 of file UdpDataLink.inl.

References ACE_INLINE, OpenDDS::DCPS::ReactorTask::get_reactor(), and reactor_task_.

Referenced by OpenDDS::DCPS::UdpReceiveStrategy::start_i(), and OpenDDS::DCPS::UdpReceiveStrategy::stop_i().

 {
   if (this->reactor_task_ == 0) return 0;
   return this->reactor_task_->get_reactor();
 }

◆ open()

bool OpenDDS::DCPS::UdpDataLink::open ( const ACE_INET_Addr & remote_address )

Definition at line 46 of file UdpDataLink.cpp.

Referenced by OpenDDS::DCPS::UdpTransport::make_datalink().

 {
   this->remote_address_ = remote_address;
 
   UdpInst_rch cfg = dynamic_rchandle_cast<UdpTransport>(impl())->config();
   if (!cfg) {
     return false;
   }
 
   this->is_loopback_ = this->remote_address_ == cfg->local_address();
 
   ACE_INET_Addr local_address;
   if (this->active_) {
     if (local_address.get_type() != remote_address.get_type()) {
       local_address.set(0, "", 0, remote_address.get_type());
     }
   } else {
     local_address = cfg->local_address();
   }
 
   if (!open_appropriate_socket_type(this->socket_, local_address)) {
     ACE_ERROR_RETURN((LM_ERROR,
       ACE_TEXT("(%P|%t) ERROR: ")
       ACE_TEXT("UdpDataLink::open: open_appropriate_socket_type failed\n")),
       false);
   }
 
   VDBG((LM_DEBUG, "(%P|%t) UdpDataLink::open: listening on %C\n",
         LogAddr(local_address).c_str()));
 
   // If listening on "any" host/port, need to record the actual port number
   // selected by the OS, as well as our actual hostname, into the config_
   // object's local_address_ for use in UdpTransport::connection_info_i().
   if (!this->active_ && cfg->local_address().is_any()) {
     ACE_INET_Addr address;
     if (this->socket_.get_local_addr(address) != 0) {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: UdpDataLink::open - %p"),
                         ACE_TEXT("cannot get local addr\n")), false);
     }
     const unsigned short port = address.get_port_number();
     const std::string hostname = get_fully_qualified_hostname();
     VDBG_LVL((LM_DEBUG,
               ACE_TEXT("(%P|%t) UdpDataLink::open listening on host %C:%hu\n"),
               hostname.c_str(), port), 2);
 
     cfg->local_address(port, hostname.c_str());
 
   // Similar case to the "if" case above, but with a bound host/IP but no port
   } else if (!this->active_ &&
              0 == cfg->local_address().get_port_number()) {
     ACE_INET_Addr address;
     if (this->socket_.get_local_addr(address) != 0) {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: UdpDataLink::open - %p"),
                         ACE_TEXT("cannot get local addr\n")), false);
     }
     const unsigned short port = address.get_port_number();
     VDBG_LVL((LM_DEBUG,
               ACE_TEXT("(%P|%t) UdpDataLink::open listening on port %hu\n"),
               port), 2);
     cfg->local_address_set_port(port);
   }
 
   if (cfg->send_buffer_size_ > 0) {
     int snd_size = cfg->send_buffer_size_;
     if (this->socket_.set_option(SOL_SOCKET,
                                 SO_SNDBUF,
                                 (void *) &snd_size,
                                 sizeof(snd_size)) < 0
         && errno != ENOTSUP) {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: ")
                         ACE_TEXT("UdpDataLink::open: failed to set the send buffer size to %d errno %m\n"),
                         snd_size),
                        false);
     }
   }
 
   if (cfg->rcv_buffer_size_ > 0) {
     int rcv_size = cfg->rcv_buffer_size_;
     if (this->socket_.set_option(SOL_SOCKET,
                                 SO_RCVBUF,
                                 (void *) &rcv_size,
                                 sizeof(int)) < 0
         && errno != ENOTSUP) {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: ")
                         ACE_TEXT("UdpDataLink::open: failed to set the receive buffer size to %d errno %m\n"),
                         rcv_size),
                        false);
     }
   }
 
 #ifdef ACE_WIN32
   // By default Winsock will cause reads to fail with "connection reset"
   // when UDP sends result in ICMP "port unreachable" messages.
   // The transport framework is not set up for this since returning <= 0
   // from our receive_bytes causes the framework to close down the datalink
   // which in this case is used to receive from multiple peers.
   BOOL recv_udp_connreset = FALSE;
   socket_.control(SIO_UDP_CONNRESET, &recv_udp_connreset);
 #endif
 
   if (this->active_) {
     // Set the DiffServ codepoint according to the priority value.
     DirectPriorityMapper mapper(this->transport_priority());
     this->set_dscp_codepoint(mapper.codepoint(), this->socket_);
 
 
     // For the active side, send the blob and wait for a 1 byte ack.
     VDBG((LM_DEBUG, "(%P|%t) UdpDataLink::open: active connect to %C\n",
       LogAddr(remote_address).c_str()));
 
     TransportLocator info = TransportLocator();
     OPENDDS_TEST_AND_CALL(TransportImpl_rch, impl(), connection_info_i(info, CONNINFO_ALL));
     ACE_Message_Block* data_block;
     ACE_NEW_RETURN(data_block,
                    ACE_Message_Block(info.data.length()+sizeof(Priority),
                                      ACE_Message_Block::MB_DATA,
                                      0, //cont
                                      0, //data
                                      0, //allocator_strategy
                                      0, //locking_strategy
                                      ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY,
                                      ACE_Time_Value::zero,
                                      ACE_Time_Value::max_time,
                                      0,
                                      0),
                    0);
 
     Serializer serializer(data_block, Encoding::KIND_UNALIGNED_CDR);
     serializer << this->transport_priority();
     serializer.write_octet_array(info.data.get_buffer(),
                                  info.data.length());
 
     DataSampleHeader sample_header;
     sample_header.message_id_ = TRANSPORT_CONTROL;
     sample_header.message_length_ =
       static_cast<ACE_UINT32>(data_block->length());
     ACE_Message_Block* sample_header_block;
     ACE_NEW_RETURN(sample_header_block,
                    ACE_Message_Block(DataSampleHeader::get_max_serialized_size(),
                                      ACE_Message_Block::MB_DATA,
                                      0, //cont
                                      0, //data
                                      0, //allocator_strategy
                                      0, //locking_strategy
                                      ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY,
                                      ACE_Time_Value::zero,
                                      ACE_Time_Value::max_time,
                                      0,
                                      0),
                    0);
     *sample_header_block << sample_header;
     sample_header_block->cont(data_block);
 
     ACE_Message_Block* transport_header_block;
     TransportHeader transport_header;
     ACE_NEW_RETURN(transport_header_block,
                    ACE_Message_Block(TransportHeader::get_max_serialized_size(),
                                      ACE_Message_Block::MB_DATA,
                                      0,
                                      0,
                                      0,
                                      0,
                                      ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY,
                                      ACE_Time_Value::zero,
                                      ACE_Time_Value::max_time,
                                      0,
                                      0),
                    0);
 
     transport_header.length_ =
       static_cast<ACE_UINT32>(data_block->length() +
                               sample_header_block->length());
     *transport_header_block << transport_header;
     transport_header_block->cont(sample_header_block);
 
     iovec iov[MAX_SEND_BLOCKS];
     const int num_blocks =
       TransportSendStrategy::mb_to_iov(*transport_header_block, iov);
     const ssize_t sent = socket().send(iov, num_blocks, remote_address);
     transport_header_block->release();
     if (sent < 0) {
       ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: UdpDataLink::open: ")
                                   ACE_TEXT("failed to send handshake %m\n")),
                        false);
     }
 
     // Need to wait for the 1 byte ack from the passive side before returning
     // the link (and indicating success).
     const size_t size = 32;
     char buff[size];
     // Default this timeout to 30.  We may want to make this settable
     // or use another settable timeout value here.
     const TimeDuration tv(30);
     const ssize_t recvd = socket().recv(buff, size, this->remote_address_, 0, &tv.value());
     if (recvd == 1) {
       // Expected value
       VDBG_LVL((LM_DEBUG,
                 ACE_TEXT("(%P|%t) UdpDataLink::open received handshake ack\n")),
                2);
     } else if (recvd < 0) {
       // Not a handshake ack, something is wrong
       ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: UdpDataLink::open: ")
                                   ACE_TEXT("failed to receive handshake ack %p\n"),
                         ACE_TEXT("recv")), false);
     } else {
       ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: UdpDataLink::open: ")
                                   ACE_TEXT("failed to receive handshake ack ")
                                   ACE_TEXT("recv returned %b\n"), recvd),
                        false);
     }
   }
 
   if (start(static_rchandle_cast<TransportSendStrategy>(this->send_strategy_),
             static_rchandle_cast<TransportStrategy>(this->recv_strategy_))
       != 0) {
     stop_i();
     ACE_ERROR_RETURN((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: ")
                       ACE_TEXT("UdpDataLink::open: start failed!\n")),
                      false);
   }
 
   return true;
 }

◆ reactor_task()

ACE_INLINE ReactorTask_rch OpenDDS::DCPS::UdpDataLink::reactor_task ( )

Definition at line 21 of file UdpDataLink.inl.

References ACE_INLINE, and reactor_task_.

 {
   return this->reactor_task_;
 }

◆ remote_address()

ACE_INLINE ACE_INET_Addr & OpenDDS::DCPS::UdpDataLink::remote_address ( )

Definition at line 34 of file UdpDataLink.inl.

References ACE_INLINE, and remote_address_.

Referenced by open(), and OpenDDS::DCPS::UdpSendStrategy::send_bytes_i().

 {
   return this->remote_address_;
 }

◆ socket()

ACE_INLINE ACE_SOCK_Dgram & OpenDDS::DCPS::UdpDataLink::socket ( void )

Definition at line 40 of file UdpDataLink.inl.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL, and socket_.

Referenced by OpenDDS::DCPS::UdpReceiveStrategy::get_handle(), open(), OpenDDS::DCPS::UdpTransport::passive_connection(), OpenDDS::DCPS::UdpReceiveStrategy::receive_bytes(), OpenDDS::DCPS::UdpSendStrategy::send_bytes_i(), and OpenDDS::DCPS::UdpReceiveStrategy::start_i().

 {
   return this->socket_;
 }

◆ stop_i()

void OpenDDS::DCPS::UdpDataLink::stop_i ( )

protectedvirtual

This announces the "stop" event to our subclass. The "stop" event will occur when this DataLink is handling a release_reservations() call and determines that it has just released all of the remaining reservations on this DataLink. The "stop" event will also occur when the TransportImpl is being shutdown() - we call stop_i() from our transport_shutdown() method to handle this case.

Reimplemented from OpenDDS::DCPS::DataLink.

Definition at line 287 of file UdpDataLink.cpp.

References ACE_SOCK::close(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, and socket_.

Referenced by open().

 {
   this->socket_.close();
 }

Member Data Documentation

◆ active_

bool OpenDDS::DCPS::UdpDataLink::active_

protected

Definition at line 59 of file UdpDataLink.h.

Referenced by active(), and open().

◆ reactor_task_

ReactorTask_rch OpenDDS::DCPS::UdpDataLink::reactor_task_

protected

Definition at line 61 of file UdpDataLink.h.

Referenced by get_reactor(), and reactor_task().

◆ recv_strategy_

UdpReceiveStrategy_rch OpenDDS::DCPS::UdpDataLink::recv_strategy_

protected

Definition at line 64 of file UdpDataLink.h.

Referenced by open().

◆ remote_address_

ACE_INET_Addr OpenDDS::DCPS::UdpDataLink::remote_address_

private

Definition at line 69 of file UdpDataLink.h.

Referenced by open(), and remote_address().

◆ send_strategy_

UdpSendStrategy_rch OpenDDS::DCPS::UdpDataLink::send_strategy_

protected

Definition at line 63 of file UdpDataLink.h.

Referenced by open().

◆ socket_

ACE_SOCK_Dgram OpenDDS::DCPS::UdpDataLink::socket_

private

Definition at line 71 of file UdpDataLink.h.

Referenced by open(), socket(), and stop_i().

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

Public Member Functions

Protected Member Functions

Protected Attributes

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ UdpDataLink()

Member Function Documentation

◆ active()

◆ control_received()

◆ get_reactor()

◆ open()

◆ reactor_task()

◆ remote_address()

◆ socket()

◆ stop_i()

Member Data Documentation

◆ active_

◆ reactor_task_

◆ recv_strategy_

◆ remote_address_

◆ send_strategy_

◆ socket_