Function ACE_TMAIN

tests/DCPS/ThreadStatusManager/main.cpp:258–330

}

int ACE_TMAIN(int argc, ACE_TCHAR* argv[])
{
  DDS::DomainParticipantFactory_var dpf = TheParticipantFactoryWithArgs(argc, argv);
  DDS::DomainParticipantQos participant_qos;
  dpf->get_default_participant_qos(participant_qos);
  DDS::PropertySeq& properties = participant_qos.property.value;
  Qos_Helper::append(properties, OpenDDS::RTPS::RTPS_HARVEST_THREAD_STATUS, "true");
  const DDS::DomainId_t domain = 0;
  DDS::DomainParticipant_var participant = dpf->create_participant(domain, participant_qos, 0, DEFAULT_STATUS_MASK);
  if (!participant) {
    ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: main - failed to create participant\n"));
    return EXIT_FAILURE;
  }

  DDS::Subscriber_var bit_subscriber = participant->get_builtin_subscriber();
  DDS::DataReader_var reader = bit_subscriber->lookup_datareader(OpenDDS::DCPS::BUILT_IN_INTERNAL_THREAD_TOPIC);
  InternalThreadBuiltinTopicDataDataReader_var itbtd_reader = InternalThreadBuiltinTopicDataDataReader::_narrow(reader);
  if (!itbtd_reader) {
    ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: main - failed to narrow internal thread builtin topic data reader\n"));
    return EXIT_FAILURE;
  }

  DDS::ReadCondition_var read_cond = reader->create_readcondition(DDS::NOT_READ_SAMPLE_STATE, DDS::ANY_VIEW_STATE, DDS::ANY_INSTANCE_STATE);
  DDS::WaitSet_var ws = new DDS::WaitSet;
  ws->attach_condition(read_cond);

  // Run test with initial config
  const DDS::UInt32 initial_interval = TheServiceParticipant->config_store()->get_uint32(
    OpenDDS::DCPS::COMMON_DCPS_THREAD_STATUS_INTERVAL, 0);
  if (!wait_for_thread_status_interval(TimeDuration(initial_interval))) {
    return EXIT_FAILURE;
  }
  int ret = tsm_test(itbtd_reader, ws);

  if (ret == EXIT_SUCCESS) {
    const char* const status_prop = OpenDDS::DCPS::COMMON_DCPS_THREAD_STATUS_INTERVAL;
    OpenDDS::DCPS::RcHandle<OpenDDS::DCPS::ConfigStoreImpl> config_store =
      TheServiceParticipant->config_store();

    // Turn off thread status reporting and expect no messages
    const DDS::UInt32 orig = config_store->get_uint32(status_prop, 0);
    config_store->set_uint32(status_prop, 0);
    // Unfortunatly, we don't have a "clean" way to wait for the config change to propagate all the
    // way into the SPDP timer's cancelation, only into the Service_Partipant config store,
    // so the safest thing to do here is just wait until we know for sure the timer is definitely done
    ACE_OS::sleep(1); // Assume any updates here are pre-cancelation updates (config still propagating)
    const DDS::Duration_t waittime = {5, 0};
    DDS::ConditionSeq active;
    DDS::ReturnCode_t rc = ws->wait(active, waittime);
    if (rc != DDS::RETCODE_TIMEOUT) {
      ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: got unexpected thread status message\n"));
      ret = EXIT_FAILURE;
    }

    // Turn it back on do the testing again
    if (ret == EXIT_SUCCESS) {
      config_store->set_uint32(status_prop, orig);
      if (!wait_for_thread_status_interval(TimeDuration(orig))) {