Method begin_serialize_complex

dds/DCPS/Xcdr2ValueWriter.cpp:136–189

}

bool Xcdr2ValueWriter::begin_serialize_complex(Extensibility extensibility, CollectionKind ck,
                                               ACE_CDR::ULong seq_map_length)
{
  if (!ser_) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: Xcdr2ValueWriter::begin_serialize_complex:"
                 " Serializer object is not available\n"));
    }
    return false;
  }

  if (serialize_states_.empty() && extensibility == FINAL) {
    // The first entry is the total size and does not correspond to any header.
    ++pos_;
  }

  if (!serialize_states_.empty()) {
    const Extensibility enclosing_ek = serialize_states_.top().extensibility;
    if (extensibility == APPENDABLE || extensibility == MUTABLE) {
      if (enclosing_ek == MUTABLE) {
        // The same size is used for both the member header of the enclosing mutable type
        // and the Dheader of this struct. pos_ was proactively increased by a preceding
        // call to begin_*_member of the containing type.
        --pos_;
      }
    }
  }

  // Write Dheader
  if (extensibility == APPENDABLE || extensibility == MUTABLE)  {
    if (pos_ >= size_cache_.size()) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: Xcdr2ValueWriter::begin_serialize_complex:"
                   " Size value is not available at index %u. Cache length: %u\n",
                   pos_, size_cache_.size()));
      }
      return false;
    }
    if (!ser_->write_delimiter(size_cache_.at(pos_))) {
      return false;
    }
    ++pos_;
  }

  // maps without a DHeader have a 32-bit length prefix (like sequences)
  if (ck == SEQUENCE_KIND || (ck == MAP_KIND && extensibility == FINAL)) {
    if (!(*ser_ << seq_map_length)) {
      return false;
    }
  }

  serialize_states_.push(SerializeState(extensibility, ck));
  return true;
}

bool Xcdr2ValueWriter::end_serialize_complex()
{