Method allocator_test

tests/DCPS/FooTest3_0/PubDriver.cpp:923–979

}

void
PubDriver::allocator_test ()
{
  size_t n_chunks = TheServiceParticipant->n_chunks ();

  ::DDS::ReturnCode_t ret = ::DDS::RETCODE_OK;

  ::Xyz::Foo foo1;
  foo1.a_long_value = 101010;
  foo1.handle_value = -1;
  foo1.sample_sequence = -1;
  foo1.writer_id = -1;

  ::DDS::InstanceHandle_t handle
    = foo_datawriter_->register_instance(foo1);

  ::Xyz::Foo foo2;
  foo2.a_long_value = 101010;
  foo2.handle_value = handle;
  foo2.writer_id = 0;

  const SerializedSizeBound bound = MarshalTraits< ::Xyz::Foo>::serialized_size_bound(encoding);

  // Allocate serialized foo data from pre-allocated pool
  for (size_t i = 1; i <= n_chunks; i ++) {
    foo2.sample_sequence = static_cast<CORBA::Long>(i);

    ret = foo_datawriter_->write(foo2, handle);

    TEST_CHECK(ret == ::DDS::RETCODE_OK);

    if (bound) {
      TEST_CHECK(foo_datawriter_servant_->data_allocator() != 0);
      TEST_CHECK(foo_datawriter_servant_->data_allocator()->allocs_from_heap_ == 0);
      TEST_CHECK(foo_datawriter_servant_->data_allocator()->allocs_from_pool_ == static_cast<unsigned long>(i));
    } else {
      TEST_CHECK(foo_datawriter_servant_->data_allocator() == 0);
    }
  }

  // The pre-allocated pool is full, now the foo data is allocated from heap
  for (size_t i = 1; i <= 2; i ++) {
    foo2.sample_sequence = static_cast<CORBA::Long>(i + n_chunks);

    ret = foo_datawriter_->write(foo2, handle);

    TEST_CHECK(ret == ::DDS::RETCODE_OK);

    if (bound) {
      TEST_CHECK(foo_datawriter_servant_->data_allocator() != 0);
      TEST_CHECK(foo_datawriter_servant_->data_allocator()->allocs_from_heap_ == static_cast<unsigned long>(i));
      TEST_CHECK(foo_datawriter_servant_->data_allocator()->allocs_from_pool_ == static_cast<unsigned long>(n_chunks));
    } else {
      TEST_CHECK(foo_datawriter_servant_->data_allocator() == 0);
    }
  }
}