Function ACE_TMAIN

tests/DCPS/FindTopic/findtopic.cpp:130–218

}

int ACE_TMAIN(int argc, ACE_TCHAR* argv[])
{
  try {
    DDS::DomainParticipantFactory_var dpf = TheParticipantFactoryWithArgs(argc, argv);

    OpenDDS::DCPS::Discovery_rch discovery;
    if (argc > 1 && ACE_TString(argv[1]) == ACE_TEXT("rtps")) {
      OpenDDS::RTPS::RtpsDiscovery_rch rtps_disc =
        OpenDDS::DCPS::make_rch<OpenDDS::RTPS::RtpsDiscovery>("RTPS");
      rtps_disc->sedp_multicast(false);
      discovery = rtps_disc;
      ACE_DEBUG((LM_DEBUG, "%N:%l main() using RTPS Discovery\n"));
    } else {
      discovery = OpenDDS::DCPS::make_rch<LocalDiscovery>();
      ACE_DEBUG((LM_DEBUG, "%N:%l main() using Local Discovery\n"));
    }
    TheServiceParticipant->add_discovery(discovery);
    TheServiceParticipant->set_default_discovery(discovery->key());

    TransportInst_rch default_inst = TheTransportRegistry->create_inst("transport", "rtps_udp");
    TheTransportRegistry->get_config(TransportRegistry::DEFAULT_CONFIG_NAME)->sorted_insert(default_inst);

    DDS::DomainParticipant_var participant = dpf->create_participant(11, PARTICIPANT_QOS_DEFAULT, 0, 0);
    if (!participant) {
      ACE_ERROR_RETURN((LM_ERROR, "%N:%l: main() ERROR: create_participant failed!\n"), EXIT_FAILURE);
    }

    Messenger::MessageTypeSupport_var mts = new Messenger::MessageTypeSupportImpl;
    if (mts->register_type(participant, "") != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR, "%N:%l: main() ERROR: register_type failed!\n"), EXIT_FAILURE);
    }

    CORBA::String_var type_name = mts->get_type_name();
    DDS::Topic_var topic1 = participant->create_topic("Movie Discussion List",
                                                      type_name, TOPIC_QOS_DEFAULT, 0, 0);
    if (!topic1) {
      ACE_ERROR_RETURN((LM_ERROR, "%N:%l: main() ERROR: create_topic failed!\n"), EXIT_FAILURE);
    }

    DDS::Publisher_var pub1 = participant->create_publisher(PUBLISHER_QOS_DEFAULT, 0, 0);
    if (!pub1) {
      ACE_ERROR_RETURN((LM_ERROR, "%N:%l: main() ERROR: create_publisher 1 failed!\n"), EXIT_FAILURE);
    }

    DDS::DataWriter_var dw1 = pub1->create_datawriter(topic1, DATAWRITER_QOS_DEFAULT, 0, 0);
    if (!dw1) {
      ACE_ERROR_RETURN((LM_ERROR, "%N:%l: main() ERROR: create_datawriter 1 failed!\n"), EXIT_FAILURE);
    }

    // Now the second part of the program will try to do its setup
    if (sub_program(participant) != EXIT_SUCCESS) {
      ACE_ERROR_RETURN((LM_ERROR, "%N:%l: main() ERROR: sub program 1 failed!\n"), EXIT_FAILURE);
    }

    // Now test double create/delete
    if (double_delete(participant, type_name.in ()) != EXIT_SUCCESS) {
      ACE_ERROR_RETURN((LM_ERROR, "%N:%l: main() ERROR: double_delete failed!\n"), EXIT_FAILURE);
    }