Function read

tools/rtpsrelay/control/RtpsRelayControl.cpp:103–141

}

int read(const RelayConfigDataReader_var& reader, RelayConfig& config, bool& done)
{
  RelayConfig sample;
  DDS::SampleInfo info;
  DDS::ReturnCode_t ret;
  while ((ret = reader->take_next_sample(sample, info)) == DDS::RETCODE_OK) {
    if (info.valid_data) {
      filter(sample);
      std::cout << OpenDDS::DCPS::to_json(sample) << std::endl;
      if (sample.relay_id() == config.relay_id()) {
        for (auto it{config.config().begin()}; it != config.config().end();) {
          const auto sample_it{sample.config().find(it->first)};
          if (sample_it != sample.config().end() && sample_it->second == it->second) {
            config.config().erase(it++);
          } else {
            ++it;
          }
        }
        if (config.config().empty() && !keep_running) {
          done = true;
        }
      }
    } else {
      if (info.instance_state != DDS::ALIVE_INSTANCE_STATE) {
        std::cerr << "Relay no longer available: " << sample.relay_id() << std::endl;
        if (sample.relay_id() == config.relay_id() && !keep_running) {
          done = true;
        }
      }
    }
  }

  if (ret != DDS::RETCODE_NO_DATA) {
    ACE_ERROR((LM_ERROR, "ERROR: read returned %C\n", OpenDDS::DCPS::retcode_to_string(ret)));
    return EXIT_FAILURE;
  }

  return EXIT_SUCCESS;
}

int run(int argc, ACE_TCHAR* argv[])
{