Method createSubscription

tools/monitor/MonitorTask.cpp:529–587

template< class TypeSupport>
void
Monitor::MonitorTask::createSubscription(
  DDS::Subscriber_ptr subscriber,
  const char*         topicName,
  int                 type
)
{
  DDS::Topic_var           topic;
  DDS::TopicQos            topicQos;
  DDS::DataReaderQos       readerQos;
  DDS::DataReader_var      reader;
  DDS::StatusCondition_var status;

  TypeSupport* typeSupport = new TypeSupport();
  typeSupport->register_type( this->participant_.in(), 0);
  topic = this->participant_->create_topic(
            topicName,
            CORBA::String_var(typeSupport->get_type_name()),
            TOPIC_QOS_DEFAULT,
            DDS::TopicListener::_nil(),
            OpenDDS::DCPS::DEFAULT_STATUS_MASK
          );

  topic->get_qos( topicQos);
  subscriber->get_default_datareader_qos( readerQos);
  subscriber->copy_from_topic_qos( readerQos, topicQos);
  readerQos.durability.kind = DDS::TRANSIENT_LOCAL_DURABILITY_QOS;
  reader = subscriber->create_datareader(
             topic,
             readerQos,
             ::DDS::DataReaderListener::_nil(),
             ::OpenDDS::DCPS::DEFAULT_STATUS_MASK
           );
  if( CORBA::is_nil( reader.in())) {
    ACE_ERROR((LM_ERROR,
      ACE_TEXT("(%P|%t) ERROR: MonitorTask::createSubscription() - ")
      ACE_TEXT("failed to create a reader for %s.\n"),
      topicName
    ));
    return;
  }

  // Track the type by handle and process any initial data.
  this->handleTypeMap_[ reader->get_instance_handle()] = type;

  status = reader->get_statuscondition();
  status->set_enabled_statuses( DDS::DATA_AVAILABLE_STATUS);
  this->waiter_->attach_condition( status.in());

  if( this->options_.verbose()) {
    ACE_DEBUG((LM_DEBUG,
      ACE_TEXT("(%P|%t) MonitorTask::createSubscription() - ")
      ACE_TEXT("topic %C installed and mapped instance %d to type %d.\n"),
      topicName,
      reader->get_instance_handle(),
      type
    ));
  }