OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders Class Reference

#include <DataReaderImpl.h>

Inheritance diagram for OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders:

Collaboration diagram for OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders:

Public Member Functions
	OnDataOnReaders (WeakRcHandle< SubscriberImpl > subscriber, DDS::SubscriberListener_var sub_listener, WeakRcHandle< DataReaderImpl > data_reader, bool call, bool set_reader_status)
Public Member Functions inherited from OpenDDS::DCPS::Job
virtual	~Job ()
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

Private Member Functions
virtual void	execute ()

Private Attributes
WeakRcHandle< SubscriberImpl >	subscriber_
DDS::SubscriberListener_var	sub_listener_
WeakRcHandle< DataReaderImpl >	data_reader_
const bool	call_
const bool	set_reader_status_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 1054 of file DataReaderImpl.h.

Constructor & Destructor Documentation

OnDataOnReaders()

OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders::OnDataOnReaders ( WeakRcHandle< SubscriberImpl >  subscriber, DDS::SubscriberListener_var  sub_listener, WeakRcHandle< DataReaderImpl >  data_reader, bool  call, bool  set_reader_status  )

inline

Definition at line 1056 of file DataReaderImpl.h.

      : subscriber_(subscriber)
      , sub_listener_(sub_listener)
      , data_reader_(data_reader)
      , call_(call)
      , set_reader_status_(set_reader_status)
    {}

Member Function Documentation

execute()

void OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders::execute ( void  )

privatevirtual

Implements OpenDDS::DCPS::Job.

Definition at line 3495 of file DataReaderImpl.cpp.

References DDS::DATA_AVAILABLE_STATUS, DDS::DATA_ON_READERS_STATUS, and OpenDDS::DCPS::RcHandle< T >::in().

{
  RcHandle<SubscriberImpl> subscriber = subscriber_.lock();
  RcHandle<DataReaderImpl> data_reader = data_reader_.lock();
  if (!subscriber || !data_reader) {
    return;
  }

  if (set_reader_status_) {
    data_reader->set_status_changed_flag(::DDS::DATA_AVAILABLE_STATUS, false);
  }
  subscriber->set_status_changed_flag(::DDS::DATA_ON_READERS_STATUS, false);

  if (call_) {
    sub_listener_->on_data_on_readers(subscriber.in());
  }
}

Member Data Documentation

call_

const bool OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders::call_

private

Definition at line 1074 of file DataReaderImpl.h.

data_reader_

WeakRcHandle<DataReaderImpl> OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders::data_reader_

private

Definition at line 1073 of file DataReaderImpl.h.

set_reader_status_

const bool OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders::set_reader_status_

private

Definition at line 1075 of file DataReaderImpl.h.

sub_listener_

DDS::SubscriberListener_var OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders::sub_listener_

private

Definition at line 1072 of file DataReaderImpl.h.

subscriber_

WeakRcHandle<SubscriberImpl> OpenDDS::DCPS::DataReaderImpl::OnDataOnReaders::subscriber_

private

Definition at line 1071 of file DataReaderImpl.h.

---

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

• DataReaderImpl.h
• DataReaderImpl.cpp