Function write

performance-tests/DCPS/UDPNoKeyTest/Writer.cpp:24–68

template<class T, class W, class W_var, class W_ptr>
void write (long id,
            int size,
            int num_messages,
            unsigned throttle_factor_,
            ::DDS::DataWriter_ptr writer)
{
  T data;
  data.data_source = id;
  data.values.length(size);

  for (int i = 0; i < size; i ++)
    {
      data.values[i] = (float) i;
    }

  W_var pt_dw
    = W::_narrow(writer);
  ACE_ASSERT (! CORBA::is_nil (pt_dw.in ()));

  //SHH remove this kludge when the transport is fixed.
  ACE_OS::sleep(2); // ensure that the connection has been fully established
  ACE_DEBUG((LM_DEBUG,
            ACE_TEXT("(%P|%t) %T Writer::svc starting to write.\n")));

  ::DDS::InstanceHandle_t handle
      = pt_dw->register_instance(data);

  {
  for (int i = 0; i < num_messages; i ++)
    {
      data.sequence_num = i;
      pt_dw->write(data, handle);
      THROTTLE
    }
  }

  for (int j = 0; j < 500; j ++)
    {
      data.sequence_num = -1;
      pt_dw->write(data, handle);
      // throttle twice to slow the rate to ensure one gets sent.
      THROTTLE
      THROTTLE
    }
}