OpenDDS::DCPS::TransportClient::PendingAssocTimer::ScheduleCommand Struct Reference

Inheritance diagram for OpenDDS::DCPS::TransportClient::PendingAssocTimer::ScheduleCommand:

Collaboration diagram for OpenDDS::DCPS::TransportClient::PendingAssocTimer::ScheduleCommand:

Public Member Functions
	ScheduleCommand (PendingAssocTimer *timer, TransportClient_rch transport_client, const PendingAssoc_rch &assoc)
virtual void	execute ()
Public Member Functions inherited from OpenDDS::DCPS::TransportClient::PendingAssocTimer::CommandBase
	CommandBase (PendingAssocTimer *timer, const PendingAssoc_rch &assoc)
Public Member Functions inherited from OpenDDS::DCPS::ReactorInterceptor::Command
	Command ()
virtual	~Command ()
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
WeakRcHandle< TransportClient >	transport_client_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::ReactorInterceptor::Command
const ACE_Reactor *	reactor () const
ACE_Reactor *	reactor ()
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()
Protected Attributes inherited from OpenDDS::DCPS::TransportClient::PendingAssocTimer::CommandBase
PendingAssocTimer *	timer_
PendingAssoc_rch	assoc_

Detailed Description

Definition at line 270 of file TransportClient.h.

Constructor & Destructor Documentation

ScheduleCommand()

OpenDDS::DCPS::TransportClient::PendingAssocTimer::ScheduleCommand::ScheduleCommand ( PendingAssocTimer *  timer, TransportClient_rch  transport_client, const PendingAssoc_rch &  assoc  )

inline

Definition at line 271 of file TransportClient.h.

        : CommandBase (timer, assoc)
        , transport_client_ (transport_client)
      { }

Member Function Documentation

execute()

virtual void OpenDDS::DCPS::TransportClient::PendingAssocTimer::ScheduleCommand::execute ( void  )

inlinevirtual

Implements OpenDDS::DCPS::ReactorInterceptor::Command.

Definition at line 277 of file TransportClient.h.

References OpenDDS::DCPS::RcHandle< T >::in().

      {
        if (timer_->reactor()) {
          TransportClient_rch client = transport_client_.lock();
          if (client) {
            ACE_Guard<ACE_Thread_Mutex> guard(assoc_->mutex_);
            assoc_->scheduled_ = true;
            long id = timer_->reactor()->schedule_timer(assoc_.in(),
                                                        client.in(),
                                                        client->passive_connect_duration_.value());
            if (id != -1) {
              timer_->set_id(id);
            }
          }
        }
      }

Member Data Documentation

transport_client_

WeakRcHandle<TransportClient> OpenDDS::DCPS::TransportClient::PendingAssocTimer::ScheduleCommand::transport_client_

Definition at line 293 of file TransportClient.h.

---

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

• TransportClient.h