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 159 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 161 of file DataReaderImpl.h.

      : CommandBase(sweeper, info)
    { }

---

Member Function Documentation

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

(

void

)

[virtual]

Implements OpenDDS::DCPS::ReactorInterceptor::Command.

Definition at line 3383 of file DataReaderImpl.cpp.

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

{
  static const ACE_Time_Value ten_seconds(10);

  const void* arg = reinterpret_cast<const void*>(info_.in());

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

Here is the call graph for this function:

---

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

• DataReaderImpl.h
• DataReaderImpl.cpp