OpenDDS::DCPS::BitPubListenerImpl Class Reference

#include <BitPubListenerImpl.h>

Inheritance diagram for OpenDDS::DCPS::BitPubListenerImpl:

[legend]Collaboration diagram for OpenDDS::DCPS::BitPubListenerImpl:

[legend]List of all members.

Public Member Functions
	BitPubListenerImpl (DomainParticipantImpl *partipant)
virtual	~BitPubListenerImpl ()
virtual void	on_requested_deadline_missed (DDS::DataReader_ptr reader, const DDS::RequestedDeadlineMissedStatus &status)
virtual void	on_requested_incompatible_qos (DDS::DataReader_ptr reader, const DDS::RequestedIncompatibleQosStatus &status)
virtual void	on_liveliness_changed (DDS::DataReader_ptr reader, const DDS::LivelinessChangedStatus &status)
virtual void	on_subscription_matched (DDS::DataReader_ptr reader, const DDS::SubscriptionMatchedStatus &status)
virtual void	on_sample_rejected (DDS::DataReader_ptr reader, const DDS::SampleRejectedStatus &status)
virtual void	on_data_available (DDS::DataReader_ptr reader)
virtual void	on_sample_lost (DDS::DataReader_ptr reader, const DDS::SampleLostStatus &status)
Private Attributes
DomainParticipantImpl *	partipant_

---

Detailed Description

Definition at line 27 of file BitPubListenerImpl.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::BitPubListenerImpl::BitPubListenerImpl

(

DomainParticipantImpl *

partipant

)

Definition at line 23 of file BitPubListenerImpl.cpp.

: partipant_ (partipant)
{
}

OpenDDS::DCPS::BitPubListenerImpl::~BitPubListenerImpl

(

)

[virtual]

Definition at line 28 of file BitPubListenerImpl.cpp.

{
}

---

Member Function Documentation

void OpenDDS::DCPS::BitPubListenerImpl::on_data_available

(

DDS::DataReader_ptr

reader

)

[virtual]

Definition at line 32 of file BitPubListenerImpl.cpp.

References OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DomainParticipantImpl::get_domain_id(), DDS::SampleInfo::instance_state, DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE, DDS::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE, OPENDDS_STRING, partipant_, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, TheServiceParticipant, OpenDDS::DCPS::DomainParticipantImpl::update_ownership_strength(), and DDS::SampleInfo::valid_data.

{
  try {
    ::DDS::PublicationBuiltinTopicDataDataReader_var bit_dr =
      ::DDS::PublicationBuiltinTopicDataDataReader::_narrow(reader);

    if (CORBA::is_nil(bit_dr.in())) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: BitPubListenerImpl::on_data_available ")
                 ACE_TEXT("_narrow failed!\n")));
      return;
    }

    ::DDS::PublicationBuiltinTopicData data;
    DDS::SampleInfo si;
    DDS::ReturnCode_t status;

    do {
      status = bit_dr->take_next_sample(data, si);

      if (status == DDS::RETCODE_OK) {
        if (si.valid_data) {
#ifndef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE
          Discovery_rch disc =
            TheServiceParticipant->get_discovery(partipant_->get_domain_id());
          PublicationId pub_id =
            disc->bit_key_to_repo_id(partipant_, BUILT_IN_PUBLICATION_TOPIC, data.key);
          CORBA::Long const ownership_strength = data.ownership_strength.value;
          this->partipant_->update_ownership_strength(pub_id, ownership_strength);
          if (DCPS_debug_level > 4) {
            GuidConverter writer_converter(pub_id);
            ACE_DEBUG((LM_DEBUG,
              ACE_TEXT("(%P|%t) BitPubListenerImpl::on_data_available: %X ")
              ACE_TEXT("reset ownership strength %d for writer %C.\n"),
              this, ownership_strength, OPENDDS_STRING(writer_converter).c_str()));
          }
#endif
        }
        else if (si.instance_state != DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE
                 && si.instance_state != DDS::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE) {
          ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: BitPubListenerImpl::on_data_available:")
                ACE_TEXT(" unknown instance state: %d\n"),
                si.instance_state));
        }
      } else if (status != DDS::RETCODE_NO_DATA) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: BitPubListenerImpl::on_data_available:")
                   ACE_TEXT(" unexpected status: %d\n"),
                   status));
      }
    } while (status == DDS::RETCODE_OK);

  } catch (const CORBA::Exception& e) {
    e._tao_print_exception("Exception caught in BitPubListenerImpl::on_data_available():");
  }
}

void OpenDDS::DCPS::BitPubListenerImpl::on_liveliness_changed	(	DDS::DataReader_ptr	reader,
		const DDS::LivelinessChangedStatus &	status
	)			[virtual]

Definition at line 102 of file BitPubListenerImpl.cpp.

{
}

void OpenDDS::DCPS::BitPubListenerImpl::on_requested_deadline_missed	(	DDS::DataReader_ptr	reader,
		const DDS::RequestedDeadlineMissedStatus &	status
	)			[virtual]

Definition at line 90 of file BitPubListenerImpl.cpp.

{
}

void OpenDDS::DCPS::BitPubListenerImpl::on_requested_incompatible_qos	(	DDS::DataReader_ptr	reader,
		const DDS::RequestedIncompatibleQosStatus &	status
	)			[virtual]

Definition at line 96 of file BitPubListenerImpl.cpp.

{
}

void OpenDDS::DCPS::BitPubListenerImpl::on_sample_lost	(	DDS::DataReader_ptr	reader,
		const DDS::SampleLostStatus &	status
	)			[virtual]

Definition at line 120 of file BitPubListenerImpl.cpp.

{
}

void OpenDDS::DCPS::BitPubListenerImpl::on_sample_rejected	(	DDS::DataReader_ptr	reader,
		const DDS::SampleRejectedStatus &	status
	)			[virtual]

Definition at line 114 of file BitPubListenerImpl.cpp.

{
}

void OpenDDS::DCPS::BitPubListenerImpl::on_subscription_matched	(	DDS::DataReader_ptr	reader,
		const DDS::SubscriptionMatchedStatus &	status
	)			[virtual]

Definition at line 108 of file BitPubListenerImpl.cpp.

{
}

---

Member Data Documentation

DomainParticipantImpl* OpenDDS::DCPS::BitPubListenerImpl::partipant_ [private]

Definition at line 64 of file BitPubListenerImpl.h.

Referenced by on_data_available().

---

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

• BitPubListenerImpl.h
• BitPubListenerImpl.cpp

---