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

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

Collaboration diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand:

Public Member Functions
	ScheduleCommand (EndHistoricSamplesMissedSweeper *sweeper, WriterInfo_rch &info)
virtual void	execute ()
Public Member Functions inherited from OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CommandBase
	CommandBase (EndHistoricSamplesMissedSweeper *sweeper, WriterInfo_rch &info)
Public Member Functions inherited from OpenDDS::DCPS::ReactorInterceptor::Command
	Command ()
virtual	~Command ()
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
long	ref_count () const
WeakObject *	_get_weak_object () const

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::ReactorInterceptor::Command
const ACE_Reactor *	reactor () const
ACE_Reactor *	reactor ()
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()
Protected Attributes inherited from OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CommandBase
EndHistoricSamplesMissedSweeper *	sweeper_
WriterInfo_rch	info_

Detailed Description

Definition at line 162 of file DataReaderImpl.h.

Constructor & Destructor Documentation

ScheduleCommand()

OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand::ScheduleCommand ( EndHistoricSamplesMissedSweeper *  sweeper, WriterInfo_rch &  info  )

inline

Definition at line 164 of file DataReaderImpl.h.

      : CommandBase(sweeper, info)
    { }

Member Function Documentation

execute()

void OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand::execute ( void  )

virtual

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

Definition at line 3462 of file DataReaderImpl.cpp.

References ACE_DEBUG, OpenDDS::DCPS::DCPS_debug_level, and LM_INFO.

{
  static const ACE_Time_Value ten_seconds(10);
  info_->schedule_historic_samples_timer(sweeper_, ten_seconds);
  const bool insert_result = sweeper_->info_set_.insert(info_).second;

  if (insert_result && DCPS_debug_level) {
    ACE_DEBUG((LM_INFO, "(%P|%t) EndHistoricSamplesMissedSweeper::ScheduleCommand::execute() - sweeper %@ is now scheduled\n", info_.in()));
  }
}

---

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

• DataReaderImpl.h
• DataReaderImpl.cpp