OpenDDS::DCPS::EndHistoricSamplesMissedSweeper Class Reference

#include <DataReaderImpl.h>

Inheritance diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper:

[legend]

Collaboration diagram for OpenDDS::DCPS::EndHistoricSamplesMissedSweeper:

[legend]

List of all members.

Classes
class	CancelCommand
class	CommandBase
class	ScheduleCommand
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 ()
	OPENDDS_SET (RcHandle< OpenDDS::DCPS::WriterInfo >) info_set_
Private Attributes
WeakRcHandle< DataReaderImpl >	reader_

---

Detailed Description

Definition at line 123 of file DataReaderImpl.h.

---

Constructor & Destructor Documentation

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

Definition at line 3329 of file DataReaderImpl.cpp.

  : ReactorInterceptor (reactor, owner)
  , reader_(*reader)
{ }

OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::~EndHistoricSamplesMissedSweeper

(

)

[private]

Definition at line 3336 of file DataReaderImpl.cpp.

{ }

---

Member Function Documentation

void OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::cancel_timer

(

OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &

info

)

Definition at line 3346 of file DataReaderImpl.cpp.

References c, and OpenDDS::DCPS::ReactorInterceptor::execute_or_enqueue().

{
  info->waiting_for_end_historic_samples_ = false;
  CancelCommand c(this, info);
  execute_or_enqueue(c);
}

Here is the call graph for this function:

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

Reimplemented from ACE_Event_Handler.

Definition at line 3353 of file DataReaderImpl.cpp.

References OpenDDS::DCPS::DCPS_debug_level, LM_INFO, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::DCPS::ReactorInterceptor::mutex_, OPENDDS_STRING, OpenDDS::DCPS::rchandle_from(), reader_, and OpenDDS::DCPS::WriterInfo::writer_id_.

{

  WriterInfo* const info =
    const_cast<WriterInfo*>(reinterpret_cast<const WriterInfo*>(arg));
  const PublicationId pub_id = info->writer_id_;

  {
    ACE_Guard<ACE_Thread_Mutex> guard(this->mutex_);
    info_set_.erase(rchandle_from(info));
  }

  RcHandle<DataReaderImpl> reader = reader_.lock();
  if (!reader)
    return 0;

  if (DCPS_debug_level >= 1) {
    GuidConverter sub_repo(reader->get_repo_id());
    GuidConverter pub_repo(pub_id);
    ACE_DEBUG((LM_INFO, "(%P|%t) EndHistoricSamplesMissedSweeper::handle_timeout reader: %C waiting on writer: %C\n",
               OPENDDS_STRING(sub_repo).c_str(),
               OPENDDS_STRING(pub_repo).c_str()));
  }

  reader->resume_sample_processing(pub_id);
  return 0;
}

Here is the call graph for this function:

OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::OPENDDS_SET

(

RcHandle< OpenDDS::DCPS::WriterInfo >

)

[private]

virtual bool OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::reactor_is_shut_down

(

)

const [inline, virtual]

Implements OpenDDS::DCPS::ReactorInterceptor.

Definition at line 135 of file DataReaderImpl.h.

References TheServiceParticipant.

  {
    return TheServiceParticipant->is_shut_down();
  }

void OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::schedule_timer

(

OpenDDS::DCPS::RcHandle< OpenDDS::DCPS::WriterInfo > &

info

)

Definition at line 3339 of file DataReaderImpl.cpp.

References c, and OpenDDS::DCPS::ReactorInterceptor::execute_or_enqueue().

{
  info->waiting_for_end_historic_samples_ = true;
  ScheduleCommand c(this, info);
  execute_or_enqueue(c);
}

Here is the call graph for this function:

---

Member Data Documentation

WeakRcHandle<DataReaderImpl> OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::reader_ [private]

Definition at line 143 of file DataReaderImpl.h.

Referenced by handle_timeout().

---

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

• DataReaderImpl.h
• DataReaderImpl.cpp