1 files changed, 830 insertions, 0 deletions
diff --git a/matlab/src/IceMatlab/InputStream.cpp b/matlab/src/IceMatlab/InputStream.cpp
new file mode 100644
index 00000000000..33633f0d3f9
--- /dev/null
+++ b/matlab/src/IceMatlab/InputStream.cpp
@@ -0,0 +1,830 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+#define EXPORT_FCNS
+
+#include <Ice/Ice.h>
+#include <Ice/Optional.h>
+#include "icematlab.h"
+#include "InputStream.h"
+#include "Util.h"
+
+#define SELF (reinterpret_cast<IceMatlab::InputStreamData*>(self))
+
+using namespace std;
+using namespace IceMatlab;
+
+void*
+IceMatlab::createInputStream(const shared_ptr<Ice::Communicator>& communicator, const Ice::EncodingVersion& encoding,
+                             vector<Ice::Byte>& data)
+{
+    InputStreamData* p = new InputStreamData;
+    p->data.swap(data);
+    p->in = new Ice::InputStream(communicator, encoding, p->data);
+    return p;
+}
+
+namespace
+{
+
+template<typename T>
+mxArray*
+readSeq(Ice::InputStream* in, mxClassID cls)
+{
+    try
+    {
+        pair<const T*, const T*> p;
+        in->read(p);
+        const size_t nelem = p.second - p.first;
+        if(nelem > 0)
+        {
+            mxArray* r = mxCreateUninitNumericMatrix(1, nelem, cls, mxREAL);
+            memcpy(reinterpret_cast<T*>(mxGetData(r)), p.first, nelem * sizeof(T));
+            return createResultValue(r);
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+template<typename T>
+mxArray*
+readOpt(Ice::InputStream* in, int tag, mxClassID cls)
+{
+    try
+    {
+        Ice::optional<T> opt;
+        in->read(tag, opt);
+        if(opt.has_value())
+        {
+            mxArray* r = mxCreateUninitNumericMatrix(1, 1, cls, mxREAL);
+            *(reinterpret_cast<T*>(mxGetData(r))) = opt.value();
+            return createResultValue(r);
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+template<typename T>
+mxArray*
+readSeqOpt(Ice::InputStream* in, int tag, mxClassID cls)
+{
+    try
+    {
+        Ice::optional<pair<const T*, const T*>> opt;
+        in->read(tag, opt);
+        const size_t sz = opt.value().second - opt.value().first;
+        if(opt.has_value() && sz > 0)
+        {
+            mxArray* r = mxCreateUninitNumericMatrix(1, sz / sizeof(T), cls, mxREAL);
+            memcpy(reinterpret_cast<T*>(mxGetData(r)), opt.value().first, sz);
+            return createResultValue(r);
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+}
+
+extern "C"
+{
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream__release(void* self)
+{
+    delete SELF->in;
+    delete SELF;
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readBool(void* self, unsigned char* v)
+{
+    try
+    {
+        bool b;
+        SELF->in->read(b);
+        *v = b ? 1 : 0;
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readBoolSeq(void* self)
+{
+    try
+    {
+        pair<const bool*, const bool*> p;
+        SELF->in->read(p);
+        const size_t sz = p.second - p.first;
+        if(sz > 0)
+        {
+            mxArray* r = mxCreateLogicalMatrix(1, sz);
+            memcpy(mxGetLogicals(r), p.first, sz);
+            return createResultValue(r);
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readBoolOpt(void* self, int tag)
+{
+    try
+    {
+        Ice::optional<bool> opt;
+        SELF->in->read(tag, opt);
+        if(opt.has_value())
+        {
+            return createResultValue(mxCreateLogicalScalar(opt.value()));
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readBoolSeqOpt(void* self, int tag)
+{
+    try
+    {
+        Ice::optional<pair<const bool*, const bool*>> opt;
+        SELF->in->read(tag, opt);
+        const size_t sz = opt.value().second - opt.value().first;
+        if(opt.has_value() && sz > 0)
+        {
+            mxArray* r = mxCreateLogicalMatrix(1, sz);
+            memcpy(mxGetLogicals(r), opt.value().first, sz);
+            return createResultValue(r);
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readByte(void* self, unsigned char* v)
+{
+    try
+    {
+        Ice::Byte b;
+        SELF->in->read(b);
+        *v = b;
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readByteSeq(void* self)
+{
+    return readSeq<Ice::Byte>(SELF->in, mxUINT8_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readByteOpt(void* self, int tag)
+{
+    return readOpt<Ice::Byte>(SELF->in, tag, mxUINT8_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readByteSeqOpt(void* self, int tag)
+{
+    return readSeqOpt<Ice::Byte>(SELF->in, tag, mxUINT8_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readShort(void* self, short* v)
+{
+    try
+    {
+        SELF->in->read(*v);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readShortSeq(void* self)
+{
+    return readSeq<short>(SELF->in, mxINT16_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readShortOpt(void* self, int tag)
+{
+    return readOpt<short>(SELF->in, tag, mxINT16_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readShortSeqOpt(void* self, int tag)
+{
+    return readSeqOpt<short>(SELF->in, tag, mxINT16_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readInt(void* self, int* v)
+{
+    try
+    {
+        SELF->in->read(*v);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readIntSeq(void* self)
+{
+    return readSeq<int>(SELF->in, mxINT32_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readIntOpt(void* self, int tag)
+{
+    return readOpt<int>(SELF->in, tag, mxINT32_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readIntSeqOpt(void* self, int tag)
+{
+    return readSeqOpt<int>(SELF->in, tag, mxINT32_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readLong(void* self, long long* v)
+{
+    try
+    {
+        SELF->in->read(*v);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readLongSeq(void* self)
+{
+    return readSeq<long long>(SELF->in, mxINT64_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readLongOpt(void* self, int tag)
+{
+    return readOpt<long long>(SELF->in, tag, mxINT64_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readLongSeqOpt(void* self, int tag)
+{
+    return readSeqOpt<long long>(SELF->in, tag, mxINT64_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readFloat(void* self, float* v)
+{
+    try
+    {
+        SELF->in->read(*v);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readFloatSeq(void* self)
+{
+    return readSeq<float>(SELF->in, mxSINGLE_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readFloatOpt(void* self, int tag)
+{
+    return readOpt<float>(SELF->in, tag, mxSINGLE_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readFloatSeqOpt(void* self, int tag)
+{
+    return readSeqOpt<float>(SELF->in, tag, mxSINGLE_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readDouble(void* self, double* v)
+{
+    try
+    {
+        SELF->in->read(*v);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readDoubleSeq(void* self)
+{
+    return readSeq<double>(SELF->in, mxDOUBLE_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readDoubleOpt(void* self, int tag)
+{
+    return readOpt<double>(SELF->in, tag, mxDOUBLE_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readDoubleSeqOpt(void* self, int tag)
+{
+    return readSeqOpt<double>(SELF->in, tag, mxDOUBLE_CLASS);
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readString(void* self)
+{
+    string s;
+    try
+    {
+        SELF->in->read(s, false);
+        return createResultValue(createStringFromUTF8(s));
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readStringSeq(void* self)
+{
+    try
+    {
+        vector<string> v;
+        SELF->in->read(v, false);
+        return createResultValue(createStringList(v));
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readStringOpt(void* self, int tag)
+{
+    try
+    {
+        Ice::optional<string> opt;
+        SELF->in->read(tag, opt);
+        if(opt.has_value())
+        {
+            return createResultValue(createStringFromUTF8(opt.value()));
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readStringSeqOpt(void* self, int tag)
+{
+    try
+    {
+        if(SELF->in->readOptional(tag, Ice::OptionalFormat::FSize))
+        {
+            SELF->in->skip(4);
+            return Ice_InputStream_readStringSeq(self);
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_skip(void* self, int n)
+{
+    try
+    {
+        SELF->in->skip(n);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_startException(void* self)
+{
+    try
+    {
+        SELF->in->startException();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_endException(void* self)
+{
+    try
+    {
+        SELF->in->endException(false);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_startEncapsulation(void* self)
+{
+    try
+    {
+        SELF->in->startEncapsulation();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_endEncapsulation(void* self)
+{
+    try
+    {
+        SELF->in->endEncapsulation();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_skipEmptyEncapsulation(void* self)
+{
+    try
+    {
+        SELF->in->skipEmptyEncapsulation();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_skipEncapsulation(void* self)
+{
+    try
+    {
+        return createResultValue(createEncodingVersion(SELF->in->skipEncapsulation()));
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_getEncoding(void* self)
+{
+    try
+    {
+        return createResultValue(createEncodingVersion(SELF->in->getEncoding()));
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_startSlice(void* self)
+{
+    try
+    {
+        SELF->in->startSlice();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_endSlice(void* self)
+{
+    try
+    {
+        SELF->in->endSlice();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_skipSlice(void* self)
+{
+    try
+    {
+        SELF->in->skipSlice();
+    }
+    catch(const std::exception& ex)
+    {
+        return createResultException(convertException(ex));
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readSize(void* self, int* size)
+{
+    try
+    {
+        *size = SELF->in->readSize();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readOptional(void* self, int tag, Ice_OptionalFormat f, unsigned char* r)
+{
+    try
+    {
+        bool b = SELF->in->readOptional(tag, static_cast<Ice::OptionalFormat>(f));
+        *r = b ? 1 : 0;
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readProxy(void* self, void** r)
+{
+    try
+    {
+        shared_ptr<Ice::ObjectPrx> proxy;
+        SELF->in->read(proxy);
+        if(proxy)
+        {
+            *r = new shared_ptr<Ice::ObjectPrx>(proxy);
+        }
+        else
+        {
+            *r = 0;
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readProxyOpt(void* self, int tag, void** r)
+{
+    try
+    {
+        Ice::optional<shared_ptr<Ice::ObjectPrx>> opt;
+        SELF->in->readAll({tag}, opt);
+        if(opt.has_value())
+        {
+            *r = new shared_ptr<Ice::ObjectPrx>(opt.value());
+        }
+        else
+        {
+            *r = 0;
+        }
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_readEnum(void* self, int maxValue, int* r)
+{
+    try
+    {
+        *r = SELF->in->readEnum(maxValue);
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+namespace
+{
+
+class MatlabUserException : public Ice::UserException
+{
+public:
+
+    MatlabUserException(const string& id, mxArray* ex, mxArray* streamWrapper) :
+        _id(id), _ex(ex), _streamWrapper(streamWrapper)
+    {
+    }
+
+    mxArray* exception() const
+    {
+        return _ex;
+    }
+
+    virtual string ice_id() const override
+    {
+        return _id;
+    }
+
+    virtual void _read(Ice::InputStream*) override
+    {
+        //
+        // Call read_() on the exception instance.
+        //
+        mxArray* params[2];
+        params[0] = _ex;
+        params[1] = _streamWrapper;
+        mxArray* err = mexCallMATLABWithTrap(0, 0, 2, params, "read_");
+        if(err)
+        {
+            mxDestroyArray(err);
+            throw Ice::MarshalException(__FILE__, __LINE__, "failure in exception's read_ method");
+        }
+    }
+
+    virtual bool _usesClasses() const override
+    {
+        //
+        // Call usesClasses_() on the exception instance.
+        //
+        mxArray* ex = const_cast<mxArray*>(_ex);
+        mxArray* r;
+        mxArray* err = mexCallMATLABWithTrap(1, &r, 1, &ex, "usesClasses_");
+        if(err)
+        {
+            mxDestroyArray(err);
+            throw Ice::MarshalException(__FILE__, __LINE__, "failure in exception's usesClasses_ method");
+        }
+        else
+        {
+            bool b = mxIsLogicalScalarTrue(r) ? true : false;
+            mxDestroyArray(r);
+            return b;
+        }
+    }
+
+    virtual void ice_throw() const override
+    {
+        throw static_cast<const MatlabUserException&>(*this);
+    }
+
+protected:
+
+    virtual IceUtil::Exception* ice_cloneImpl() const override
+    {
+        return 0;
+    }
+
+    virtual void _writeImpl(Ice::OutputStream*) const override
+    {
+        assert(false);
+    }
+
+    virtual void _readImpl(Ice::InputStream* in) override
+    {
+        assert(false);
+    }
+
+private:
+
+    string _id;
+    mxArray* _ex;
+    mxArray* _streamWrapper;
+};
+
+void createException(mxArray* streamWrapper, const string& id)
+{
+    //
+    // Convert the Slice type ID to a Matlab class name.
+    //
+    string cls = idToClass(id);
+    //
+    // Attempt to call the class constructor to obtain an instance. This may raise an exception.
+    //
+    mxArray* ex;
+    mxArray* err = mexCallMATLABWithTrap(1, &ex, 0, 0, cls.c_str());
+    if(err)
+    {
+        mxDestroyArray(err);
+    }
+    else
+    {
+        throw MatlabUserException(id, ex, streamWrapper);
+    }
+}
+
+}
+
+EXPORTED_FUNCTION mxArray*
+Ice_InputStream_throwException(void* self, mxArray* wrapper)
+{
+    try
+    {
+        SELF->in->throwException([wrapper](const string& id){ createException(wrapper, id); });
+    }
+    catch(MatlabUserException& ex)
+    {
+        return ex.exception();
+    }
+    catch(const std::exception& ex)
+    {
+        return convertException(ex);
+    }
+    return 0;
+}
+
+}