Public Member Functions | |
CancelCommand (EndHistoricSamplesMissedSweeper *sweeper, OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &info) | |
virtual void | execute () |
Definition at line 168 of file DataReaderImpl.h.
OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CancelCommand::CancelCommand | ( | EndHistoricSamplesMissedSweeper * | sweeper, | |
OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > & | info | |||
) | [inline] |
Definition at line 170 of file DataReaderImpl.h.
00172 : CommandBase(sweeper, info) 00173 { }
void OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CancelCommand::execute | ( | void | ) | [virtual] |
Implements OpenDDS::DCPS::ReactorInterceptor::Command.
Definition at line 3398 of file DataReaderImpl.cpp.
References OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CommandBase::info_, LM_INFO, OpenDDS::DCPS::WriterInfo::NO_TIMER, ACE_Event_Handler::reactor(), and OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CommandBase::sweeper_.
03399 { 03400 if (info_->historic_samples_timer_ != WriterInfo::NO_TIMER) { 03401 sweeper_->reactor()->cancel_timer(info_->historic_samples_timer_); 03402 if (DCPS_debug_level) { 03403 ACE_DEBUG((LM_INFO, "(%P|%t) EndHistoricSamplesMissedSweeper::CancelCommand::execute() - Unscheduled sweeper %d\n", info_->historic_samples_timer_)); 03404 } 03405 info_->historic_samples_timer_ = WriterInfo::NO_TIMER; 03406 sweeper_->info_set_.erase(info_); 03407 } 03408 }