#include <MulticastTransport.h>

Inheritance diagram for OpenDDS::DCPS::MulticastTransport:

Collaboration diagram for OpenDDS::DCPS::MulticastTransport:

[legend]

Public Member Functions
	MulticastTransport (const MulticastInst_rch &inst)

	~MulticastTransport ()

void	passive_connection (MulticastPeer local_peer, MulticastPeer remote_peer)

MulticastInst_rch	config () const

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

virtual void	unbind_link (DataLink *link)
	Remove any pending_release mappings. More...

bool	release_link_resources (DataLink *link)

TransportInst_rch	config () const

virtual void	register_for_reader (const GUID_t &, const GUID_t &, const GUID_t &, const TransportLocatorSeq &, OpenDDS::DCPS::DiscoveryListener *)

virtual void	unregister_for_reader (const GUID_t &, const GUID_t &, const GUID_t &)

virtual void	register_for_writer (const GUID_t &, const GUID_t &, const GUID_t &, const TransportLocatorSeq &, DiscoveryListener *)

virtual void	unregister_for_writer (const GUID_t &, const GUID_t &, const GUID_t &)

virtual void	update_locators (const GUID_t &, const TransportLocatorSeq &)

virtual void	get_last_recv_locator (const GUID_t &, TransportLocator &)

virtual void	rtps_relay_address_change ()

virtual void	append_transport_statistics (TransportStatisticsSequence &)

ACE_Reactor_Timer_Interface *	timer () const
	Interface to the transport's reactor for scheduling timers. More...

ACE_Reactor *	reactor () const

ACE_thread_t	reactor_owner () const

bool	is_shut_down () const

void	create_reactor_task (bool useAsyncSend=false, const OPENDDS_STRING &name="")

void	dump ()
	Diagnostic aid. More...

OPENDDS_STRING	dump_to_str ()

void	report ()

virtual WeakRcHandle< ICE::Endpoint >	get_ice_endpoint ()

virtual void	rtps_relay_only_now (bool)

virtual void	use_rtps_relay_now (bool)

virtual void	use_ice_now (bool)

ReactorTask_rch	reactor_task ()

EventDispatcher_rch	event_dispatcher ()

int	acquire ()

int	tryacquire ()

int	release ()

int	remove ()

bool	connection_info (TransportLocator &local_info, ConnectionInfoFlags flags) const

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 AcceptConnectResult	connect_datalink (const RemoteTransport &remote, const ConnectionAttribs &attribs, const TransportClient_rch &client)

virtual AcceptConnectResult	accept_datalink (const RemoteTransport &remote, const ConnectionAttribs &attribs, const TransportClient_rch &client)

virtual void	stop_accepting_or_connecting (const TransportClient_wrch &client, const GUID_t &remote_id, bool disassociate, bool association_failed)

bool	configure_i (const MulticastInst_rch &config)

virtual void	shutdown_i ()

virtual bool	connection_info_i (TransportLocator &info, ConnectionInfoFlags flags) const

virtual void	release_datalink (DataLink *link)

virtual std::string	transport_type () const

void	client_stop (const GUID_t &localId)

Protected Member Functions inherited from OpenDDS::DCPS::TransportImpl
	TransportImpl (TransportInst_rch config)

bool	open ()

typedef	OPENDDS_MULTIMAP (TransportClient_wrch, DataLink_rch) PendConnMap

void	add_pending_connection (const TransportClient_rch &client, DataLink_rch link)

void	shutdown ()

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

Private Types
typedef ACE_SYNCH_MUTEX	LockType

typedef ACE_Guard< LockType >	GuardType

typedef ACE_Thread_Mutex	ThreadLockType

typedef ACE_Guard< ThreadLockType >	GuardThreadType

typedef std::vector< DataLink::OnStartCallback >	Callbacks

typedef std::pair< MulticastPeer, MulticastPeer >	Peers

Private Member Functions
MulticastDataLink_rch	make_datalink (const GUID_t &local_id, Priority priority, bool active)

MulticastSession_rch	start_session (const MulticastDataLink_rch &link, MulticastPeer remote_peer, bool active)

typedef	OPENDDS_MAP (MulticastPeer, MulticastDataLink_rch) Links
	link for pubs. More...

typedef	OPENDDS_MAP (Peers, Callbacks) PendConnMap

	OPENDDS_SET (Peers) connections_

Private Attributes
ThreadLockType	links_lock_

Links	client_links_

Links	server_links_
	link for subs. More...

ThreadLockType	connections_lock_

PendConnMap	pending_connections_

Additional Inherited Members
Public Attributes inherited from OpenDDS::DCPS::TransportImpl
LockType	lock_
	Lock to protect the config_ and reactor_task_ data members. More...

WeakRcHandle< TransportInst >	config_

ReactorTask_rch	reactor_task_

EventDispatcher_rch	event_dispatcher_
	smart ptr to the associated DL cleanup task More...

unique_ptr< Monitor >	monitor_
	Monitor object for this entity. More...

Protected Types inherited from OpenDDS::DCPS::TransportImpl
typedef ACE_SYNCH_MUTEX	LockType

typedef ACE_Guard< LockType >	GuardType

Protected Attributes inherited from OpenDDS::DCPS::TransportImpl
LockType	pending_connections_lock_
	Lock to protect the pending_connections_ data member. More...

PendConnMap	pending_connections_

AtomicBool	is_shut_down_
	Id of the last link established. More...

Detailed Description

Definition at line 28 of file MulticastTransport.h.

Member Typedef Documentation

◆ Callbacks

typedef std::vector<DataLink::OnStartCallback> OpenDDS::DCPS::MulticastTransport::Callbacks

private

Definition at line 92 of file MulticastTransport.h.

◆ GuardThreadType

typedef ACE_Guard<ThreadLockType> OpenDDS::DCPS::MulticastTransport::GuardThreadType

private

Definition at line 69 of file MulticastTransport.h.

◆ GuardType

typedef ACE_Guard<LockType> OpenDDS::DCPS::MulticastTransport::GuardType

private

Definition at line 66 of file MulticastTransport.h.

◆ LockType

typedef ACE_SYNCH_MUTEX OpenDDS::DCPS::MulticastTransport::LockType

private

Definition at line 65 of file MulticastTransport.h.

◆ Peers

typedef std::pair<MulticastPeer, MulticastPeer> OpenDDS::DCPS::MulticastTransport::Peers

private

Definition at line 93 of file MulticastTransport.h.

◆ ThreadLockType

typedef ACE_Thread_Mutex OpenDDS::DCPS::MulticastTransport::ThreadLockType

private

Definition at line 68 of file MulticastTransport.h.

Constructor & Destructor Documentation

◆ MulticastTransport()

OpenDDS::DCPS::MulticastTransport::MulticastTransport ( const MulticastInst_rch & inst )

explicit

Definition at line 31 of file MulticastTransport.cpp.

References configure_i(), and OpenDDS::DCPS::TransportImpl::open().

   : TransportImpl(inst)
 {
   if (! (configure_i(inst) && open())) {
     throw Transport::UnableToCreate();
   }
 }

◆ ~MulticastTransport()

OpenDDS::DCPS::MulticastTransport::~MulticastTransport ( )

Definition at line 39 of file MulticastTransport.cpp.

40 {

41 }

Member Function Documentation

◆ accept_datalink()

TransportImpl::AcceptConnectResult OpenDDS::DCPS::MulticastTransport::accept_datalink	(	const RemoteTransport &	remote,
		const ConnectionAttribs &	attribs,
		const TransportClient_rch &	client
	)

protectedvirtual

accept_datalink() is called from TransportClient to initiate an association as the passive peer. A DataLink may be returned if one is already connected and ready to use, otherwise passively wait for a physical connection from the active side (either in the form of a connection event or handshaking message). Upon completion of the physical connection, the transport calls back to TransportClient::use_datalink().

active

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 210 of file MulticastTransport.cpp.

References OpenDDS::DCPS::TransportImpl::AcceptConnectResult::ACR_FAILED, OpenDDS::DCPS::TransportImpl::AcceptConnectResult::ACR_SUCCESS, config(), connections_lock_, OpenDDS::DCPS::RepoIdConverter::federationId(), OpenDDS::DCPS::get_remote_reliability(), OpenDDS::DCPS::RcHandle< T >::is_nil(), links_lock_, LM_DEBUG, OpenDDS::DCPS::TransportImpl::ConnectionAttribs::local_id_, make_datalink(), OpenDDS::DCPS::RepoIdConverter::participantId(), pending_connections_, OpenDDS::DCPS::TransportImpl::ConnectionAttribs::priority_, OpenDDS::DCPS::push_back(), ACE_Guard< ACE_LOCK >::release(), OpenDDS::DCPS::TransportImpl::RemoteTransport::repo_id_, OpenDDS::DCPS::RcHandle< T >::reset(), server_links_, start_session(), and VDBG.

 {
   MulticastInst_rch cfg = config();
 
   if (!cfg) {
     return AcceptConnectResult(AcceptConnectResult::ACR_FAILED);
   }
 
   // Check that the remote reliability matches.
   if (get_remote_reliability(remote) != cfg->is_reliable()) {
     return AcceptConnectResult();
   }
 
   const MulticastPeer local_peer = (ACE_INT64)RepoIdConverter(attribs.local_id_).federationId() << 32
                                  | RepoIdConverter(attribs.local_id_).participantId();
 
   GuardThreadType guard_links(this->links_lock_);
 
   Links::const_iterator link_iter = this->server_links_.find(local_peer);
   MulticastDataLink_rch link;
 
   if (link_iter == this->server_links_.end()) {
 
     link = this->make_datalink(attribs.local_id_, attribs.priority_, false /*passive*/);
     this->server_links_[local_peer] = link;
   } else {
     link = link_iter->second;
   }
 
   guard_links.release();
 
   MulticastPeer remote_peer = (ACE_INT64)RepoIdConverter(remote.repo_id_).federationId() << 32
                             | RepoIdConverter(remote.repo_id_).participantId();
 
   GuardThreadType guard(this->connections_lock_);
 
   if (connections_.count(std::make_pair(remote_peer, local_peer))) {
     //can't call start session with connections_lock_ due to reactor
     //call in session->start which could deadlock with passive_connection
     guard.release();
 
     VDBG((LM_DEBUG, "(%P|%t) MulticastTransport::accept_datalink found\n"));
     MulticastSession_rch session(
       this->start_session(link, remote_peer, false /*!active*/));
 
     if (session.is_nil()) {
       link.reset();
     }
     return AcceptConnectResult(link);
 
   } else {
 
     if (cfg->is_reliable()) {
       pending_connections_[std::make_pair(remote_peer, local_peer)].
       push_back(std::make_pair(client, remote.repo_id_));
     }
 
     //can't call start session with connections_lock_ due to reactor
     //call in session->start which could deadlock with passive_connection
     guard.release();
     MulticastSession_rch session(
       this->start_session(link, remote_peer, false /*!active*/));
 
     if (!session) {
       return AcceptConnectResult(AcceptConnectResult::ACR_FAILED);
     } else if (cfg->is_reliable()) {
       return AcceptConnectResult(AcceptConnectResult::ACR_SUCCESS);
     } else {
       return AcceptConnectResult(link);
     }
   }
 }

◆ client_stop()

void OpenDDS::DCPS::MulticastTransport::client_stop ( const GUID_t & localId )

protectedvirtual

Reimplemented from OpenDDS::DCPS::TransportImpl.

Definition at line 435 of file MulticastTransport.cpp.

References client_links_, OpenDDS::DCPS::RepoIdConverter::federationId(), links_lock_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::RepoIdConverter::participantId(), and ACE_Guard< ACE_LOCK >::release().

 {
   GuardThreadType guard_links(this->links_lock_);
   const MulticastPeer local_peer = (ACE_INT64)RepoIdConverter(localId).federationId() << 32
                                  | RepoIdConverter(localId).participantId();
   Links::const_iterator link_iter = this->client_links_.find(local_peer);
   MulticastDataLink_rch link;
 
   if (link_iter != this->client_links_.end()) {
     link = link_iter->second;
   }
   guard_links.release();
 
   if (link) {
     link->client_stop(localId);
   }
 }

◆ config()

MulticastInst_rch OpenDDS::DCPS::MulticastTransport::config ( ) const

Definition at line 45 of file MulticastTransport.cpp.

References OpenDDS::DCPS::TransportImpl::config(), and OpenDDS::DCPS::dynamic_rchandle_cast().

Referenced by accept_datalink(), connect_datalink(), connection_info_i(), make_datalink(), passive_connection(), and start_session().

 {
   return dynamic_rchandle_cast<MulticastInst>(TransportImpl::config());
 }

◆ configure_i()

bool OpenDDS::DCPS::MulticastTransport::configure_i ( const MulticastInst_rch & config )

protected

Definition at line 368 of file MulticastTransport.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::TransportImpl::create_reactor_task(), INET6_ADDRSTRLEN, OpenDDS::DCPS::LogAddr::ip(), LM_ERROR, and TheServiceParticipant.

Referenced by MulticastTransport().

 {
   if (!config) {
     return false;
   }
 
   // Override with DCPSDefaultAddress.
   if (config->local_address_.empty() &&
       TheServiceParticipant->default_address().to_addr() != ACE_INET_Addr()) {
     char buffer[INET6_ADDRSTRLEN];
     config->local_address_ = TheServiceParticipant->default_address().to_addr().get_host_addr(buffer, sizeof buffer);
   }
 
   if (!config->group_address_.is_multicast()) {
     ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: MulticastTransport[%@]::configure_i: ")
                       ACE_TEXT("invalid configuration: address %C is not multicast.\n"),
                       this, LogAddr::ip(config->group_address_).c_str()), false);
   }
 
   this->create_reactor_task(config->async_send_, "MulticastTransport" + config->name());
 
   return true;
 }

◆ connect_datalink()

TransportImpl::AcceptConnectResult OpenDDS::DCPS::MulticastTransport::connect_datalink	(	const RemoteTransport &	remote,
		const ConnectionAttribs &	attribs,
		const TransportClient_rch &	client
	)

protectedvirtual

connect_datalink() is called from TransportClient to initiate an association as the active peer. A DataLink may be returned if one is already connected and ready to use, otherwise initiate a connection to the passive side and return from this method. Upon completion of the physical connection, the transport calls back to TransportClient::use_datalink().

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 150 of file MulticastTransport.cpp.

References OpenDDS::DCPS::TransportImpl::AcceptConnectResult::ACR_FAILED, OpenDDS::DCPS::TransportImpl::AcceptConnectResult::ACR_SUCCESS, client_links_, config(), OpenDDS::DCPS::RepoIdConverter::federationId(), OpenDDS::DCPS::get_remote_reliability(), OpenDDS::DCPS::RcHandle< T >::is_nil(), links_lock_, OpenDDS::DCPS::TransportImpl::ConnectionAttribs::local_id_, make_datalink(), OpenDDS::DCPS::RepoIdConverter::participantId(), OpenDDS::DCPS::TransportImpl::ConnectionAttribs::priority_, OpenDDS::DCPS::TransportImpl::RemoteTransport::repo_id_, and start_session().

 {
   MulticastInst_rch cfg = config();
 
   if (!cfg) {
     return AcceptConnectResult(AcceptConnectResult::ACR_FAILED);
   }
 
   // Check that the remote reliability matches.
   if (get_remote_reliability(remote) != cfg->is_reliable()) {
     return AcceptConnectResult();
   }
 
   GuardThreadType guard_links(this->links_lock_);
   const MulticastPeer local_peer = (ACE_INT64)RepoIdConverter(attribs.local_id_).federationId() << 32
                                  | RepoIdConverter(attribs.local_id_).participantId();
   Links::const_iterator link_iter = this->client_links_.find(local_peer);
   MulticastDataLink_rch link;
 
   if (link_iter == this->client_links_.end()) {
     link = this->make_datalink(attribs.local_id_, attribs.priority_, true /*active*/);
     this->client_links_[local_peer] = link;
   } else {
     link = link_iter->second;
   }
 
   MulticastPeer remote_peer = (ACE_INT64)RepoIdConverter(remote.repo_id_).federationId() << 32
                             | RepoIdConverter(remote.repo_id_).participantId();
 
   if (cfg->is_reliable()) {
     link->add_on_start_callback(client, remote.repo_id_);
   }
 
   MulticastSession_rch session(
     this->start_session(link, remote_peer, true /*active*/));
 
   if (session.is_nil()) {
     Links::iterator to_remove = this->client_links_.find(local_peer);
     if (to_remove != this->client_links_.end()) {
       this->client_links_.erase(to_remove);
     }
     link->remove_on_start_callback(client, remote.repo_id_);
     return AcceptConnectResult();
   }
 
   if (cfg->is_reliable()) {
     session->add_remote(attribs.local_id_, remote.repo_id_);
     if (remote_peer != local_peer) {
       return AcceptConnectResult(AcceptConnectResult::ACR_SUCCESS);
     }
   } else {
     session->add_remote(attribs.local_id_);
   }
 
   return AcceptConnectResult(link);
 }

◆ connection_info_i()

bool OpenDDS::DCPS::MulticastTransport::connection_info_i	(	TransportLocator &	local_info,
		ConnectionInfoFlags	flags
	)		const

protectedvirtual

Called by our connection_info() method to allow the concrete TransportImpl subclass to do the dirty work since it really is the one that knows how to populate the supplied TransportLocator object.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 418 of file MulticastTransport.cpp.

References config().

 {
   MulticastInst_rch cfg = config();
   if (cfg) {
     cfg->populate_locator(info, flags);
     return true;
   }
   return false;
 }

◆ make_datalink()

MulticastDataLink_rch OpenDDS::DCPS::MulticastTransport::make_datalink	(	const GUID_t &	local_id,
		Priority	priority,
		bool	active
	)

private

Definition at line 51 of file MulticastTransport.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogAddr::c_str(), config(), OpenDDS::DCPS::RepoIdConverter::federationId(), OpenDDS::DCPS::LogAddr::HostPort, LM_DEBUG, LM_ERROR, OpenDDS::DCPS::RepoIdConverter::participantId(), OpenDDS::DCPS::rchandle_from(), OpenDDS::DCPS::TransportImpl::reactor_task(), OpenDDS::DCPS::ref(), and VDBG_LVL.

Referenced by accept_datalink(), and connect_datalink().

 {
   RcHandle<MulticastSessionFactory> session_factory;
   MulticastInst_rch cfg = config();
   if (cfg && cfg->is_reliable()) {
     session_factory = make_rch<ReliableSessionFactory>();
   } else {
     session_factory = make_rch<BestEffortSessionFactory>();
   }
 
   MulticastPeer local_peer = (ACE_INT64)RepoIdConverter(local_id).federationId() << 32
                            | RepoIdConverter(local_id).participantId();
 
   VDBG_LVL((LM_DEBUG, "(%P|%t) MulticastTransport[%C]::make_datalink "
             "peers: local %#08x%08x priority %d active %d\n",
             cfg ? cfg->name().c_str() : "", (unsigned int)(local_peer >> 32), (unsigned int)local_peer,
             priority, active), 2);
 
   MulticastDataLink_rch link(make_rch<MulticastDataLink>(rchandle_from(this),
                                                          session_factory,
                                                          local_peer,
                                                          ref(cfg),
                                                          reactor_task(),
                                                          active));
 
   // Join multicast group:
   if (!link->join(cfg->group_address_)) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: MulticastTransport::make_datalink: ")
                ACE_TEXT("failed to join multicast group: %C!\n"),
                LogAddr(cfg->group_address_, LogAddr::HostPort).c_str()));
     return MulticastDataLink_rch();
   }
 
   return link;
 }

◆ OPENDDS_MAP() [1/2]

typedef OpenDDS::DCPS::MulticastTransport::OPENDDS_MAP	(	MulticastPeer	,
		MulticastDataLink_rch
	)

private

link for pubs.

◆ OPENDDS_MAP() [2/2]

typedef OpenDDS::DCPS::MulticastTransport::OPENDDS_MAP	(	Peers	,
		Callbacks
	)

private

◆ OPENDDS_SET()

OpenDDS::DCPS::MulticastTransport::OPENDDS_SET ( Peers )

private

◆ passive_connection()

void OpenDDS::DCPS::MulticastTransport::passive_connection	(	MulticastPeer	local_peer,
		MulticastPeer	remote_peer
	)

Definition at line 314 of file MulticastTransport.cpp.

References ACE_Guard< ACE_LOCK >::acquire(), config(), connections_lock_, OpenDDS::DCPS::find(), LM_DEBUG, OpenDDS::DCPS::WeakRcHandle< T >::lock(), pending_connections_, ACE_Guard< ACE_LOCK >::release(), server_links_, OpenDDS::DCPS::static_rchandle_cast(), and VDBG_LVL.

 {
   GuardThreadType guard(this->connections_lock_);
 
   MulticastInst_rch cfg = config();
 
   VDBG_LVL((LM_DEBUG, "(%P|%t) MulticastTransport[%C]::passive_connection "
             "from remote peer %#08x%08x to local peer %#08x%08x\n",
             cfg ? cfg->name().c_str() : "",
             (unsigned int) (remote_peer >> 32),
             (unsigned int) remote_peer,
             (unsigned int) (local_peer >> 32),
             (unsigned int) local_peer), 2);
 
   const Peers peers(remote_peer, local_peer);
   const PendConnMap::iterator pend = this->pending_connections_.find(peers);
   //if connection was pending, calls to use_datalink finalized the connection
   //if it was not previously pending, accept_datalink() will finalize connection
 
   this->connections_.insert(peers);
 
   Links::const_iterator server_link = this->server_links_.find(local_peer);
   DataLink_rch link;
 
   if (server_link != this->server_links_.end()) {
     link = static_rchandle_cast<DataLink>(server_link->second);
     MulticastSession_rch session (server_link->second->find_or_create_session(remote_peer));
     session->set_acked();
   }
 
   if (pend != pending_connections_.end()) {
     Callbacks tmp(pend->second);
     for (size_t i = 0; i < tmp.size(); ++i) {
       const PendConnMap::iterator pend = pending_connections_.find(peers);
       if (pend != pending_connections_.end()) {
         const Callbacks::iterator tmp_iter = find(pend->second.begin(),
                                                   pend->second.end(),
                                                   tmp.at(i));
         if (tmp_iter != pend->second.end()) {
           TransportClient_wrch pend_client = tmp.at(i).first;
           GUID_t remote_repo = tmp.at(i).second;
           guard.release();
           TransportClient_rch client = pend_client.lock();
           if (client) {
             client->use_datalink(remote_repo, link);
           }
           guard.acquire();
         }
       }
     }
   }
 }

◆ release_datalink()

void OpenDDS::DCPS::MulticastTransport::release_datalink ( DataLink * link )

protectedvirtual

Called by the TransportRegistry when this TransportImpl object is released while the TransportRegistry is handling a release() "event". The DataLink itself calls this method when it thinks it is no longer used for any associations. This occurs during a "remove associations" operation being performed by some TransportClient that uses this TransportImpl. The TransportClient is known to have acquired our reservation_lock_, so there won't be any reserve_datalink() calls being made from any other threads while we perform this release.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 429 of file MulticastTransport.cpp.

 {
   // No-op for multicast: keep both the client_link_ and server_link_ around
   // until the transport is shut down.
 }

◆ shutdown_i()

void OpenDDS::DCPS::MulticastTransport::shutdown_i ( )

protectedvirtual

Called during the shutdown() method in order to give the concrete TransportImpl subclass a chance to do something when the shutdown "event" occurs.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 393 of file MulticastTransport.cpp.

References client_links_, links_lock_, and server_links_.

 {
   GuardThreadType guard_links(this->links_lock_);
   Links::iterator link;
 
   for (link = this->client_links_.begin();
        link != this->client_links_.end();
        ++link) {
     if (link->second.in()) {
       link->second->transport_shutdown();
     }
   }
   client_links_.clear();
 
   for (link = this->server_links_.begin();
        link != this->server_links_.end();
        ++link) {
     if (link->second.in()) {
       link->second->transport_shutdown();
     }
   }
   server_links_.clear();
 }

◆ start_session()

MulticastSession_rch OpenDDS::DCPS::MulticastTransport::start_session	(	const MulticastDataLink_rch &	link,
		MulticastPeer	remote_peer,
		bool	active
	)

private

Definition at line 90 of file MulticastTransport.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), config(), OpenDDS::DCPS::RcHandle< T >::is_nil(), and LM_ERROR.

Referenced by accept_datalink(), and connect_datalink().

 {
   MulticastInst_rch cfg = config();
 
   if (link.is_nil()) {
     ACE_ERROR_RETURN((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: ")
                       ACE_TEXT("MulticastTransport[%C]::start_session: ")
                       ACE_TEXT("link is nil\n"),
                       cfg ? cfg->name().c_str() : ""),
                      MulticastSession_rch());
   }
 
   MulticastSession_rch session(link->find_or_create_session(remote_peer));
 
   if (session.is_nil()) {
     ACE_ERROR_RETURN((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: ")
                       ACE_TEXT("MulticastTransport[%C]::start_session: ")
                       ACE_TEXT("failed to create session for remote peer: %#08x%08x!\n"),
                       cfg ? cfg->name().c_str() : "",
                       (unsigned int)(remote_peer >> 32),
                       (unsigned int) remote_peer),
                      MulticastSession_rch());
   }
 
   const bool acked = this->connections_.count(std::make_pair(remote_peer, link->local_peer()));
 
   if (!session->start(active, acked)) {
     ACE_ERROR_RETURN((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: ")
                       ACE_TEXT("MulticastTransport[%C]::start_session: ")
                       ACE_TEXT("failed to start session for remote peer: %#08x%08x!\n"),
                       cfg ? cfg->name().c_str() : "",
                       (unsigned int)(remote_peer >> 32),
                       (unsigned int) remote_peer),
                      MulticastSession_rch());
   }
 
   return session;
 }

◆ stop_accepting_or_connecting()

void OpenDDS::DCPS::MulticastTransport::stop_accepting_or_connecting	(	const TransportClient_wrch &	client,
		const GUID_t &	remote_id,
		bool	disassociate,
		bool	association_failed
	)

protectedvirtual

stop_accepting_or_connecting() is called from TransportClient to terminate the accepting process begun by accept_datalink() or connect_datalink(). This allows the TransportImpl to clean up any resources associated with this pending connection. The TransportClient* passed in to accept or connect is not valid after this method is called.

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 286 of file MulticastTransport.cpp.

References connections_lock_, LM_DEBUG, pending_connections_, and VDBG.

 {
   VDBG((LM_DEBUG, "(%P|%t) MulticastTransport::stop_accepting_or_connecting\n"));
 
   GuardThreadType guard(this->connections_lock_);
 
   for (PendConnMap::iterator it = this->pending_connections_.begin();
        it != this->pending_connections_.end(); ++it) {
     bool erased_from_it = false;
     for (size_t i = 0; i < it->second.size(); ++i) {
       if (it->second[i].first == client && it->second[i].second == remote_id) {
         erased_from_it = true;
         it->second.erase(it->second.begin() + i);
         break;
       }
     }
 
     if (erased_from_it && it->second.empty()) {
       this->pending_connections_.erase(it);
       return;
     }
   }
 }

◆ transport_type()

virtual std::string OpenDDS::DCPS::MulticastTransport::transport_type ( ) const

inlineprotectedvirtual

Implements OpenDDS::DCPS::TransportImpl.

Definition at line 59 of file MulticastTransport.h.

59 { return "multicast"; }

Member Data Documentation

◆ client_links_

Links OpenDDS::DCPS::MulticastTransport::client_links_

private

Definition at line 81 of file MulticastTransport.h.

Referenced by client_stop(), connect_datalink(), and shutdown_i().

◆ connections_lock_

ThreadLockType OpenDDS::DCPS::MulticastTransport::connections_lock_

private

Definition at line 91 of file MulticastTransport.h.

Referenced by accept_datalink(), passive_connection(), and stop_accepting_or_connecting().

◆ links_lock_

ThreadLockType OpenDDS::DCPS::MulticastTransport::links_lock_

private

Definition at line 78 of file MulticastTransport.h.

Referenced by accept_datalink(), client_stop(), connect_datalink(), and shutdown_i().

◆ pending_connections_

PendConnMap OpenDDS::DCPS::MulticastTransport::pending_connections_

private

Definition at line 95 of file MulticastTransport.h.

Referenced by accept_datalink(), passive_connection(), and stop_accepting_or_connecting().

◆ server_links_

Links OpenDDS::DCPS::MulticastTransport::server_links_

private

link for subs.

Definition at line 83 of file MulticastTransport.h.

Referenced by accept_datalink(), passive_connection(), and shutdown_i().

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

Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Callbacks

◆ GuardThreadType

◆ GuardType

◆ LockType

◆ Peers

◆ ThreadLockType

Constructor & Destructor Documentation

◆ MulticastTransport()

◆ ~MulticastTransport()

Member Function Documentation

◆ accept_datalink()

◆ client_stop()

◆ config()

◆ configure_i()

◆ connect_datalink()

◆ connection_info_i()

◆ make_datalink()

◆ OPENDDS_MAP() [1/2]

◆ OPENDDS_MAP() [2/2]

◆ OPENDDS_SET()

◆ passive_connection()

◆ release_datalink()

◆ shutdown_i()

◆ start_session()

◆ stop_accepting_or_connecting()

◆ transport_type()

Member Data Documentation

◆ client_links_

◆ connections_lock_

◆ links_lock_

◆ pending_connections_

◆ server_links_