InputStream.h

Go to the documentation of this file.

//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
 
#ifndef ICE_INPUT_STREAM_H
#define ICE_INPUT_STREAM_H
 
#include <Ice/CommunicatorF.h>
#include <Ice/InstanceF.h>
#include <Ice/Object.h>
#include <Ice/ValueF.h>
#include <Ice/ProxyF.h>
#include <Ice/LoggerF.h>
#include <Ice/ValueFactory.h>
#include <Ice/Buffer.h>
#include <Ice/Protocol.h>
#include <Ice/SlicedDataF.h>
#include <Ice/UserExceptionFactory.h>
#include <Ice/StreamHelpers.h>
#include <Ice/FactoryTable.h>
 
namespace Ice
{
 
class UserException;
 
template<typename T> inline void
patchHandle(void* addr, const ValuePtr& v)
{
#ifdef ICE_CPP11_MAPPING
    ::std::shared_ptr<T>* handle = static_cast<::std::shared_ptr<T>*>(addr);
    *handle = ::std::dynamic_pointer_cast<T>(v);
    if(v && !(*handle))
    {
        IceInternal::Ex::throwUOE(T::ice_staticId(), v);
    }
#else
    IceInternal::Handle<T>* p = static_cast<IceInternal::Handle<T>*>(addr);
    _icePatchObjectPtr(*p, v); // Generated _icePatchObjectPtr function, necessary for forward declarations.
#endif
}
 
class ICE_API InputStream : public IceInternal::Buffer
{
public:
 
    typedef size_t size_type;
 
    typedef void (*PatchFunc)(void* addr, const ValuePtr& v);
 
    InputStream();
 
    InputStream(const std::vector<Byte>& bytes);
 
    InputStream(const std::pair<const Byte*, const Byte*>& bytes);
 
    InputStream(IceInternal::Buffer&, bool = false);
 
    InputStream(const CommunicatorPtr& communicator);
 
    InputStream(const CommunicatorPtr& communicator, const std::vector<Byte>& bytes);
 
    InputStream(const CommunicatorPtr& communicator, const std::pair<const Byte*, const Byte*>& bytes);
 
    InputStream(const CommunicatorPtr& communicator, IceInternal::Buffer&, bool = false);
 
    InputStream(const EncodingVersion& version);
 
    InputStream(const EncodingVersion& version, const std::vector<Byte>& bytes);
 
    InputStream(const EncodingVersion& version, const std::pair<const Byte*, const Byte*>& bytes);
 
    InputStream(const EncodingVersion&, IceInternal::Buffer&, bool = false);
 
    InputStream(const CommunicatorPtr& communicator, const EncodingVersion& version);
 
    InputStream(const CommunicatorPtr& communicator, const EncodingVersion& version, const std::vector<Byte>& bytes);
 
    InputStream(const CommunicatorPtr& communicator, const EncodingVersion& version,
                const std::pair<const Byte*, const Byte*>& bytes);
 
    InputStream(const CommunicatorPtr&, const EncodingVersion&, IceInternal::Buffer&, bool = false);
 
    ~InputStream()
    {
        // Inlined for performance reasons.
 
        if(_currentEncaps != &_preAllocatedEncaps)
        {
            clear(); // Not inlined.
        }
 
#ifdef ICE_CPP11_MAPPING
 
        for(auto d: _deleters)
        {
            d();
        }
#endif
    }
 
    void initialize(const CommunicatorPtr& communicator);
 
    void initialize(const CommunicatorPtr& communicator, const EncodingVersion& version);
 
    void clear();
 
    //
    // Must return Instance*, because we don't hold an InstancePtr for
    // optimization reasons (see comments below).
    //
    IceInternal::Instance* instance() const { return _instance; } // Inlined for performance reasons.
 
    void setValueFactoryManager(const ValueFactoryManagerPtr& vfm);
 
    void setLogger(const LoggerPtr& logger);
 
#ifdef ICE_CPP11_MAPPING
    void setCompactIdResolver(std::function<std::string(int)> r);
#else
    void setCompactIdResolver(const CompactIdResolverPtr& r);
#endif
 
#ifndef ICE_CPP11_MAPPING
 
    void setCollectObjects(bool b);
#endif
 
    void setSliceValues(bool b);
 
    void setTraceSlicing(bool b);
 
    void setClassGraphDepthMax(size_t n);
 
    void* getClosure() const;
 
    void* setClosure(void* p);
 
    void swap(InputStream& other);
 
    void resetEncapsulation();
 
    void resize(Container::size_type sz)
    {
        b.resize(sz);
        i = b.end();
    }
 
    void startValue()
    {
        assert(_currentEncaps && _currentEncaps->decoder);
        _currentEncaps->decoder->startInstance(ValueSlice);
    }
 
    SlicedDataPtr endValue(bool preserve)
    {
        assert(_currentEncaps && _currentEncaps->decoder);
        return _currentEncaps->decoder->endInstance(preserve);
    }
 
    void startException()
    {
        assert(_currentEncaps && _currentEncaps->decoder);
        _currentEncaps->decoder->startInstance(ExceptionSlice);
    }
 
    SlicedDataPtr endException(bool preserve)
    {
        assert(_currentEncaps && _currentEncaps->decoder);
        return _currentEncaps->decoder->endInstance(preserve);
    }
 
    const EncodingVersion& startEncapsulation()
    {
        Encaps* oldEncaps = _currentEncaps;
        if(!oldEncaps) // First allocated encaps?
        {
            _currentEncaps = &_preAllocatedEncaps;
        }
        else
        {
            _currentEncaps = new Encaps();
            _currentEncaps->previous = oldEncaps;
        }
        _currentEncaps->start = static_cast<size_t>(i - b.begin());
 
        //
        // I don't use readSize() and writeSize() for encapsulations,
        // because when creating an encapsulation, I must know in advance
        // how many bytes the size information will require in the data
        // stream. If I use an Int, it is always 4 bytes. For
        // readSize()/writeSize(), it could be 1 or 5 bytes.
        //
        Int sz;
        read(sz);
        if(sz < 6)
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
        if(i - sizeof(Int) + sz > b.end())
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
        _currentEncaps->sz = sz;
 
        read(_currentEncaps->encoding);
        IceInternal::checkSupportedEncoding(_currentEncaps->encoding); // Make sure the encoding is supported
 
        return _currentEncaps->encoding;
    }
 
    void endEncapsulation()
    {
        assert(_currentEncaps);
 
        if(_currentEncaps->encoding != Encoding_1_0)
        {
            skipOptionals();
            if(i != b.begin() + _currentEncaps->start + _currentEncaps->sz)
            {
                throwEncapsulationException(__FILE__, __LINE__);
            }
        }
        else if(i != b.begin() + _currentEncaps->start + _currentEncaps->sz)
        {
            if(i + 1 != b.begin() + _currentEncaps->start + _currentEncaps->sz)
            {
                throwEncapsulationException(__FILE__, __LINE__);
            }
 
            //
            // Ice version < 3.3 had a bug where user exceptions with
            // class members could be encoded with a trailing byte
            // when dispatched with AMD. So we tolerate an extra byte
            // in the encapsulation.
            //
            ++i;
        }
 
        Encaps* oldEncaps = _currentEncaps;
        _currentEncaps = _currentEncaps->previous;
        if(oldEncaps == &_preAllocatedEncaps)
        {
            oldEncaps->reset();
        }
        else
        {
            delete oldEncaps;
        }
    }
 
    EncodingVersion skipEmptyEncapsulation()
    {
        Ice::Int sz;
        read(sz);
        if(sz < 6)
        {
            throwEncapsulationException(__FILE__, __LINE__);
        }
        if(i - sizeof(Ice::Int) + sz > b.end())
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
        Ice::EncodingVersion encoding;
        read(encoding);
        IceInternal::checkSupportedEncoding(encoding); // Make sure the encoding is supported
 
        if(encoding == Ice::Encoding_1_0)
        {
            if(sz != static_cast<Ice::Int>(sizeof(Ice::Int)) + 2)
            {
                throwEncapsulationException(__FILE__, __LINE__);
            }
        }
        else
        {
            // Skip the optional content of the encapsulation if we are expecting an
            // empty encapsulation.
            i += static_cast<size_t>(sz) - sizeof(Ice::Int) - 2;
        }
        return encoding;
    }
 
    EncodingVersion readEncapsulation(const Byte*& v, Int& sz)
    {
        EncodingVersion encoding;
        v = i;
        read(sz);
        if(sz < 6)
        {
            throwEncapsulationException(__FILE__, __LINE__);
        }
        if(i - sizeof(Int) + sz > b.end())
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
 
        read(encoding);
        i += static_cast<size_t>(sz) - sizeof(Int) - 2;
        return encoding;
    }
 
    const EncodingVersion& getEncoding() const
    {
        return _currentEncaps ? _currentEncaps->encoding : _encoding;
    }
 
    Int getEncapsulationSize();
 
    EncodingVersion skipEncapsulation();
 
    std::string startSlice()
    {
        assert(_currentEncaps && _currentEncaps->decoder);
        return _currentEncaps->decoder->startSlice();
    }
 
    void endSlice()
    {
        assert(_currentEncaps && _currentEncaps->decoder);
        _currentEncaps->decoder->endSlice();
    }
 
    void skipSlice()
    {
        assert(_currentEncaps && _currentEncaps->decoder);
        _currentEncaps->decoder->skipSlice();
    }
 
    void readPendingValues();
 
    Int readSize() // Inlined for performance reasons.
    {
        Byte byte;
        read(byte);
        unsigned char val = static_cast<unsigned char>(byte);
        if(val == 255)
        {
            Int v;
            read(v);
            if(v < 0)
            {
                throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
            }
            return v;
        }
        else
        {
            return static_cast<Int>(static_cast<unsigned char>(byte));
        }
    }
 
    Int readAndCheckSeqSize(int minSize);
 
    void readBlob(std::vector<Byte>& bytes, Int sz);
 
    void readBlob(const Byte*& v, Container::size_type sz)
    {
        if(sz > 0)
        {
            v = i;
            if(static_cast<Container::size_type>(b.end() - i) < sz)
            {
                throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
            }
            i += sz;
        }
        else
        {
            v = i;
        }
    }
 
    template<typename T> void read(T& v)
    {
        StreamHelper<T, StreamableTraits<T>::helper>::read(this, v);
    }
 
    template<typename T> void read(Int tag, IceUtil::Optional<T>& v)
    {
        if(readOptional(tag, StreamOptionalHelper<T,
                                             StreamableTraits<T>::helper,
                                             StreamableTraits<T>::fixedLength>::optionalFormat))
        {
#ifdef ICE_CPP11_MAPPING
            v.emplace();
#else
            v.__setIsSet();
#endif
            StreamOptionalHelper<T,
                                 StreamableTraits<T>::helper,
                                 StreamableTraits<T>::fixedLength>::read(this, *v);
        }
        else
        {
            v = IceUtil::None;
        }
    }
 
#ifdef ICE_CPP11_MAPPING
 
    template<typename T> void read(std::pair<const T*, const T*>& v)
    {
        auto holder = new std::vector<T>;
        _deleters.push_back([holder] { delete holder; });
        read(*holder);
        if(holder->size() > 0)
        {
            v.first = holder->data();
            v.second = holder->data() + holder->size();
        }
        else
        {
            v.first = 0;
            v.second = 0;
        }
    }
 
    template<typename T> void readAll(T& v)
    {
        read(v);
    }
 
    template<typename T, typename... Te> void readAll(T& v, Te&... ve)
    {
        read(v);
        readAll(ve...);
    }
 
    template<typename T>
    void readAll(std::initializer_list<int> tags, IceUtil::Optional<T>& v)
    {
        read(*(tags.begin() + tags.size() - 1), v);
    }
 
    template<typename T, typename... Te>
    void readAll(std::initializer_list<int> tags, IceUtil::Optional<T>& v, IceUtil::Optional<Te>&... ve)
    {
        size_t index = tags.size() - sizeof...(ve) - 1;
        read(*(tags.begin() + index), v);
        readAll(tags, ve...);
    }
 
#endif
 
    bool readOptional(Int tag, OptionalFormat expectedFormat)
    {
        assert(_currentEncaps);
        if(_currentEncaps->decoder)
        {
            return _currentEncaps->decoder->readOptional(tag, expectedFormat);
        }
        else
        {
            return readOptImpl(tag, expectedFormat);
        }
    }
 
    void read(Byte& v)
    {
        if(i >= b.end())
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
        v = *i++;
    }
 
    void read(std::vector<Byte>& v);
 
    void read(std::pair<const Byte*, const Byte*>& v);
 
#ifndef ICE_CPP11_MAPPING
 
    void read(std::pair<const Byte*, const Byte*>& v, ::IceUtil::ScopedArray<Byte>& arr)
    {
        arr.reset();
        read(v);
    }
#endif
 
    void read(bool& v)
    {
        if(i >= b.end())
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
        v = (0 != *i++);
    }
 
    void read(std::vector<bool>& v);
 
#ifdef ICE_CPP11_MAPPING
 
    void read(std::pair<const bool*, const bool*>& v);
#else
 
    void read(std::pair<const bool*, const bool*>& v, ::IceUtil::ScopedArray<bool>& arr);
#endif
 
    void read(Short& v);
 
    void read(std::vector<Short>& v);
 
#ifdef ICE_CPP11_MAPPING
 
    void read(std::pair<const short*, const short*>& v);
#else
 
    void read(std::pair<const Short*, const Short*>& v, ::IceUtil::ScopedArray<Short>& arr);
#endif
 
    void read(Int& v) // Inlined for performance reasons.
    {
        if(b.end() - i < static_cast<int>(sizeof(Int)))
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
        const Byte* src = &(*i);
        i += sizeof(Int);
#ifdef ICE_BIG_ENDIAN
        Byte* dest = reinterpret_cast<Byte*>(&v) + sizeof(Int) - 1;
        *dest-- = *src++;
        *dest-- = *src++;
        *dest-- = *src++;
        *dest = *src;
#else
        Byte* dest = reinterpret_cast<Byte*>(&v);
        *dest++ = *src++;
        *dest++ = *src++;
        *dest++ = *src++;
        *dest = *src;
#endif
    }
 
    void read(std::vector<Int>& v);
 
#ifdef ICE_CPP11_MAPPING
 
    void read(std::pair<const int*, const int*>& v);
#else
 
    void read(std::pair<const Int*, const Int*>& v, ::IceUtil::ScopedArray<Int>& arr);
#endif
 
    void read(Long& v);
 
    void read(std::vector<Long>& v);
 
#ifdef ICE_CPP11_MAPPING
 
    void read(std::pair<const long long*, const long long*>& v);
#else
 
    void read(std::pair<const Long*, const Long*>& v, ::IceUtil::ScopedArray<Long>& arr);
#endif
 
    void read(Float& v);
 
    void read(std::vector<Float>& v);
 
#ifdef ICE_CPP11_MAPPING
 
    void read(std::pair<const float*, const float*>& v);
#else
 
    void read(std::pair<const Float*, const Float*>& v, ::IceUtil::ScopedArray<Float>& arr);
#endif
 
    void read(Double& v);
 
    void read(std::vector<Double>& v);
 
#ifdef ICE_CPP11_MAPPING
 
    void read(std::pair<const double*, const double*>& v);
#else
 
    void read(std::pair<const Double*, const Double*>& v, ::IceUtil::ScopedArray<Double>& arr);
#endif
 
    void read(std::string& v, bool convert = true);
 
#ifdef ICE_CPP11_MAPPING
 
    void read(const char*& vdata, size_t& vsize, bool convert = true);
#else
    // For custom strings, convert = false
    void read(const char*& vdata, size_t& vsize);
 
    // For custom strings, convert = true
    void read(const char*& vdata, size_t& vsize, std::string& holder);
#endif
 
    void read(std::vector<std::string>& v, bool convert = true);
 
    void read(std::wstring& v);
 
    void read(std::vector<std::wstring>& v);
 
#ifdef ICE_CPP11_MAPPING
 
    std::shared_ptr<ObjectPrx> readProxy();
 
    template<typename T, typename ::std::enable_if<::std::is_base_of<ObjectPrx, T>::value>::type* = nullptr>
    void read(::std::shared_ptr<T>& v)
    {
        ::std::shared_ptr<ObjectPrx> proxy(readProxy());
        if(!proxy)
        {
            v = 0;
        }
        else
        {
            v = ::IceInternal::createProxy<T>();
            v->_copyFrom(proxy);
        }
    }
#else
 
    void read(ObjectPrx& v);
 
    template<typename T> void read(IceInternal::ProxyHandle<T>& v)
    {
        _readProxy(this, v); // Generated _readProxy method, necessary for forward declarations.
    }
#endif
 
#ifdef ICE_CPP11_MAPPING // C++11 mapping
    template<typename T, typename ::std::enable_if<::std::is_base_of<Value, T>::value>::type* = nullptr>
    void read(::std::shared_ptr<T>& v)
    {
        read(&patchHandle<T>, &v);
    }
#else // C++98 mapping
    template<typename T> void read(IceInternal::Handle<T>& v)
    {
        read(&patchHandle<T>, &v);
    }
#endif
 
    void read(PatchFunc patchFunc, void* patchAddr)
    {
        initEncaps();
        _currentEncaps->decoder->read(patchFunc, patchAddr);
    }
 
    Int readEnum(Int maxValue);
 
    void throwException(ICE_IN(ICE_DELEGATE(UserExceptionFactory)) factory = ICE_NULLPTR);
 
    void skipOptional(OptionalFormat format);
 
    void skipOptionals();
 
    void skip(size_type size)
    {
        if(i + size > b.end())
        {
            throwUnmarshalOutOfBoundsException(__FILE__, __LINE__);
        }
        i += size;
    }
 
    void skipSize()
    {
        Byte bt;
        read(bt);
        if(static_cast<unsigned char>(bt) == 255)
        {
            skip(4);
        }
    }
 
    size_type pos()
    {
        return static_cast<size_t>(i - b.begin());
    }
 
    void pos(size_type p)
    {
        i = b.begin() + p;
    }
 
    InputStream(IceInternal::Instance*, const EncodingVersion&);
    InputStream(IceInternal::Instance*, const EncodingVersion&, IceInternal::Buffer&, bool = false);
 
    void initialize(IceInternal::Instance*, const EncodingVersion&);
 
    bool readOptImpl(Int, OptionalFormat);
 
private:
 
    void initialize(const EncodingVersion&);
 
    //
    // String
    //
    bool readConverted(std::string&, Int);
 
    //
    // We can't throw these exception from inline functions from within
    // this file, because we cannot include the header with the
    // exceptions. Doing so would screw up the whole include file
    // ordering.
    //
    void throwUnmarshalOutOfBoundsException(const char*, int);
    void throwEncapsulationException(const char*, int);
 
    std::string resolveCompactId(int) const;
 
    void postUnmarshal(const ValuePtr&) const;
 
    class Encaps;
    enum SliceType { NoSlice, ValueSlice, ExceptionSlice };
 
    void traceSkipSlice(const std::string&, SliceType) const;
 
    ValueFactoryManagerPtr valueFactoryManager() const;
 
    LoggerPtr logger() const;
 
#ifdef ICE_CPP11_MAPPING
    std::function<std::string(int)> compactIdResolver() const;
#else
    CompactIdResolverPtr compactIdResolver() const;
#endif
 
    typedef std::vector<ValuePtr> ValueList;
 
    class ICE_API EncapsDecoder : private ::IceUtil::noncopyable
    {
    public:
 
        virtual ~EncapsDecoder();
 
        virtual void read(PatchFunc, void*) = 0;
        virtual void throwException(ICE_IN(ICE_DELEGATE(UserExceptionFactory))) = 0;
 
        virtual void startInstance(SliceType) = 0;
        virtual SlicedDataPtr endInstance(bool) = 0;
        virtual const std::string& startSlice() = 0;
        virtual void endSlice() = 0;
        virtual void skipSlice() = 0;
 
        virtual bool readOptional(Int, OptionalFormat)
        {
            return false;
        }
 
        virtual void readPendingValues()
        {
        }
 
    protected:
 
        EncapsDecoder(InputStream* stream, Encaps* encaps, bool sliceValues, size_t classGraphDepthMax,
                      const Ice::ValueFactoryManagerPtr& f) :
            _stream(stream), _encaps(encaps), _sliceValues(sliceValues), _classGraphDepthMax(classGraphDepthMax),
            _classGraphDepth(0), _valueFactoryManager(f), _typeIdIndex(0)
        {
        }
 
        std::string readTypeId(bool);
        ValuePtr newInstance(const std::string&);
 
        void addPatchEntry(Int, PatchFunc, void*);
        void unmarshal(Int, const ValuePtr&);
 
        typedef std::map<Int, ValuePtr> IndexToPtrMap;
        typedef std::map<Int, std::string> TypeIdMap;
 
        struct PatchEntry
        {
            PatchFunc patchFunc;
            void* patchAddr;
            size_t classGraphDepth;
        };
        typedef std::vector<PatchEntry> PatchList;
        typedef std::map<Int, PatchList> PatchMap;
 
        InputStream* _stream;
        Encaps* _encaps;
        const bool _sliceValues;
        const size_t _classGraphDepthMax;
        size_t _classGraphDepth;
        Ice::ValueFactoryManagerPtr _valueFactoryManager;
 
        // Encapsulation attributes for object un-marshalling
        PatchMap _patchMap;
 
    private:
 
        // Encapsulation attributes for object un-marshalling
        IndexToPtrMap _unmarshaledMap;
        TypeIdMap _typeIdMap;
        Int _typeIdIndex;
        ValueList _valueList;
    };
 
    class ICE_API EncapsDecoder10 : public EncapsDecoder
    {
    public:
 
        EncapsDecoder10(InputStream* stream, Encaps* encaps, bool sliceValues, size_t classGraphDepthMax,
                        const Ice::ValueFactoryManagerPtr& f) :
            EncapsDecoder(stream, encaps, sliceValues, classGraphDepthMax, f),
            _sliceType(NoSlice)
        {
        }
 
        virtual void read(PatchFunc, void*);
        virtual void throwException(ICE_IN(ICE_DELEGATE(UserExceptionFactory)));
 
        virtual void startInstance(SliceType);
        virtual SlicedDataPtr endInstance(bool);
        virtual const std::string& startSlice();
        virtual void endSlice();
        virtual void skipSlice();
 
        virtual void readPendingValues();
 
    private:
 
        void readInstance();
 
        // Instance attributes
        SliceType _sliceType;
        bool _skipFirstSlice;
 
        // Slice attributes
        Int _sliceSize;
        std::string _typeId;
    };
 
    class ICE_API EncapsDecoder11 : public EncapsDecoder
    {
    public:
 
        EncapsDecoder11(InputStream* stream, Encaps* encaps, bool sliceValues, size_t classGraphDepthMax,
                        const Ice::ValueFactoryManagerPtr& f) :
            EncapsDecoder(stream, encaps, sliceValues, classGraphDepthMax, f),
            _preAllocatedInstanceData(0), _current(0), _valueIdIndex(1)
        {
        }
 
        virtual void read(PatchFunc, void*);
        virtual void throwException(ICE_IN(ICE_DELEGATE(UserExceptionFactory)));
 
        virtual void startInstance(SliceType);
        virtual SlicedDataPtr endInstance(bool);
        virtual const std::string& startSlice();
        virtual void endSlice();
        virtual void skipSlice();
 
        virtual bool readOptional(Int, OptionalFormat);
 
    private:
 
        Int readInstance(Int, PatchFunc, void*);
        SlicedDataPtr readSlicedData();
 
        struct IndirectPatchEntry
        {
            Int index;
            PatchFunc patchFunc;
            void* patchAddr;
        };
        typedef std::vector<IndirectPatchEntry> IndirectPatchList;
 
        typedef std::vector<Int> IndexList;
        typedef std::vector<IndexList> IndexListList;
 
        struct InstanceData
        {
            InstanceData(InstanceData* p) : previous(p), next(0)
            {
                if(previous)
                {
                    previous->next = this;
                }
            }
 
            ~InstanceData()
            {
                if(next)
                {
                    delete next;
                }
            }
 
            // Instance attributes
            SliceType sliceType;
            bool skipFirstSlice;
            SliceInfoSeq slices; // Preserved slices.
            IndexListList indirectionTables;
 
            // Slice attributes
            Byte sliceFlags;
            Int sliceSize;
            std::string typeId;
            int compactId;
            IndirectPatchList indirectPatchList;
 
            InstanceData* previous;
            InstanceData* next;
        };
        InstanceData _preAllocatedInstanceData;
        InstanceData* _current;
 
        void push(SliceType sliceType)
        {
            if(!_current)
            {
                _current = &_preAllocatedInstanceData;
            }
            else
            {
                _current = _current->next ? _current->next : new InstanceData(_current);
            }
            _current->sliceType = sliceType;
            _current->skipFirstSlice = false;
        }
 
        Int _valueIdIndex; // The ID of the next value to unmarshal.
    };
 
    class Encaps : private ::IceUtil::noncopyable
    {
    public:
 
        Encaps() : start(0), decoder(0), previous(0)
        {
            // Inlined for performance reasons.
        }
        ~Encaps()
        {
            // Inlined for performance reasons.
            delete decoder;
        }
        void reset()
        {
            // Inlined for performance reasons.
            delete decoder;
            decoder = 0;
 
            previous = 0;
        }
 
        Container::size_type start;
        Int sz;
        EncodingVersion encoding;
 
        EncapsDecoder* decoder;
 
        Encaps* previous;
    };
 
    //
    // Optimization. The instance may not be deleted while a
    // stack-allocated stream still holds it.
    //
    IceInternal::Instance* _instance;
 
    //
    // The encoding version to use when there's no encapsulation to
    // read from. This is for example used to read message headers.
    //
    EncodingVersion _encoding;
 
    Encaps* _currentEncaps;
 
    void initEncaps();
 
    Encaps _preAllocatedEncaps;
 
#ifndef ICE_CPP11_MAPPING
    bool _collectObjects;
#endif
 
    bool _traceSlicing;
 
    size_t _classGraphDepthMax;
 
    void* _closure;
 
    bool _sliceValues;
 
    int _startSeq;
    int _minSeqSize;
 
    ValueFactoryManagerPtr _valueFactoryManager;
    LoggerPtr _logger;
#ifdef ICE_CPP11_MAPPING
    std::function<std::string(int)> _compactIdResolver;
#else
    CompactIdResolverPtr _compactIdResolver;
#endif
 
#ifdef ICE_CPP11_MAPPING
    std::vector<std::function<void()>> _deleters;
#endif
 
};
 
} // End namespace Ice
 
#endif