Function ACE_TMAIN

tests/DCPS/Reliability/sub/Subscriber.cpp:76–148

} // namespace

int
ACE_TMAIN(int argc, ACE_TCHAR *argv[])
{
  int status = -1;
  try {
    // Initialize DomainParticipantFactory, handling command line args
    DDS::DomainParticipantFactory_var dpf =
      TheParticipantFactoryWithArgs(argc, argv);

    parse_args(argc, argv);

    // Create Listener
    DataReaderListenerImpl* listener_impl = NULL;
    if (take_next) {
      listener_impl = new TakeNextReaderListenerImpl;
    } else if (take) {
      listener_impl = new SeqReaderListenerImpl;
    } else if (zero_copy) {
      listener_impl = new ZeroCopyReaderListenerImpl;
    } else {
      listener_impl = new TakeNextReaderListenerImpl;
    }

    listener_impl->set_num_sleeps(num_sleeps);
    listener_impl->set_sleep_length(sleep_time);

    // Create domain participant
    DDS::DomainParticipant_var participant = createParticipant(dpf);

    // Register type support and create topic
    DDS::Topic_var topic = createTopic(participant);

    // Create subscriber
    DDS::Subscriber_var subscriber = createSubscriber(participant);

    DDS::DataReaderListener_var listener(listener_impl);

    // Create DataReader with the listener attached
    DDS::DataReader_var reader = createDataReader(subscriber, topic, listener);

    std::cout << "Waiting for connection" << std::endl;
    {
      // Block until reader has associated with a writer
      // but is no longer associated with any writer
      OpenDDS::Model::ReaderSync rs(reader);
    }

    if (listener_impl->sample_count() == listener_impl->expected_count()) {
      std::cout << "Got all " << listener_impl->sample_count()
                << " samples" << std::endl;
      status = 0;
    } else {
      std::cout << "ERROR: Got " << listener_impl->sample_count()
                << " samples, expected " << listener_impl->expected_count()
                << std::endl;
    }
    // Clean-up!
    cleanup(participant, dpf);