Public Member Functions | |
ScheduleCommand (RemoveAssociationSweeper< T > *sweeper, RcHandle< WriterInfo > info) | |
virtual void | execute () |
Definition at line 69 of file RemoveAssociationSweeper.h.
OpenDDS::DCPS::RemoveAssociationSweeper< T >::ScheduleCommand::ScheduleCommand | ( | RemoveAssociationSweeper< T > * | sweeper, | |
RcHandle< WriterInfo > | info | |||
) | [inline] |
Definition at line 71 of file RemoveAssociationSweeper.h.
00073 : CommandBase(sweeper, info) 00074 { }
void OpenDDS::DCPS::RemoveAssociationSweeper< T >::ScheduleCommand::execute | ( | void | ) | [inline, virtual] |
Definition at line 181 of file RemoveAssociationSweeper.h.
References OpenDDS::DCPS::DCPS_debug_level, ACE_OS::gettimeofday(), OpenDDS::DCPS::RcHandle< T >::in(), OpenDDS::DCPS::RemoveAssociationSweeper< T >::CommandBase::info_, LM_INFO, and OpenDDS::DCPS::RemoveAssociationSweeper< T >::CommandBase::sweeper_.
00182 { 00183 //Pass pointer to writer info for timer to use, must decrease ref count when canceling timer 00184 const void* arg = reinterpret_cast<const void*>(this->info_.in()); 00185 this->sweeper_->info_set_.push_back(this->info_); 00186 00187 this->info_->remove_association_timer_ = this->sweeper_->reactor()->schedule_timer(this->sweeper_, 00188 arg, 00189 this->info_->removal_deadline_ - ACE_OS::gettimeofday()); 00190 if (DCPS_debug_level) { 00191 ACE_DEBUG((LM_INFO, "(%P|%t) RemoveAssociationSweeper::ScheduleCommand::execute() - Scheduled sweeper %d\n", this->info_->remove_association_timer_)); 00192 } 00193 }