Public Member Functions | |
ScheduleCommand (RemoveAssociationSweeper< T > *sweeper, OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &info) | |
virtual void | execute () |
Definition at line 63 of file RemoveAssociationSweeper.h.
OpenDDS::DCPS::RemoveAssociationSweeper< T >::ScheduleCommand::ScheduleCommand | ( | RemoveAssociationSweeper< T > * | sweeper, | |
OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > & | info | |||
) | [inline] |
Definition at line 65 of file RemoveAssociationSweeper.h.
00067 : CommandBase(sweeper, info) 00068 { }
void OpenDDS::DCPS::RemoveAssociationSweeper< T >::ScheduleCommand::execute | ( | ) | [virtual] |
Definition at line 134 of file RemoveAssociationSweeper.h.
References OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::RcHandle< T >::in(), OpenDDS::DCPS::RemoveAssociationSweeper< T >::CommandBase::info_, and OpenDDS::DCPS::RemoveAssociationSweeper< T >::CommandBase::sweeper_.
00135 { 00136 static const ACE_Time_Value two_seconds(2); 00137 00138 //Pass pointer to writer info for timer to use, must decrease ref count when canceling timer 00139 const void* arg = reinterpret_cast<const void*>(this->info_.in()); 00140 this->info_->_add_ref(); 00141 00142 this->info_->remove_association_timer_ = this->sweeper_->reactor()->schedule_timer(this->sweeper_, 00143 arg, 00144 two_seconds); 00145 if (DCPS_debug_level) { 00146 ACE_DEBUG((LM_INFO, "(%P|%t) RemoveAssociationSweeper::ScheduleCommand::execute() - Scheduled sweeper %d\n", this->info_->remove_association_timer_)); 00147 } 00148 }