Method serialize_sample

dds/DCPS/DataWriterImpl.cpp:2990–3070

}

ACE_Message_Block* DataWriterImpl::serialize_sample(const Sample& sample)
{
  const bool encapsulated = cdr_encapsulation();
  const Encoding& encoding = encoding_mode_.encoding();
  Message_Block_Ptr mb;
  ACE_Message_Block* tmp_mb;

  // Don't use the cached allocator for the registered sample message
  // block.
  if (sample.key_only() && !skip_serialize_) {
    ACE_NEW_RETURN(tmp_mb,
      ACE_Message_Block(
        encoding_mode_.buffer_size(sample),
        ACE_Message_Block::MB_DATA,
        0, // cont
        0, // data
        0, // alloc_strategy
        get_db_lock()),
      0);
  } else {
    ACE_NEW_MALLOC_RETURN(tmp_mb,
      static_cast<ACE_Message_Block*>(
        mb_allocator_->malloc(sizeof(ACE_Message_Block))),
      ACE_Message_Block(
        encoding_mode_.buffer_size(sample),
        ACE_Message_Block::MB_DATA,
        0, // cont
        0, // data
        data_allocator_.get(), // allocator_strategy
        get_db_lock(), // data block locking_strategy
        ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY,
        ACE_Time_Value::zero,
        ACE_Time_Value::max_time,
        db_allocator_.get(),
        mb_allocator_.get()),
      0);
  }
  mb.reset(tmp_mb);

  if (skip_serialize_) {
    if (!sample.to_message_block(*mb)) {
      if (log_level >= LogLevel::Error) {
        ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: DataWriterImpl::serialize_sample: "
                   "to_message_block failed\n"));
      }
      return 0;
    }
  } else {
    Serializer serializer(mb.get(), encoding);
    if (encapsulated) {
      EncapsulationHeader encap;
      if (!from_encoding(encap, encoding, type_support_->base_extensibility())) {
        // from_encoding logged the error
        return 0;
      }
      if (!(serializer << encap)) {
        if (log_level >= LogLevel::Error) {
          ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: DataWriterImpl::serialize_sample: "