Inheritance diagram for OpenDDS::DCPS::TransportClient::PendingAssoc:

[legend]

Collaboration diagram for OpenDDS::DCPS::TransportClient::PendingAssoc:

[legend]

Public Member Functions
	PendingAssoc (RcHandle< TransportClient > tc_rch)

void	reset_client ()

bool	safe_to_remove ()

bool	initiate_connect (TransportClient *tc, Guard &guard)

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

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_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_exit (ACE_Process *)

virtual int	handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)

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

Public Attributes
ACE_Thread_Mutex	mutex_

bool	active_

bool	scheduled_

ImplsType	impls_

CORBA::ULong	blob_index_

AssociationData	data_

TransportImpl::ConnectionAttribs	attribs_

WeakRcHandle< TransportClient >	client_

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

Additional Inherited Members
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)

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

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 inherited from ACE_Event_Handler
Atomic_Reference_Count	reference_count_

Detailed Description

Definition at line 200 of file TransportClient.h.

Constructor & Destructor Documentation

◆ PendingAssoc()

OpenDDS::DCPS::TransportClient::PendingAssoc::PendingAssoc ( RcHandle< TransportClient > tc_rch )

inlineexplicit

Definition at line 209 of file TransportClient.h.

References time().

       : active_(false)
       , scheduled_(false)
       , blob_index_(0)
       , client_(tc_rch)
     {}

Member Function Documentation

◆ handle_timeout()

int OpenDDS::DCPS::TransportClient::PendingAssoc::handle_timeout	(	const ACE_Time_Value &	time,
		const void *	arg
	)

virtual

Reimplemented from ACE_Event_Handler.

Definition at line 365 of file TransportClient.cpp.

References TheServiceParticipant.

 {
   ThreadStatusManager::Event ev(TheServiceParticipant->get_thread_status_manager());
 
   RcHandle<TransportClient> client;
   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     client = client_.lock();
     scheduled_ = false;
   }
 
   if (client && client.get() == static_cast<TransportClient*>(const_cast<void*>(arg))) {
     client->use_datalink(data_.remote_id_, DataLink_rch());
   }
   return 0;
 }

◆ initiate_connect()

bool OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect	(	TransportClient *	tc,
		Guard &	guard
	)

Definition at line 439 of file TransportClient.cpp.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

 {
   LogGuid local_log(tc->repo_id_);
   LogGuid remote_log(data_.remote_id_);
   VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::initiate_connect - "
                       "between %C and remote %C\n",
                       local_log.c_str(),
                       remote_log.c_str()), 0);
   // find the next impl / blob entry that have matching types
   while (!impls_.empty()) {
     TransportImpl_rch impl = impls_.back().lock();
     if (!impl) {
       impls_.pop_back();
       continue;
     }
     const OPENDDS_STRING type = impl->transport_type();
 
     for (; blob_index_ < data_.remote_data_.length(); ++blob_index_) {
       if (data_.remote_data_[blob_index_].transport_type.in() == type) {
         const TransportImpl::RemoteTransport remote_transport = {
           data_.remote_id_, data_.remote_data_[blob_index_].data, data_.discovery_locator_.data,
           data_.participant_discovered_at_, data_.remote_transport_context_,
           data_.publication_transport_priority_, data_.remote_reliable_, data_.remote_durable_};
 
         TransportImpl::AcceptConnectResult res;
         bool ret;
         {
           // Release the PendingAssoc object's mutex_ since initiate_connect_i doesn't need it.
           Reverse_Lock_t rev_mutex(mutex_);
           ACE_GUARD_RETURN(Reverse_Lock_t, rev_pend_guard, rev_mutex, false);
           ret = tc->initiate_connect_i(res, impl, remote_transport, attribs_, guard);
         }
         if (!ret) {
           //tc init connect returned false there is no PendingAssoc left in map because use_datalink_i finished elsewhere
           //so don't do anything further with pend and return success or failure up to tc's associate
           if (res.success_ ) {
             VDBG_LVL((LM_DEBUG, ACE_TEXT("(%P|%t) PendingAssoc::initiate_connect - ")
                                 ACE_TEXT("between %C and remote %C success\n"),
                                 local_log.c_str(),
                                 remote_log.c_str()), 0);
             return true;
           }
 
           VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::initiate_connect - "
                               "between %C and remote %C unsuccessful\n",
                               local_log.c_str(),
                               remote_log.c_str()), 0);
         }
 
         if (res.success_) {
 
           ++blob_index_;
 
           if (!res.link_.is_nil()) {
 
             {
               // use_datalink_i calls PendingAssoc::reset_client which needs the PendingAssoc's mutex_.
               Reverse_Lock_t rev_mutex(mutex_);
               ACE_GUARD_RETURN(Reverse_Lock_t, rev_pend_guard, rev_mutex, false);
               tc->use_datalink_i(data_.remote_id_, res.link_, guard);
             }
           } else {
             VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::intiate_connect - "
                                 "resulting link from initiate_connect_i (local: %C to remote: %C) was nil\n",
                                 local_log.c_str(),
                                 remote_log.c_str()), 0);
           }
 
           return true;
         } else {
           VDBG_LVL((LM_DEBUG, "(%P|%t) PendingAssoc::intiate_connect - "
                               "result of initiate_connect_i (local: %C to remote: %C) was not success\n",
                               local_log.c_str(),
                               remote_log.c_str()), 0);
         }
       }
     }
 
     impls_.pop_back();
     blob_index_ = 0;
   }
 
   return false;
 }

◆ reset_client()

void OpenDDS::DCPS::TransportClient::PendingAssoc::reset_client ( )

Definition at line 353 of file TransportClient.cpp.

Referenced by OpenDDS::DCPS::TransportClient::use_datalink_i().

                                           {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   client_.reset();
 }

◆ safe_to_remove()

bool OpenDDS::DCPS::TransportClient::PendingAssoc::safe_to_remove ( )

Definition at line 359 of file TransportClient.cpp.

                                             {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   return !client_ && !scheduled_;
 }

Member Data Documentation

◆ active_

bool OpenDDS::DCPS::TransportClient::PendingAssoc::active_

Definition at line 202 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

◆ attribs_

TransportImpl::ConnectionAttribs OpenDDS::DCPS::TransportClient::PendingAssoc::attribs_

Definition at line 206 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate().

◆ blob_index_

CORBA::ULong OpenDDS::DCPS::TransportClient::PendingAssoc::blob_index_

Definition at line 204 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate().

◆ client_

WeakRcHandle<TransportClient> OpenDDS::DCPS::TransportClient::PendingAssoc::client_

Definition at line 207 of file TransportClient.h.

◆ data_

AssociationData OpenDDS::DCPS::TransportClient::PendingAssoc::data_

Definition at line 205 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

◆ impls_

ImplsType OpenDDS::DCPS::TransportClient::PendingAssoc::impls_

Definition at line 203 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

◆ mutex_

ACE_Thread_Mutex OpenDDS::DCPS::TransportClient::PendingAssoc::mutex_

Definition at line 201 of file TransportClient.h.

Referenced by OpenDDS::DCPS::TransportClient::associate(), and OpenDDS::DCPS::TransportClient::use_datalink_i().

◆ scheduled_

bool OpenDDS::DCPS::TransportClient::PendingAssoc::scheduled_

Definition at line 202 of file TransportClient.h.

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

Public Member Functions

Public Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ PendingAssoc()

Member Function Documentation

◆ handle_timeout()

◆ initiate_connect()

◆ reset_client()

◆ safe_to_remove()

Member Data Documentation

◆ active_

◆ attribs_

◆ blob_index_

◆ client_

◆ data_

◆ impls_

◆ mutex_

◆ scheduled_