OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand Class Reference

Inheritance diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand:

[legend]Collaboration diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand:

[legend]List of all members.

Public Member Functions
	ScheduleCommand (EndHistoricSamplesMissedSweeper *sweeper, OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &info)
virtual void	execute ()

---

Detailed Description

Definition at line 152 of file DataReaderImpl.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand::ScheduleCommand	(	EndHistoricSamplesMissedSweeper *	sweeper,
		OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &	info
	)			[inline]

Definition at line 154 of file DataReaderImpl.h.

      : CommandBase(sweeper, info)
    { }

---

Member Function Documentation

void OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand::execute

(

)

[virtual]

Definition at line 3426 of file DataReaderImpl.cpp.

References OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::RcHandle< T >::in(), OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CommandBase::info_, OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::schedule_timer(), and OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CommandBase::sweeper_.

{
  static const ACE_Time_Value ten_seconds(10);

  //Pass pointer to writer info for timer to use, must decrease ref count when canceling timer
  const void* arg = reinterpret_cast<const void*>(info_.in());
  info_->_add_ref();

  info_->historic_samples_timer_ = sweeper_->reactor()->schedule_timer(sweeper_,
                                                                       arg,
                                                                       ten_seconds);
  if (DCPS_debug_level) {
    ACE_DEBUG((LM_INFO, "(%P|%t) EndHistoricSamplesMissedSweeper::ScheduleCommand::execute() - Scheduled sweeper %d\n", info_->historic_samples_timer_));
  }
}

---

The documentation for this class was generated from the following files:

• DataReaderImpl.h
• DataReaderImpl.cpp

---