Function run_test

tests/DCPS/QueryCondition/QueryConditionTest.cpp:962–1017

}

int run_test(int argc, ACE_TCHAR* argv[])
{
  DomainParticipantFactory_var dpf = TheParticipantFactoryWithArgs(argc, argv);

  ACE_Argv_Type_Converter conv(argc, argv);
  char** const argva = conv.get_ASCII_argv();
  for (int i = 1; i < argc; ++i) {
    if (0 == std::strcmp("-dynamic", argva[i])) {
      dynamic = true;
      break;
    }
  }

  DomainParticipant_var dp =
    dpf->create_participant(23, PARTICIPANT_QOS_DEFAULT, 0,
                            DEFAULT_STATUS_MASK);
  MessageTypeSupport_var ts = new MessageTypeSupportImpl;
  ts->register_type(dp, "");

  Publisher_var pub = dp->create_publisher(PUBLISHER_QOS_DEFAULT, 0,
                                           DEFAULT_STATUS_MASK);

  DomainParticipant_var dp_reader = dp;
  if (dynamic) {
    dp_reader = dpf->create_participant(23, PARTICIPANT_QOS_DEFAULT, 0, 0);
    DDS::DynamicType_var dt = ts->get_type();
    DDS::TypeSupport_var dts = new DDS::DynamicTypeSupport(dt);
    CORBA::String_var type_name = ts->get_type_name();
    dts->register_type(dp_reader, type_name);
    TransportConfig_rch cfg = TheTransportRegistry->get_config("config2");
    if (cfg) {
      TheTransportRegistry->bind_config(cfg, dp_reader);
    }
  }

  Subscriber_var sub = dp_reader->create_subscriber(SUBSCRIBER_QOS_DEFAULT, 0, 0);

  bool passed = true;
  passed &= run_sorting_test(ts, pub, sub);
  passed &= run_filtering_test(ts, pub, sub);
  passed &= run_change_parameter_test(ts, pub, sub);
  passed &= run_complex_filtering_test(ts, pub, sub);
  passed &= run_dispose_filter_tests(ts, pub, sub);

  pub = 0;
  ts = 0;
  sub = 0;
  dp->delete_contained_entities();

  dpf->delete_participant(dp);
  if (dynamic) {
    dp_reader->delete_contained_entities();
    dpf->delete_participant(dp_reader);
  }
  return passed ? 0 : 1;
}