Method init

dds/DCPS/DataReaderImpl.cpp:185–228

}

void DataReaderImpl::init(
    TopicDescriptionImpl* topic_desc,
    const DDS::DataReaderQos &qos,
    DDS::DataReaderListener_ptr listener,
    const DDS::StatusMask & mask,
    DomainParticipantImpl* participant,
    SubscriberImpl* subscriber)
{
  topic_desc_ = DDS::TopicDescription::_duplicate(topic_desc);
  if (TopicImpl* topic = dynamic_cast<TopicImpl*>(topic_desc)) {
    topic_servant_ = topic;
    type_support_ = dynamic_cast<TypeSupportImpl*>(topic->get_type_support());
    topic_id_ = topic->get_id();
  }

#ifndef DDS_HAS_MINIMUM_BIT
  CORBA::String_var topic_name = topic_desc->get_name();
  CORBA::String_var topic_type_name = topic_desc->get_type_name();
  is_bit_ = topicIsBIT(topic_name, topic_type_name);
#endif // !defined (DDS_HAS_MINIMUM_BIT)

  qos_ = qos;
  passed_qos_ = qos;

#ifndef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE
  is_exclusive_ownership_ = this->qos_.ownership.kind == ::DDS::EXCLUSIVE_OWNERSHIP_QOS;
#endif

  set_listener(listener, mask);

  // Only store the participant pointer, since it is our "grand"
  // parent, we will exist as long as it does
  participant_servant_ = *participant;

  domain_id_ = participant->get_domain_id();

  subscriber_servant_ = rchandle_from(subscriber);

  if (subscriber->get_qos(this->subqos_) != ::DDS::RETCODE_OK) {
    ACE_DEBUG((LM_WARNING,
        ACE_TEXT("(%P|%t) WARNING: DataReaderImpl::init() - ")
        ACE_TEXT("failed to get SubscriberQos\n")));
  }
}

DDS::InstanceHandle_t
DataReaderImpl::get_instance_handle()