cannam@147: // Copyright (c) 2013-2014 Sandstorm Development Group, Inc. and contributors cannam@147: // Licensed under the MIT License: cannam@147: // cannam@147: // Permission is hereby granted, free of charge, to any person obtaining a copy cannam@147: // of this software and associated documentation files (the "Software"), to deal cannam@147: // in the Software without restriction, including without limitation the rights cannam@147: // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell cannam@147: // copies of the Software, and to permit persons to whom the Software is cannam@147: // furnished to do so, subject to the following conditions: cannam@147: // cannam@147: // The above copyright notice and this permission notice shall be included in cannam@147: // all copies or substantial portions of the Software. cannam@147: // cannam@147: // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR cannam@147: // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, cannam@147: // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE cannam@147: // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER cannam@147: // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, cannam@147: // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN cannam@147: // THE SOFTWARE. cannam@147: cannam@147: #ifndef CAPNP_LIST_H_ cannam@147: #define CAPNP_LIST_H_ cannam@147: cannam@147: #if defined(__GNUC__) && !defined(CAPNP_HEADER_WARNINGS) cannam@147: #pragma GCC system_header cannam@147: #endif cannam@147: cannam@147: #include "layout.h" cannam@147: #include "orphan.h" cannam@147: #include cannam@147: #ifdef KJ_STD_COMPAT cannam@147: #include cannam@147: #endif // KJ_STD_COMPAT cannam@147: cannam@147: namespace capnp { cannam@147: namespace _ { // private cannam@147: cannam@147: template cannam@147: class TemporaryPointer { cannam@147: // This class is a little hack which lets us define operator->() in cases where it needs to cannam@147: // return a pointer to a temporary value. We instead construct a TemporaryPointer and return that cannam@147: // (by value). The compiler then invokes operator->() on the TemporaryPointer, which itself is cannam@147: // able to return a real pointer to its member. cannam@147: cannam@147: public: cannam@147: TemporaryPointer(T&& value): value(kj::mv(value)) {} cannam@147: TemporaryPointer(const T& value): value(value) {} cannam@147: cannam@147: inline T* operator->() { return &value; } cannam@147: private: cannam@147: T value; cannam@147: }; cannam@147: cannam@147: template cannam@147: class IndexingIterator { cannam@147: public: cannam@147: IndexingIterator() = default; cannam@147: cannam@147: inline Element operator*() const { return (*container)[index]; } cannam@147: inline TemporaryPointer operator->() const { cannam@147: return TemporaryPointer((*container)[index]); cannam@147: } cannam@147: inline Element operator[]( int off) const { return (*container)[index]; } cannam@147: inline Element operator[](uint off) const { return (*container)[index]; } cannam@147: cannam@147: inline IndexingIterator& operator++() { ++index; return *this; } cannam@147: inline IndexingIterator operator++(int) { IndexingIterator other = *this; ++index; return other; } cannam@147: inline IndexingIterator& operator--() { --index; return *this; } cannam@147: inline IndexingIterator operator--(int) { IndexingIterator other = *this; --index; return other; } cannam@147: cannam@147: inline IndexingIterator operator+(uint amount) const { return IndexingIterator(container, index + amount); } cannam@147: inline IndexingIterator operator-(uint amount) const { return IndexingIterator(container, index - amount); } cannam@147: inline IndexingIterator operator+( int amount) const { return IndexingIterator(container, index + amount); } cannam@147: inline IndexingIterator operator-( int amount) const { return IndexingIterator(container, index - amount); } cannam@147: cannam@147: inline int operator-(const IndexingIterator& other) const { return index - other.index; } cannam@147: cannam@147: inline IndexingIterator& operator+=(uint amount) { index += amount; return *this; } cannam@147: inline IndexingIterator& operator-=(uint amount) { index -= amount; return *this; } cannam@147: inline IndexingIterator& operator+=( int amount) { index += amount; return *this; } cannam@147: inline IndexingIterator& operator-=( int amount) { index -= amount; return *this; } cannam@147: cannam@147: // STL says comparing iterators of different containers is not allowed, so we only compare cannam@147: // indices here. cannam@147: inline bool operator==(const IndexingIterator& other) const { return index == other.index; } cannam@147: inline bool operator!=(const IndexingIterator& other) const { return index != other.index; } cannam@147: inline bool operator<=(const IndexingIterator& other) const { return index <= other.index; } cannam@147: inline bool operator>=(const IndexingIterator& other) const { return index >= other.index; } cannam@147: inline bool operator< (const IndexingIterator& other) const { return index < other.index; } cannam@147: inline bool operator> (const IndexingIterator& other) const { return index > other.index; } cannam@147: cannam@147: private: cannam@147: Container* container; cannam@147: uint index; cannam@147: cannam@147: friend Container; cannam@147: inline IndexingIterator(Container* container, uint index) cannam@147: : container(container), index(index) {} cannam@147: }; cannam@147: cannam@147: } // namespace _ (private) cannam@147: cannam@147: template cannam@147: struct List { cannam@147: // List of primitives. cannam@147: cannam@147: List() = delete; cannam@147: cannam@147: class Reader { cannam@147: public: cannam@147: typedef List Reads; cannam@147: cannam@147: inline Reader(): reader(_::elementSizeForType()) {} cannam@147: inline explicit Reader(_::ListReader reader): reader(reader) {} cannam@147: cannam@147: inline uint size() const { return unbound(reader.size() / ELEMENTS); } cannam@147: inline T operator[](uint index) const { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return reader.template getDataElement(bounded(index) * ELEMENTS); cannam@147: } cannam@147: cannam@147: typedef _::IndexingIterator Iterator; cannam@147: inline Iterator begin() const { return Iterator(this, 0); } cannam@147: inline Iterator end() const { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListReader reader; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: template cannam@147: friend struct List; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Builder { cannam@147: public: cannam@147: typedef List Builds; cannam@147: cannam@147: inline Builder(): builder(_::elementSizeForType()) {} cannam@147: inline Builder(decltype(nullptr)): Builder() {} cannam@147: inline explicit Builder(_::ListBuilder builder): builder(builder) {} cannam@147: cannam@147: inline operator Reader() const { return Reader(builder.asReader()); } cannam@147: inline Reader asReader() const { return Reader(builder.asReader()); } cannam@147: cannam@147: inline uint size() const { return unbound(builder.size() / ELEMENTS); } cannam@147: inline T operator[](uint index) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return builder.template getDataElement(bounded(index) * ELEMENTS); cannam@147: } cannam@147: inline void set(uint index, T value) { cannam@147: // Alas, it is not possible to make operator[] return a reference to which you can assign, cannam@147: // since the encoded representation does not necessarily match the compiler's representation cannam@147: // of the type. We can't even return a clever class that implements operator T() and cannam@147: // operator=() because it will lead to surprising behavior when using type inference (e.g. cannam@147: // calling a template function with inferred argument types, or using "auto" or "decltype"). cannam@147: cannam@147: builder.template setDataElement(bounded(index) * ELEMENTS, value); cannam@147: } cannam@147: cannam@147: typedef _::IndexingIterator Iterator; cannam@147: inline Iterator begin() { return Iterator(this, 0); } cannam@147: inline Iterator end() { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListBuilder builder; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Pipeline {}; cannam@147: cannam@147: private: cannam@147: inline static _::ListBuilder initPointer(_::PointerBuilder builder, uint size) { cannam@147: return builder.initList(_::elementSizeForType(), bounded(size) * ELEMENTS); cannam@147: } cannam@147: inline static _::ListBuilder getFromPointer(_::PointerBuilder builder, const word* defaultValue) { cannam@147: return builder.getList(_::elementSizeForType(), defaultValue); cannam@147: } cannam@147: inline static _::ListReader getFromPointer( cannam@147: const _::PointerReader& reader, const word* defaultValue) { cannam@147: return reader.getList(_::elementSizeForType(), defaultValue); cannam@147: } cannam@147: cannam@147: template cannam@147: friend struct List; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: }; cannam@147: cannam@147: template cannam@147: struct List: public List {}; cannam@147: cannam@147: template cannam@147: struct List { cannam@147: // List of structs. cannam@147: cannam@147: List() = delete; cannam@147: cannam@147: class Reader { cannam@147: public: cannam@147: typedef List Reads; cannam@147: cannam@147: inline Reader(): reader(ElementSize::INLINE_COMPOSITE) {} cannam@147: inline explicit Reader(_::ListReader reader): reader(reader) {} cannam@147: cannam@147: inline uint size() const { return unbound(reader.size() / ELEMENTS); } cannam@147: inline typename T::Reader operator[](uint index) const { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return typename T::Reader(reader.getStructElement(bounded(index) * ELEMENTS)); cannam@147: } cannam@147: cannam@147: typedef _::IndexingIterator Iterator; cannam@147: inline Iterator begin() const { return Iterator(this, 0); } cannam@147: inline Iterator end() const { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListReader reader; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: template cannam@147: friend struct List; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Builder { cannam@147: public: cannam@147: typedef List Builds; cannam@147: cannam@147: inline Builder(): builder(ElementSize::INLINE_COMPOSITE) {} cannam@147: inline Builder(decltype(nullptr)): Builder() {} cannam@147: inline explicit Builder(_::ListBuilder builder): builder(builder) {} cannam@147: cannam@147: inline operator Reader() const { return Reader(builder.asReader()); } cannam@147: inline Reader asReader() const { return Reader(builder.asReader()); } cannam@147: cannam@147: inline uint size() const { return unbound(builder.size() / ELEMENTS); } cannam@147: inline typename T::Builder operator[](uint index) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return typename T::Builder(builder.getStructElement(bounded(index) * ELEMENTS)); cannam@147: } cannam@147: cannam@147: inline void adoptWithCaveats(uint index, Orphan&& orphan) { cannam@147: // Mostly behaves like you'd expect `adopt` to behave, but with two caveats originating from cannam@147: // the fact that structs in a struct list are allocated inline rather than by pointer: cannam@147: // * This actually performs a shallow copy, effectively adopting each of the orphan's cannam@147: // children rather than adopting the orphan itself. The orphan ends up being discarded, cannam@147: // possibly wasting space in the message object. cannam@147: // * If the orphan is larger than the target struct -- say, because the orphan was built cannam@147: // using a newer version of the schema that has additional fields -- it will be truncated, cannam@147: // losing data. cannam@147: cannam@147: KJ_IREQUIRE(index < size()); cannam@147: cannam@147: // We pass a zero-valued StructSize to asStruct() because we do not want the struct to be cannam@147: // expanded under any circumstances. We're just going to throw it away anyway, and cannam@147: // transferContentFrom() already carefully compares the struct sizes before transferring. cannam@147: builder.getStructElement(bounded(index) * ELEMENTS).transferContentFrom( cannam@147: orphan.builder.asStruct(_::StructSize(ZERO * WORDS, ZERO * POINTERS))); cannam@147: } cannam@147: inline void setWithCaveats(uint index, const typename T::Reader& reader) { cannam@147: // Mostly behaves like you'd expect `set` to behave, but with a caveat originating from cannam@147: // the fact that structs in a struct list are allocated inline rather than by pointer: cannam@147: // If the source struct is larger than the target struct -- say, because the source was built cannam@147: // using a newer version of the schema that has additional fields -- it will be truncated, cannam@147: // losing data. cannam@147: // cannam@147: // Note: If you are trying to concatenate some lists, use Orphanage::newOrphanConcat() to cannam@147: // do it without losing any data in case the source lists come from a newer version of the cannam@147: // protocol. (Plus, it's easier to use anyhow.) cannam@147: cannam@147: KJ_IREQUIRE(index < size()); cannam@147: builder.getStructElement(bounded(index) * ELEMENTS).copyContentFrom(reader._reader); cannam@147: } cannam@147: cannam@147: // There are no init(), set(), adopt(), or disown() methods for lists of structs because the cannam@147: // elements of the list are inlined and are initialized when the list is initialized. This cannam@147: // means that init() would be redundant, and set() would risk data loss if the input struct cannam@147: // were from a newer version of the protocol. cannam@147: cannam@147: typedef _::IndexingIterator Iterator; cannam@147: inline Iterator begin() { return Iterator(this, 0); } cannam@147: inline Iterator end() { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListBuilder builder; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Pipeline {}; cannam@147: cannam@147: private: cannam@147: inline static _::ListBuilder initPointer(_::PointerBuilder builder, uint size) { cannam@147: return builder.initStructList(bounded(size) * ELEMENTS, _::structSize()); cannam@147: } cannam@147: inline static _::ListBuilder getFromPointer(_::PointerBuilder builder, const word* defaultValue) { cannam@147: return builder.getStructList(_::structSize(), defaultValue); cannam@147: } cannam@147: inline static _::ListReader getFromPointer( cannam@147: const _::PointerReader& reader, const word* defaultValue) { cannam@147: return reader.getList(ElementSize::INLINE_COMPOSITE, defaultValue); cannam@147: } cannam@147: cannam@147: template cannam@147: friend struct List; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: }; cannam@147: cannam@147: template cannam@147: struct List, Kind::LIST> { cannam@147: // List of lists. cannam@147: cannam@147: List() = delete; cannam@147: cannam@147: class Reader { cannam@147: public: cannam@147: typedef List> Reads; cannam@147: cannam@147: inline Reader(): reader(ElementSize::POINTER) {} cannam@147: inline explicit Reader(_::ListReader reader): reader(reader) {} cannam@147: cannam@147: inline uint size() const { return unbound(reader.size() / ELEMENTS); } cannam@147: inline typename List::Reader operator[](uint index) const { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return typename List::Reader(_::PointerHelpers>::get( cannam@147: reader.getPointerElement(bounded(index) * ELEMENTS))); cannam@147: } cannam@147: cannam@147: typedef _::IndexingIterator::Reader> Iterator; cannam@147: inline Iterator begin() const { return Iterator(this, 0); } cannam@147: inline Iterator end() const { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListReader reader; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: template cannam@147: friend struct List; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Builder { cannam@147: public: cannam@147: typedef List> Builds; cannam@147: cannam@147: inline Builder(): builder(ElementSize::POINTER) {} cannam@147: inline Builder(decltype(nullptr)): Builder() {} cannam@147: inline explicit Builder(_::ListBuilder builder): builder(builder) {} cannam@147: cannam@147: inline operator Reader() const { return Reader(builder.asReader()); } cannam@147: inline Reader asReader() const { return Reader(builder.asReader()); } cannam@147: cannam@147: inline uint size() const { return unbound(builder.size() / ELEMENTS); } cannam@147: inline typename List::Builder operator[](uint index) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return typename List::Builder(_::PointerHelpers>::get( cannam@147: builder.getPointerElement(bounded(index) * ELEMENTS))); cannam@147: } cannam@147: inline typename List::Builder init(uint index, uint size) { cannam@147: KJ_IREQUIRE(index < this->size()); cannam@147: return typename List::Builder(_::PointerHelpers>::init( cannam@147: builder.getPointerElement(bounded(index) * ELEMENTS), size)); cannam@147: } cannam@147: inline void set(uint index, typename List::Reader value) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: builder.getPointerElement(bounded(index) * ELEMENTS).setList(value.reader); cannam@147: } cannam@147: void set(uint index, std::initializer_list> value) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: auto l = init(index, value.size()); cannam@147: uint i = 0; cannam@147: for (auto& element: value) { cannam@147: l.set(i++, element); cannam@147: } cannam@147: } cannam@147: inline void adopt(uint index, Orphan&& value) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: builder.getPointerElement(bounded(index) * ELEMENTS).adopt(kj::mv(value.builder)); cannam@147: } cannam@147: inline Orphan disown(uint index) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return Orphan(builder.getPointerElement(bounded(index) * ELEMENTS).disown()); cannam@147: } cannam@147: cannam@147: typedef _::IndexingIterator::Builder> Iterator; cannam@147: inline Iterator begin() { return Iterator(this, 0); } cannam@147: inline Iterator end() { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListBuilder builder; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Pipeline {}; cannam@147: cannam@147: private: cannam@147: inline static _::ListBuilder initPointer(_::PointerBuilder builder, uint size) { cannam@147: return builder.initList(ElementSize::POINTER, bounded(size) * ELEMENTS); cannam@147: } cannam@147: inline static _::ListBuilder getFromPointer(_::PointerBuilder builder, const word* defaultValue) { cannam@147: return builder.getList(ElementSize::POINTER, defaultValue); cannam@147: } cannam@147: inline static _::ListReader getFromPointer( cannam@147: const _::PointerReader& reader, const word* defaultValue) { cannam@147: return reader.getList(ElementSize::POINTER, defaultValue); cannam@147: } cannam@147: cannam@147: template cannam@147: friend struct List; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: }; cannam@147: cannam@147: template cannam@147: struct List { cannam@147: List() = delete; cannam@147: cannam@147: class Reader { cannam@147: public: cannam@147: typedef List Reads; cannam@147: cannam@147: inline Reader(): reader(ElementSize::POINTER) {} cannam@147: inline explicit Reader(_::ListReader reader): reader(reader) {} cannam@147: cannam@147: inline uint size() const { return unbound(reader.size() / ELEMENTS); } cannam@147: inline typename T::Reader operator[](uint index) const { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return reader.getPointerElement(bounded(index) * ELEMENTS) cannam@147: .template getBlob(nullptr, ZERO * BYTES); cannam@147: } cannam@147: cannam@147: typedef _::IndexingIterator Iterator; cannam@147: inline Iterator begin() const { return Iterator(this, 0); } cannam@147: inline Iterator end() const { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListReader reader; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: template cannam@147: friend struct List; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Builder { cannam@147: public: cannam@147: typedef List Builds; cannam@147: cannam@147: inline Builder(): builder(ElementSize::POINTER) {} cannam@147: inline Builder(decltype(nullptr)): Builder() {} cannam@147: inline explicit Builder(_::ListBuilder builder): builder(builder) {} cannam@147: cannam@147: inline operator Reader() const { return Reader(builder.asReader()); } cannam@147: inline Reader asReader() const { return Reader(builder.asReader()); } cannam@147: cannam@147: inline uint size() const { return unbound(builder.size() / ELEMENTS); } cannam@147: inline typename T::Builder operator[](uint index) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return builder.getPointerElement(bounded(index) * ELEMENTS) cannam@147: .template getBlob(nullptr, ZERO * BYTES); cannam@147: } cannam@147: inline void set(uint index, typename T::Reader value) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: builder.getPointerElement(bounded(index) * ELEMENTS).template setBlob(value); cannam@147: } cannam@147: inline typename T::Builder init(uint index, uint size) { cannam@147: KJ_IREQUIRE(index < this->size()); cannam@147: return builder.getPointerElement(bounded(index) * ELEMENTS) cannam@147: .template initBlob(bounded(size) * BYTES); cannam@147: } cannam@147: inline void adopt(uint index, Orphan&& value) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: builder.getPointerElement(bounded(index) * ELEMENTS).adopt(kj::mv(value.builder)); cannam@147: } cannam@147: inline Orphan disown(uint index) { cannam@147: KJ_IREQUIRE(index < size()); cannam@147: return Orphan(builder.getPointerElement(bounded(index) * ELEMENTS).disown()); cannam@147: } cannam@147: cannam@147: typedef _::IndexingIterator Iterator; cannam@147: inline Iterator begin() { return Iterator(this, 0); } cannam@147: inline Iterator end() { return Iterator(this, size()); } cannam@147: cannam@147: private: cannam@147: _::ListBuilder builder; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: friend class Orphanage; cannam@147: template cannam@147: friend struct ToDynamic_; cannam@147: }; cannam@147: cannam@147: class Pipeline {}; cannam@147: cannam@147: private: cannam@147: inline static _::ListBuilder initPointer(_::PointerBuilder builder, uint size) { cannam@147: return builder.initList(ElementSize::POINTER, bounded(size) * ELEMENTS); cannam@147: } cannam@147: inline static _::ListBuilder getFromPointer(_::PointerBuilder builder, const word* defaultValue) { cannam@147: return builder.getList(ElementSize::POINTER, defaultValue); cannam@147: } cannam@147: inline static _::ListReader getFromPointer( cannam@147: const _::PointerReader& reader, const word* defaultValue) { cannam@147: return reader.getList(ElementSize::POINTER, defaultValue); cannam@147: } cannam@147: cannam@147: template cannam@147: friend struct List; cannam@147: template cannam@147: friend struct _::PointerHelpers; cannam@147: }; cannam@147: cannam@147: } // namespace capnp cannam@147: cannam@147: #ifdef KJ_STD_COMPAT cannam@147: namespace std { cannam@147: cannam@147: template cannam@147: struct iterator_traits> cannam@147: : public std::iterator {}; cannam@147: cannam@147: } // namespace std cannam@147: #endif // KJ_STD_COMPAT cannam@147: cannam@147: #endif // CAPNP_LIST_H_