| 42 | } |
| 43 | |
| 44 | DDS::Topic_var |
| 45 | Factory::topic(const DDS::DomainParticipant_var& dp) const |
| 46 | { |
| 47 | |
| 48 | // When collocation doesn't matter we choose a topic name that will not match |
| 49 | // the publisher's topic name |
| 50 | std::string topicname((opts_.collocation_str == "none") ? MY_OTHER_TOPIC : MY_SAME_TOPIC); |
| 51 | |
| 52 | DDS::TopicQos topic_qos; |
| 53 | TEST_CHECK(DDS::RETCODE_OK == dp->get_default_topic_qos(topic_qos)); |
| 54 | |
| 55 | CORBA::String_var tn = typsup_->get_type_name(); |
| 56 | ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Topic name: %C\n"), tn.in())); |
| 57 | DDS::Topic_var p(dp->create_topic(topicname.c_str(), |
| 58 | tn, |
| 59 | TOPIC_QOS_DEFAULT, |
| 60 | DDS::TopicListener::_nil(), |
| 61 | OpenDDS::DCPS::DEFAULT_STATUS_MASK)); |
| 62 | TEST_CHECK(!CORBA::is_nil(p.in())); |
| 63 | return p; |
| 64 | } |
| 65 | |
| 66 | DDS::Publisher_var |
| 67 | Factory::publisher(const DDS::DomainParticipant_var& dp) const |
no test coverage detected