Public Member Functions | |
PendingAssocTimer (ACE_Reactor *reactor, ACE_thread_t owner) | |
void | schedule_timer (TransportClient *transport_client, PendingAssoc *pend) |
void | cancel_timer (TransportClient *transport_client, PendingAssoc *pend) |
void | delete_pending_assoc (PendingAssoc *pend) |
virtual bool | reactor_is_shut_down () const |
Private Member Functions | |
~PendingAssocTimer () | |
Classes | |
struct | CancelCommand |
class | CommandBase |
struct | DeleteCommand |
struct | ScheduleCommand |
Definition at line 184 of file TransportClient.h.
OpenDDS::DCPS::TransportClient::PendingAssocTimer::PendingAssocTimer | ( | ACE_Reactor * | reactor, | |
ACE_thread_t | owner | |||
) | [inline] |
Definition at line 186 of file TransportClient.h.
00188 : ReactorInterceptor(reactor, owner) 00189 { }
OpenDDS::DCPS::TransportClient::PendingAssocTimer::~PendingAssocTimer | ( | ) | [inline, private] |
void OpenDDS::DCPS::TransportClient::PendingAssocTimer::cancel_timer | ( | TransportClient * | transport_client, | |
PendingAssoc * | pend | |||
) | [inline] |
Definition at line 197 of file TransportClient.h.
Referenced by OpenDDS::DCPS::TransportClient::use_datalink_i(), and OpenDDS::DCPS::TransportClient::~TransportClient().
00198 { 00199 CancelCommand c(this, transport_client, pend); 00200 execute_or_enqueue(c); 00201 }
void OpenDDS::DCPS::TransportClient::PendingAssocTimer::delete_pending_assoc | ( | PendingAssoc * | pend | ) | [inline] |
Definition at line 203 of file TransportClient.h.
Referenced by OpenDDS::DCPS::TransportClient::use_datalink_i().
00204 { 00205 DeleteCommand c(pend); 00206 // Always defer. 00207 enqueue(c); 00208 }
virtual bool OpenDDS::DCPS::TransportClient::PendingAssocTimer::reactor_is_shut_down | ( | ) | const [inline, virtual] |
Implements OpenDDS::DCPS::ReactorInterceptor.
Definition at line 210 of file TransportClient.h.
References TheServiceParticipant.
00211 { 00212 return TheServiceParticipant->is_shut_down(); 00213 }
void OpenDDS::DCPS::TransportClient::PendingAssocTimer::schedule_timer | ( | TransportClient * | transport_client, | |
PendingAssoc * | pend | |||
) | [inline] |
Definition at line 191 of file TransportClient.h.
Referenced by OpenDDS::DCPS::TransportClient::associate().
00192 { 00193 ScheduleCommand c(this, transport_client, pend); 00194 execute_or_enqueue(c); 00195 }