#include <DataReaderImpl.h>
Inheritance diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper:
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 ¤t_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 |
Definition at line 117 of file DataReaderImpl.h.
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] |
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 }