Method TryDeepCopyCollections

be/src/runtime/tuple-ir.cc:101–134

}

bool Tuple::TryDeepCopyCollections(uint8_t** data, const uint8_t* data_end, int* offset,
    const TupleDescriptor& desc, bool convert_ptrs) {
  vector<SlotDescriptor*>::const_iterator slot = desc.collection_slots().begin();
  for (; slot != desc.collection_slots().end(); ++slot) {
    DCHECK((*slot)->type().IsCollectionType());
    if (IsNull((*slot)->null_indicator_offset())) continue;

    CollectionValue* coll_value = GetCollectionSlot((*slot)->tuple_offset());
    const TupleDescriptor& item_desc = *(*slot)->children_tuple_descriptor();
    int coll_byte_size = coll_value->num_tuples * item_desc.byte_size();
    if (!TryMemCopy(*data, data_end, coll_byte_size, coll_value->ptr)) return false;
    uint8_t* coll_data = reinterpret_cast<uint8_t*>(*data);

    coll_value->ptr = convert_ptrs ? reinterpret_cast<uint8_t*>(*offset) : coll_data;

    *data += coll_byte_size;
    *offset += coll_byte_size;

    // Copy per-tuple varlen data if necessary.
    if (!item_desc.HasVarlenSlots()) continue;
    for (int i = 0; i < coll_value->num_tuples; ++i) {
      Tuple* dst_item = reinterpret_cast<Tuple*>(coll_data);
      if(!dst_item->TryDeepCopyStrings(data, data_end, offset, item_desc, convert_ptrs)) {
        return false;
      }
      if(!dst_item->TryDeepCopyCollections(
          data, data_end, offset, item_desc, convert_ptrs)) {
        return false;
      }
      coll_data += item_desc.byte_size();
    }
  }
  return true;
}

}