Function read_dynamic

tests/DCPS/DynamicData/subscriber.cpp:138–156

}

void read_dynamic(DDS::DataReader_var& data_reader, bool& done, bool& got_message)
{
  DDS::DynamicDataReader_var ddr = DDS::DynamicDataReader::_narrow(data_reader);
  DDS::DynamicDataSeq messages;
  DDS::SampleInfoSeq infos;
  ddr->take(messages, infos, DDS::LENGTH_UNLIMITED,
            DDS::ANY_SAMPLE_STATE, DDS::ANY_VIEW_STATE, DDS::ANY_INSTANCE_STATE);
  for (unsigned int idx = 0; idx != messages.length(); ++idx) {
    CORBA::String_var str;
    messages[idx]->get_string_value(str, 0);
    if (!strcmp(str.in(), HelloWorld::MESSAGE_EXAMPLE_VALUE)) {
      got_message = true;
    }
    if (infos[idx].valid_data) {
      ACE_DEBUG((LM_DEBUG, "received %C\n", str.in()));
      done = true;
    }
  }
}