Function write

performance-tests/DCPS/TCPProfilingTest/Writer.cpp:15–44

extern ACE_Condition<ACE_Recursive_Thread_Mutex> done_condition_;

void write (long id,
            int size,
            int num_messages,
            ::DDS::DataWriter_ptr writer)
{
  profilingTest::testMsg data;
  data.msgID = id;
  data.contents.length(size);

  for (int i = 0; i < size; i ++)
  {
    data.contents[i] = (char) i % 256;
  }

  ::profilingTest::testMsgDataWriter_var pt_dw
    = ::profilingTest::testMsgDataWriter::_narrow(writer);
  ACE_ASSERT (! CORBA::is_nil (pt_dw.in ()));

  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.count = i;
    pt_dw->write(data, handle);
  }
}