Skip to content

Commit

Permalink
[Runtime] Make ADTObject POD container type
Browse files Browse the repository at this point in the history
  • Loading branch information
wweic committed Nov 18, 2019
1 parent 7dca655 commit 3636388
Show file tree
Hide file tree
Showing 6 changed files with 355 additions and 49 deletions.
220 changes: 220 additions & 0 deletions include/tvm/runtime/container.h
@@ -0,0 +1,220 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/

/*!
* \file tvm/runtime/container.h
* \brief Common POD(plain old data) container types.
*/
#ifndef TVM_RUNTIME_CONTAINER_H_
#define TVM_RUNTIME_CONTAINER_H_
#include <tvm/runtime/object.h>
#include <initializer_list>
#include <type_traits>
#include <vector>

namespace tvm {
namespace runtime {

/**
* @brief Base template for classes with array like memory layout.
*
* It provides general methods to access the memory. The memory
* layout is ArrayType + [ElemType]. The alignment of ArrayType
* and ElemType is handled by the memory allocator.
*
* @tparam ArrayType
* @tparam ElemType
*/
template <typename ArrayType, typename ElemType>
class InplaceArrayBase {
public:
/**
* @brief Initialize the elements in the array.
*/
void Init() {
CHECK_EQ(sizeof(ArrayType) % alignof(ElemType), 0);
for (size_t i = 0; i < Self()->size(); ++i) {
void* field_ptr = AddressOf(i);
new (field_ptr) ElemType();
}
}

/**
* @brief Initialize the elements in the array.
*
* @tparam Iterator Iterator type of the array.
* @param begin The begin iterator.
* @param end The end iterator.
*/
template <typename Iterator>
void Init(Iterator begin, Iterator end) {
CHECK_EQ(sizeof(ArrayType) % alignof(ElemType), 0);
ArrayType* self = Self();
size_t num_elems = std::distance(begin, end);
if (num_elems != self->size()) {
LOG(FATAL)
<< "Number of initializer values does not match number of elements\n";
}
auto it = begin;
for (size_t i = 0; i < num_elems; ++i) {
void* field_ptr = AddressOf(i);
new (field_ptr) ElemType(*it);
++it;
}
}

/**
* @brief Initialize the elements in the array.
*
* @param init The initializer list of elements.
*/
void Init(std::initializer_list<ElemType> init) {
CHECK_EQ(sizeof(ArrayType) % alignof(ElemType), 0);
Init(init.begin(), init.end());
}

/*!
* \brief Access element at index
* \param idx The index of the element.
* \return Reference to ElemType at the index.
*/
ElemType& operator[](size_t idx) const {
size_t size = Self()->size();
if (idx > size) {
LOG(FATAL) << "Index " << idx << " out of bounds " << size << "\n";
}
return *(reinterpret_cast<ElemType*>(AddressOf(idx)));
}

/**
* @brief Destroy the Inplace Array Base object
*/
virtual ~InplaceArrayBase() {
if (!IsPOD()) {
size_t size = Self()->size();
for (size_t i = 0; i < size; ++i) {
ElemType* fp = reinterpret_cast<ElemType*>(AddressOf(i));
fp->ElemType::~ElemType();
}
}
}

private:
/**
* @brief Check if the ElemType is Plain Old Data.
*
* @return If ElemType is POD.
*/
inline bool IsPOD() const {
return std::is_standard_layout<ElemType>::value &&
std::is_trivial<ElemType>::value;
}

/**
* @brief Return the self object for the array.
*
* @return Pointer to ArrayType.
*/
inline ArrayType* Self() const {
return static_cast<ArrayType*>(const_cast<InplaceArrayBase*>(this));
}

/**
* @brief Return the raw pointer to the element at idx.
*
* @param idx The index of the element.
* @return Raw pointer to the element.
*/
void* AddressOf(size_t idx) const {
const size_t kDataStart = sizeof(ArrayType);
ArrayType* self = Self();
char* data_start = reinterpret_cast<char*>(self) + kDataStart;
return data_start + idx * sizeof(ElemType);
}
};

/*! \brief An object representing a structure or enumeration. */
class ADTObj : public Object, public InplaceArrayBase<ADTObj, ObjectRef> {
public:
/*! \brief The tag representing the constructor used. */
uint32_t tag_;
/*! \brief Number of fields in the ADT object. */
uint32_t size_;
// The fields of the structure follows directly in memory.

/**
* @brief The number of elements in the array.
*/
inline size_t size() const { return size_; }

/**
* @brief Destroy the ADTObj object
*/
~ADTObj() {}

static constexpr const uint32_t _type_index = TypeIndex::kVMADT;
static constexpr const char* _type_key = "vm.ADT";
TVM_DECLARE_FINAL_OBJECT_INFO(ADTObj, Object);
};

/*! \brief reference to algebraic data type objects. */
class ADT : public ObjectRef {
public:
/*!
* \brief construct an ADT object reference.
* \param tag The tag of the ADT object.
* \param fields The fields of the ADT object.
* \return The constructed ADT object reference.
*/
ADT(uint32_t tag, std::vector<ObjectRef> fields)
: ADT(tag, fields.begin(), fields.end()){};

/**
* \brief construct an ADT object reference.
* \param tag The tag of the ADT object.
* \param begin The begin iterator to the start of the fields array.
* \param end The end iterator to the end of the fields array.
* \return The constructed ADT object reference.
*/
template <typename Iterator>
ADT(uint32_t tag, Iterator begin, Iterator end);

/**
* \brief construct an ADT object reference.
* \param tag The tag of the ADT object.
* \param init The initializer list of fields.
* \return The constructed ADT object reference.
*/
ADT(uint32_t tag, std::initializer_list<ObjectRef> init)
: ADT(tag, init.begin(), init.end()){};

/*!
* \brief construct a tuple object.
* \param fields The fields of the tuple.
* \return The constructed tuple type.
*/
static ADT Tuple(std::vector<ObjectRef> fields);

TVM_DEFINE_OBJECT_REF_METHODS(ADT, ObjectRef, ADTObj);
};

} // namespace runtime
} // namespace tvm

#endif // TVM_RUNTIME_CONTAINER_H_
80 changes: 79 additions & 1 deletion include/tvm/runtime/memory.h
Expand Up @@ -23,6 +23,7 @@
#ifndef TVM_RUNTIME_MEMORY_H_
#define TVM_RUNTIME_MEMORY_H_

#include <cstdlib>
#include <utility>
#include <type_traits>
#include "object.h"
Expand All @@ -33,7 +34,7 @@ namespace runtime {
* \brief Allocate an object using default allocator.
* \param args arguments to the constructor.
* \tparam T the node type.
* \return The NodePtr to the allocated object.
* \return The ObjectPtr to the allocated object.
*/
template<typename T, typename... Args>
inline ObjectPtr<T> make_object(Args&&... args);
Expand Down Expand Up @@ -73,6 +74,26 @@ class ObjAllocatorBase {
ptr->deleter_ = Handler::Deleter();
return ObjectPtr<T>(ptr);
}

/*!
* \tparam T The type to be allocated.
* \tparam ElemType The type to array element.
* \tparam Args The constructor signature.
* \param num_elems The number of array elements.
* \param args The arguments.
*/
template<typename T, typename ElemType, typename... Args>
inline ObjectPtr<T> make_array(size_t num_elems, Args&&... args) {
using Handler = typename Derived::template Handler<T, ElemType>;
static_assert(std::is_base_of<Object, T>::value,
"make_node can only be used to create NodeBase");
T* ptr = Handler::New(static_cast<Derived*>(this),
num_elems,
std::forward<Args>(args)...);
ptr->type_index_ = T::RuntimeTypeIndex();
ptr->deleter_ = Handler::Deleter();
return ObjectPtr<T>(ptr);
}
};

// Simple allocator that uses new/delete.
Expand Down Expand Up @@ -124,11 +145,68 @@ class SimpleObjAllocator :
};
};

// Array allocator that uses new/delete.
class ArrayObjAllocator :
public ObjAllocatorBase<ArrayObjAllocator> {
public:
template<typename ArrayType, typename ElemType>
class Handler {
public:
using StorageType = typename std::aligned_union<sizeof(ArrayType), ArrayType, ElemType>::type;

template<typename... Args>
static ArrayType* New(ArrayObjAllocator*, size_t num_elems, Args&&... args) {
// NOTE: the first argument is not needed for ArrayObjAllocator
// It is reserved for special allocators that needs to recycle
// the object to itself (e.g. in the case of object pool).
//
// In the case of an object pool, an allocator needs to create
// a special chunk memory that hides reference to the allocator
// and call allocator's release function in the deleter.

// NOTE2: Use inplace new to allocate
// This is used to get rid of warning when deleting a virtual
// class with non-virtual destructor.
// We are fine here as we captured the right deleter during construction.
// This is also the right way to get storage type for an object pool.
size_t factor = sizeof(ArrayType) / sizeof(ElemType);
num_elems = (num_elems + factor - 1) / factor;
StorageType* data = new StorageType[num_elems+1];
new (data) ArrayType(std::forward<Args>(args)...);
return reinterpret_cast<ArrayType*>(data);
}

static Object::FDeleter Deleter() {
return Deleter_;
}

private:
static void Deleter_(Object* objptr) {
// NOTE: this is important to cast back to ArrayType*
// because objptr and tptr may not be the same
// depending on how sub-class allocates the space.
ArrayType* tptr = static_cast<ArrayType*>(objptr);
// It is important to do tptr->ArrayType::~ArrayType(),
// so that we explicitly call the specific destructor
// instead of tptr->~ArrayType(), which could mean the intention
// call a virtual destructor(which may not be available and is not required).
tptr->ArrayType::~ArrayType();
StorageType* p = reinterpret_cast<StorageType*>(tptr);
delete []p;
}
};
};

template<typename T, typename... Args>
inline ObjectPtr<T> make_object(Args&&... args) {
return SimpleObjAllocator().make<T>(std::forward<Args>(args)...);
}

template<typename T, typename ElemType, typename... Args>
inline ObjectPtr<T> make_array(size_t num_elems, Args&&... args) {
return ArrayObjAllocator().make_array<T, ElemType>(num_elems, std::forward<Args>(args)...);
}

} // namespace runtime
} // namespace tvm
#endif // TVM_RUNTIME_MEMORY_H_
29 changes: 0 additions & 29 deletions include/tvm/runtime/vm.h
Expand Up @@ -55,35 +55,6 @@ class Tensor : public ObjectRef {
TVM_DEFINE_OBJECT_REF_METHODS(Tensor, ObjectRef, TensorObj);
};


/*! \brief An object representing a structure or enumeration. */
class ADTObj : public Object {
public:
/*! \brief The tag representing the constructor used. */
size_t tag;
/*! \brief The fields of the structure. */
std::vector<ObjectRef> fields;

static constexpr const uint32_t _type_index = TypeIndex::kVMADT;
static constexpr const char* _type_key = "vm.ADT";
TVM_DECLARE_FINAL_OBJECT_INFO(ADTObj, Object);
};

/*! \brief reference to algebraic data type objects. */
class ADT : public ObjectRef {
public:
ADT(size_t tag, std::vector<ObjectRef> fields);

/*!
* \brief construct a tuple object.
* \param fields The fields of the tuple.
* \return The constructed tuple type.
*/
static ADT Tuple(std::vector<ObjectRef> fields);

TVM_DEFINE_OBJECT_REF_METHODS(ADT, ObjectRef, ADTObj);
};

/*! \brief An object representing a closure. */
class ClosureObj : public Object {
public:
Expand Down

0 comments on commit 3636388

Please sign in to comment.