OpenDDS::DCPS::EndHistoricSamplesMissedSweeper

OpenDDS::DCPS::EndHistoricSamplesMissedSweeper Class Reference

#include <DataReaderImpl.h>

Inheritance diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper:

Inheritance graph
[legend]
Collaboration diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 EndHistoricSamplesMissedSweeper (ACE_Reactor *reactor, ACE_thread_t owner, DataReaderImpl *reader)
void schedule_timer (OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &info)
void cancel_timer (OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &info)
int handle_timeout (const ACE_Time_Value &current_time, const void *arg)
virtual bool reactor_is_shut_down () const

Private Member Functions

 ~EndHistoricSamplesMissedSweeper ()

Private Attributes

DataReaderImpl * reader_

Classes

class  CancelCommand
class  CommandBase
class  ScheduleCommand

Detailed Description

Definition at line 117 of file DataReaderImpl.h.

Constructor & Destructor Documentation

OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::EndHistoricSamplesMissedSweeper ( ACE_Reactor *  reactor,
ACE_thread_t  owner,
DataReaderImpl *  reader 
)

Definition at line 3384 of file DataReaderImpl.cpp.

03387   : ReactorInterceptor (reactor, owner)
03388   , reader_(reader)
03389 { }

OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::~EndHistoricSamplesMissedSweeper (  )  [private]

Definition at line 3391 of file DataReaderImpl.cpp.

03392 { }

Member Function Documentation

void OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::cancel_timer ( OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &  info  ) 

Definition at line 3401 of file DataReaderImpl.cpp.

References OpenDDS::DCPS::ReactorInterceptor::execute_or_enqueue().

Referenced by OpenDDS::DCPS::DataReaderImpl::cleanup(), OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::CancelCommand::execute(), OpenDDS::DCPS::DataReaderImpl::remove_associations_i(), OpenDDS::DCPS::DataReaderImpl::resume_sample_processing(), and OpenDDS::DCPS::DataReaderImpl::~DataReaderImpl().

03402 {
03403   info->waiting_for_end_historic_samples_ = false;
03404   CancelCommand c(this, info);
03405   execute_or_enqueue(c);
03406 }

int OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::handle_timeout ( const ACE_Time_Value &  current_time,
const void *  arg 
)

Definition at line 3408 of file DataReaderImpl.cpp.

References OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DataReaderImpl::get_repo_id(), OPENDDS_STRING, reader_, and OpenDDS::DCPS::DataReaderImpl::resume_sample_processing().

03411 {
03412   PublicationId pub_id = reinterpret_cast<const WriterInfo*>(arg)->writer_id_;
03413 
03414   if (DCPS_debug_level >= 1) {
03415     GuidConverter sub_repo(reader_->get_repo_id());
03416     GuidConverter pub_repo(pub_id);
03417     ACE_DEBUG((LM_INFO, "(%P|%t) EndHistoricSamplesMissedSweeper::handle_timeout reader: %C waiting on writer: %C\n",
03418                OPENDDS_STRING(sub_repo).c_str(),
03419                OPENDDS_STRING(pub_repo).c_str()));
03420   }
03421 
03422   reader_->resume_sample_processing(pub_id);
03423   return 0;
03424 }

virtual bool OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::reactor_is_shut_down (  )  const [inline, virtual]

Implements OpenDDS::DCPS::ReactorInterceptor.

Definition at line 129 of file DataReaderImpl.h.

References TheServiceParticipant.

00130   {
00131     return TheServiceParticipant->is_shut_down();
00132   }

void OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::schedule_timer ( OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &  info  ) 

Definition at line 3394 of file DataReaderImpl.cpp.

References OpenDDS::DCPS::ReactorInterceptor::execute_or_enqueue().

Referenced by OpenDDS::DCPS::DataReaderImpl::add_link(), and OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::ScheduleCommand::execute().

03395 {
03396   info->waiting_for_end_historic_samples_ = true;
03397   ScheduleCommand c(this, info);
03398   execute_or_enqueue(c);
03399 }

Member Data Documentation

DataReaderImpl* OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::reader_ [private]

Definition at line 137 of file DataReaderImpl.h.

Referenced by handle_timeout().

The documentation for this class was generated from the following files:
Generated on Fri Feb 12 20:06:11 2016 for OpenDDS by  doxygen 1.4.7