// **********************************************************************
//
// Copyright (c) 2002
// ZeroC, Inc.
// Billerica, MA, USA
//
// All Rights Reserved.
//
// Ice is free software; you can redistribute it and/or modify it under
// the terms of the GNU General Public License version 2 as published by
// the Free Software Foundation.
//
// **********************************************************************

package IceXML;

public class StreamI extends Ice.LocalObjectImpl implements Ice.Stream
{
    private
    StreamI()
    {
    }

    public
    StreamI(Ice.Communicator communicator, java.io.PrintWriter writer)
    {
        _communicator = communicator;
        _os = new IceUtil.XMLOutput(writer);
        _level = 0;
        _nextId = 0;
        _objects = new java.util.IdentityHashMap();
        _dump = false;
    }

    public
    StreamI(Ice.Communicator communicator, java.io.Reader input)
    {
        this(communicator, input, true);
    }

    public
    StreamI(Ice.Communicator communicator, java.io.Reader input, boolean schema)
    {
        _communicator = communicator;
        _nodeStack = new java.util.LinkedList();
        _readObjects = new java.util.HashMap();
        _nextId = 0;

        Ice.Logger logger = communicator.getLogger();

        //
        // Create our parser, then attach an error handler to the parser.
        // The parser will call back to methods of the ErrorHandler if it
        // discovers errors during the course of parsing the XML
        // document.
        //
        javax.xml.parsers.DocumentBuilderFactory factory = javax.xml.parsers.DocumentBuilderFactory.newInstance();
        //
        // TODO: Using the standard JDK parser, calling setValidating(true)
        // appears to enable DTD validation, not schema validation. This
        // needs to be generalized to support other implementations.
        //
        factory.setValidating(false);
        if(schema)
        {
            factory.setNamespaceAware(true);
            //factory.setDoSchema(true); // TODO
        }

        javax.xml.parsers.DocumentBuilder parser = null;
        try
        {
            parser = factory.newDocumentBuilder();
        }
        catch(javax.xml.parsers.ParserConfigurationException ex)
        {
            logger.error("parser configuration error: " + ex.getMessage());
            Ice.MarshalException e = new Ice.MarshalException();
            e.initCause(ex);
            throw e;
        }

        parser.setErrorHandler(new DOMTreeErrorReporter(logger));
        //parser.setCreateEntityReferenceNodes(false); // TODO
        //parser.setToCreateXMLDeclTypeNode(true); // TODO

        // TODO:
        // parser.setEntityResolver

        //
        // Parse the XML file, catching any XML exceptions that might propagate
        // out of it.
        //
        boolean errorsOccurred = false;
        try
        {
            _document = parser.parse(new org.xml.sax.InputSource(input));
        }
        catch(java.io.IOException ex)
        {
            logger.error("I/O error during parsing: " + ex.getMessage());
            errorsOccurred = true;
        }
        catch(org.xml.sax.SAXException ex)
        {
            logger.error("parsing error: " + ex.getMessage());
            errorsOccurred = true;
        }

        if(errorsOccurred)
        {
            throw new Ice.MarshalException();
        }

        //
        // The first child of the document is the root node - ignore
        // that. Move to the top-level node in the document content.
        //
        _current = _document.getFirstChild();
        _current = _current.getFirstChild();
    }

    public
    StreamI(Ice.Communicator communicator, org.w3c.dom.Document document)
    {
        _communicator = communicator;
        _nodeStack = new java.util.LinkedList();
        _readObjects = new java.util.HashMap();
        _nextId = 0;
        _document = document;

        //
        // The first child of the document is the root node - ignore
        // that. Move to the top-level node in the document content.
        //
        _current = _document.getFirstChild();
        _current = _current.getFirstChild();
    }

    public void
    startWriteDictionary(String name, int size)
    {
        String s = name + " length=\"" + size + "\"";
        startWrite(s);
    }

    public void
    endWriteDictionary()
    {
        endWrite();
    }

    public void
    startWriteDictionaryElement()
    {
        startWrite(getWritePrefix() + seqElementName);
    }

    public void
    endWriteDictionaryElement()
    {
        endWrite();
    }

    public int
    startReadDictionary(String name)
    {
        startRead(name);
        int size = readLength();
        _current = _current.getFirstChild();
        return size;
    }

    public void
    endReadDictionary()
    {
        endRead();
    }

    public void
    startReadDictionaryElement()
    {
        startRead(getReadPrefix() + seqElementName);
        _current = _current.getFirstChild();
    }

    public void
    endReadDictionaryElement()
    {
        endRead();
    }

    public void
    startWriteSequence(String name, int size)
    {
        String s = name + " length=\"" + size + "\"";
        startWrite(s);
    }

    public void
    endWriteSequence()
    {
        endWrite();
    }

    public void
    startWriteSequenceElement()
    {
        startWrite(getWritePrefix() + seqElementName);
    }

    public void
    endWriteSequenceElement()
    {
        endWrite();
    }

    public int
    startReadSequence(String name)
    {
        startRead(name);
        int size = readLength();
        _current = _current.getFirstChild();
        return size;
    }

    public void
    endReadSequence()
    {
        endRead();
    }

    public void
    startReadSequenceElement()
    {
        startRead(getReadPrefix() + seqElementName);
    }

    public void
    endReadSequenceElement()
    {
        endRead();
    }

    public void
    startWriteStruct(String name)
    {
        startWrite(name);
    }

    public void
    endWriteStruct()
    {
        endWrite();
    }

    public void
    startReadStruct(String name)
    {
        startRead(name);
        _current = _current.getFirstChild();
    }

    public void
    endReadStruct()
    {
        endRead();
    }

    public void
    startWriteException(String name)
    {
        startWrite(name);
    }

    public void
    endWriteException()
    {
        endWrite();
    }

    public void
    startReadException(String name)
    {
        startRead(name);
        _current = _current.getFirstChild();
    }

    public void
    endReadException()
    {
        endRead();
    }

    public void
    writeEnum(String name, String[] table, int ordinal)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name);
        _os.startEscapes().write(table[ordinal]).endEscapes();
        _os.ee();
    }

    public int
    readEnum(String name, String[] table)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String value = child.getNodeValue();
        int ordinal;
        for(ordinal = 0; ordinal < table.length; ordinal++)
        {
            if(value.equals(table[ordinal]))
            {
                break;
            }
        }
        if(ordinal == table.length)
        {
            throw new Ice.MarshalException();
        }

        endRead();

        return ordinal;
    }

    public void
    writeByte(String name, byte value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        // The schema encoding for xs:byte is a value from -127 to 128.
        _os.se(name);
        _os.startEscapes().write("" + (int)value).endEscapes();
        _os.ee();
    }

    public void
    writeByteSeq(String name, byte[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                startWriteSequenceElement();
                _os.startEscapes().write("" + (int)value[i]).endEscapes();
                endWriteSequenceElement();
            }
            endWriteSequence();
        }
    }

    public byte
    readByte(String name)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String s = child.getNodeValue();
        byte i = 0;
        try
        {
            i = Byte.parseByte(s);
        }
        catch(NumberFormatException ex)
        {
            Ice.MarshalException e = new Ice.MarshalException();
            e.initCause(ex);
            throw e;
        }

        endRead();

        return i;
    }

    public byte[]
    readByteSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        byte[] value = new byte[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readByte(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeBool(String name, boolean value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name).write(value ? "true" : "false").ee();
    }

    public void
    writeBoolSeq(String name, boolean[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                _os.se("e").write(value[i] ? "true" : "false").ee();
            }
            endWriteSequence();
        }
    }

    public boolean
    readBool(String name)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String s = child.getNodeValue();
        boolean value = s.equals("true");

        endRead();

        return value;
    }

    public boolean[]
    readBoolSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        boolean[] value = new boolean[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readBool(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeShort(String name, short value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name).write("" + value).ee();
    }

    public void
    writeShortSeq(String name, short[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                _os.se("e").write("" + value[i]).ee();
            }
            endWriteSequence();
        }
    }

    public short
    readShort(String name)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String s = child.getNodeValue();
        short i = 0;
        try
        {
            i = Short.parseShort(s);
        }
        catch(NumberFormatException ex)
        {
            Ice.MarshalException e = new Ice.MarshalException();
            e.initCause(ex);
            throw e;
        }

        endRead();

        return i;
    }

    public short[]
    readShortSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        short[] value = new short[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readShort(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeInt(String name, int value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name).write("" + value).ee();
    }

    public void
    writeIntSeq(String name, int[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                _os.se("e").write("" + value[i]).ee();
            }
            endWriteSequence();
        }
    }

    public int
    readInt(String name)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String s = child.getNodeValue();
        int i = 0;
        try
        {
            i = Integer.parseInt(s);
        }
        catch(NumberFormatException ex)
        {
            Ice.MarshalException e = new Ice.MarshalException();
            e.initCause(ex);
            throw e;
        }

        endRead();

        return i;
    }

    public int[]
    readIntSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        int[] value = new int[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readInt(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeLong(String name, long value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name).write("" + value).ee();
    }

    public void
    writeLongSeq(String name, long[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                _os.se("e").write("" + value[i]).ee();
            }
            endWriteSequence();
        }
    }

    public long
    readLong(String name)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String s = child.getNodeValue();
        long i = 0;
        try
        {
            i = Long.parseLong(s);
        }
        catch(NumberFormatException ex)
        {
            Ice.MarshalException e = new Ice.MarshalException();
            e.initCause(ex);
            throw e;
        }

        endRead();

        return i;
    }

    public long[]
    readLongSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        long[] value = new long[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readLong(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeFloat(String name, float value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name).write("" + value).ee();
    }

    public void
    writeFloatSeq(String name, float[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                _os.se("e").write("" + value[i]).ee();
            }
            endWriteSequence();
        }
    }

    public float
    readFloat(String name)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String s = child.getNodeValue();
        float i = 0;
        try
        {
            i = Float.parseFloat(s);
        }
        catch(NumberFormatException ex)
        {
            Ice.MarshalException e = new Ice.MarshalException();
            e.initCause(ex);
            throw e;
        }

        endRead();

        return i;
    }

    public float[]
    readFloatSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        float[] value = new float[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readFloat(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeDouble(String name, double value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name).write("" + value).ee();
    }

    public void
    writeDoubleSeq(String name, double[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                _os.se("e").write("" + value[i]).ee();
            }
            endWriteSequence();
        }
    }

    public double
    readDouble(String name)
    {
        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child == null || child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
        {
            throw new Ice.MarshalException();
        }

        String s = child.getNodeValue();
        double i = 0;
        try
        {
            i = Double.parseDouble(s);
        }
        catch(NumberFormatException ex)
        {
            Ice.MarshalException e = new Ice.MarshalException();
            e.initCause(ex);
            throw e;
        }

        endRead();

        return i;
    }

    public double[]
    readDoubleSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        double[] value = new double[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readDouble(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeString(String name, String value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);

        _os.se(name);
        if(value != null && value.length() > 0)
        {
            _os.startEscapes().write(value == null ? "" : value).endEscapes();
        }
        _os.ee();
    }

    public void
    writeStringSeq(String name, String[] value)
    {
        if(value == null)
        {
            startWriteSequence(name, 0);
            endWriteSequence();
        }
        else
        {
            startWriteSequence(name, value.length);
            for(int i = 0; i < value.length; i++)
            {
                _os.se("e");
                if(value[i] != null && value[i].length() > 0)
                {
                    _os.startEscapes().write(value[i] == null ? "" : value[i]).endEscapes();
                }
                _os.ee();
            }
            endWriteSequence();
        }
    }

    public String
    readString(String name)
    {
        String value = null;

        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        if(child != null)
        {
            if(child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
            {
                throw new Ice.MarshalException();
            }
            value = child.getNodeValue();
        }
        else
        {
            value = "";
        }

        endRead();

        return value;
    }

    public String[]
    readStringSeq(String name)
    {
        startRead(name);

        final String elem = getPrefix(name) + seqElementName;
        int size = readLength();
        String[] value = new String[size];
        if(size > 0)
        {
            _current = _current.getFirstChild();
            for(int i = 0; i < size; i++)
            {
                value[i] = readString(elem);
            }
        }

        endRead();

        return value;
    }

    public void
    writeProxy(String name, Ice.ObjectPrx value)
    {
        // No attributes
        assert(IceInternal.StringUtil.findFirstOf(name, " \t") == -1);
        String s = _communicator.proxyToString(value);

        _os.se(name);
        if(s.length() > 0)
        {
            _os.startEscapes().write(s).endEscapes();
        }
        _os.ee();
    }

    public Ice.ObjectPrx
    readProxy(String name)
    {
        Ice.ObjectPrx value = null;

        startRead(name);

        org.w3c.dom.Node child = _current.getFirstChild();
        String s = "";
        if(child != null)
        {
            if(child.getNodeType() != org.w3c.dom.Node.TEXT_NODE)
            {
                throw new Ice.MarshalException();
            }
            s = child.getNodeValue();
        }

        value = _communicator.stringToProxy(s);

        endRead();

        return value;
    }

    public void
    writeObject(String name, Ice.Object value)
    {
        //
        // If at the top level of the document then the object itself must
        // be written, otherwise write a reference.
        //
        boolean writeReference = (_level != 0);

        //
        // If the object doesn't exist in the map add it.
        //
        ObjectInfo info = (ObjectInfo)_objects.get(value);
        if(info == null)
        {
            String s = "object" + _nextId++;
            info = new ObjectInfo(s, !writeReference);
            _objects.put(value, info);
        }

        if(writeReference)
        {
            _os.nl();
            _os.print("<" + name + " href=\"#" + info.id + "\"/>");
        }
        else
        {
            //
            // Precondition: If the actual object is being written the
            // written flag should be true.
            //
            assert(info.written);
            writeObjectData(name, info.id, value);
        }
    }

    public Ice.Object
    readObject(String name, String signatureType, Ice.ObjectFactory factory)
    {
        Ice.Object value = null;

        startRead(name);

        //
        // Node attributes. Either id & type will be set, or href.
        //
        // TODO: Eliminate Holders?
        //
        Ice.StringHolder id = new Ice.StringHolder();
        Ice.StringHolder type = new Ice.StringHolder();
        Ice.StringHolder href = new Ice.StringHolder();
        readAttributes(id, type, href);

        //
        // If this object is an href then locate the object. If the object
        // has been previously read then it will be contained in the
        // readObjects list. Otherwise, it should be in the object-set at
        // the top-level of the document.
        //
        if(href.value != null && href.value.length() > 0)
        {
            href.value = href.value.substring(1); // Skip the '#'

            value = (Ice.Object)_readObjects.get(href.value);
            if(value != null)
            {
                endRead();
                return value;
            }

            //
            // The first child of the document is the root node - ignore
            // that. Move to the top-level node in the document content.
            //
            _current = _document.getFirstChild();
            _current = _current.getFirstChild();
            while(_current != null)
            {
                if(_current.getNodeType() == org.w3c.dom.Node.ELEMENT_NODE)
                {
                    Ice.StringHolder dummy = new Ice.StringHolder();
                    readAttributes(id, type, dummy);
                    if(id.value.equals(href.value))
                    {
                        break;
                    }
                }
                _current = _current.getNextSibling();
            }
            //
            // If the object isn't found, that's an error.
            //
            if(_current == null)
            {
                throw new Ice.MarshalException();
            }
        }

        //
        // Empty type indicates nil object.
        //
        if(type.value.length() == 0)
        {
            value = null;
        }
        else
        {
            if(type.value.equals("::Ice::Object"))
            {
                value = new Ice.ObjectImpl();
            }
            else
            {
                //
                // First, determine if there is an installed factory for this
                // type. If so use that. If that factory doesn't exist, or it
                // doesn't create an object of that type then use the supplied
                // factory provided that the types are the same. If no value
                // can be created then throw a NoObjectFactoryException.
                //
                Ice.ObjectFactory userFactory = _communicator.findObjectFactory(type.value);
                if(userFactory != null)
                {
                    value = userFactory.create(type.value);
                }

                if(value == null && type.value.equals(signatureType))
                {
                    assert(factory != null);
                    value = factory.create(type.value);
                    assert(value != null);
                }

                if(value == null)
                {
                    userFactory = loadObjectFactory(type.value);
                    if(userFactory != null)
                    {
                        value = userFactory.create(type.value);
                    }
                }

                if(value == null)
                {
                    Ice.NoObjectFactoryException e = new Ice.NoObjectFactoryException();
		    e.type = type.value;
		    throw e;
                }
            }

            //
            // Add the object to the readObjects map, move to the first
            // child node & unmarshal the object.
            //
            _readObjects.put(id.value, value);
            _current = _current.getFirstChild();
            value.__unmarshal(this);
        }

        endRead();

        return value;
    }

    private void
    startWrite(String name)
    {
        _os.se(name);
        ++_level;
    }

    private void
    endWrite()
    {
        --_level;

        _os.ee();

        if(_level == 0 && !_dump)
        {
            dumpUnwrittenObjects();
        }
    }

    private void
    startRead(String name)
    {
        while(_current != null && _current.getNodeType() != org.w3c.dom.Node.ELEMENT_NODE)
        {
            _current = _current.getNextSibling();
        }
        if(_current == null)
        {
            throw new Ice.MarshalException();
        }

        String nodeName = _current.getNodeName();
        //
        // TODO: Work around for bug in xerces
        //
        final String facets = "facets";
        final String facetsNS = "ice:facets";
        if((!name.equals(facetsNS) || !nodeName.equals(facets)) && !name.equals(nodeName))
        {
            throw new Ice.MarshalException();
        }

        _nodeStack.add(_current);
    }

    private void
    endRead()
    {
        _current = (org.w3c.dom.Node)_nodeStack.removeLast();
        _current = _current.getNextSibling();
    }

    private void
    dumpUnwrittenObjects()
    {
        //
        // Precondition: Must be at the top-level.
        //
        assert(_level == 0 && !_dump);

        _dump = true;

        //
        // It's necessary to run through the set of unwritten objects
        // repeatedly until all referenced objects have been written
        // (since referenced objects can themselves reference other
        // objects).
        //
        int nwritten;
        do
        {
            nwritten = 0;
            java.util.Iterator p = _objects.entrySet().iterator();
            try
            {
                while(p.hasNext())
                {
                    java.util.Map.Entry e = (java.util.Map.Entry)p.next();
                    Ice.Object obj = (Ice.Object)e.getKey();
                    ObjectInfo info = (ObjectInfo)e.getValue();
                    if(!info.written)
                    {
                        info.written = true;
                        writeObjectData("ice:object", info.id, obj);
                    }
                    ++nwritten;
                }
            }
            catch(java.util.ConcurrentModificationException ex)
            {
                //
                // This will be thrown if _objects has been modified, e.g.,
                // if a new object is added. We need to start the loop
                // again with a new iterator.
                //
            }
        }
        while(_objects.size() != nwritten);

        _dump = false;
    }

    private void
    writeObjectData(String name, String id, Ice.Object obj)
    {
        String xsdType = "";
        String typeId = "";

        if(obj != null)
        {
            //
            // Convert the type-id to the equivalent schema type
            // definition name.
            //
            typeId = obj.ice_id(null);

            final String xsdPrefix = "_internal.";
            final String xsdSuffix = "Type";
            xsdType += xsdPrefix;
            int i = 0;
            if(typeId.charAt(0) == ':') // Skip the preceeding "::".
            {
                i = 2;
            }
            for(; i < typeId.length(); ++i)
            {
                if(typeId.charAt(i) == ':')
                {
                    xsdType += '.';
                    ++i;
                }
                else
                {
                    xsdType += typeId.charAt(i);
                }
            }
            xsdType += xsdSuffix;
        }
        else
        {
            xsdType = "";
        }

        String s = name + " id=\"" + id + "\" type=\"" + typeId + "\"" + " xsi:type=\"" + xsdType + "\"";
        if(obj == null)
        {
            s += " xsi:nil=\"true\"";
        }

        startWrite(s);
        if(obj != null)
        {
            obj.__marshal(this);
        }
        endWrite();
    }

    private void
    readAttributes(Ice.StringHolder id, Ice.StringHolder type, Ice.StringHolder href)
    {
        final String idStr = "id";
        final String typeStr = "type";
        final String hrefStr = "href";

        org.w3c.dom.NamedNodeMap attributes = _current.getAttributes();
        int attrCount = attributes.getLength();
        for(int i = 0; i < attrCount; i++)
        {
            org.w3c.dom.Node attribute = attributes.item(i);
            String name = attribute.getNodeName();
            if(name.equals(idStr))
            {
                id.value = attribute.getNodeValue();
            }
            else if(name.equals(typeStr))
            {
                type.value = attribute.getNodeValue();
            }
            else if(name.equals(hrefStr))
            {
                href.value = attribute.getNodeValue();
            }
        }
    }

    private int
    readLength()
    {
        final String lengthStr = "length";

        org.w3c.dom.NamedNodeMap attributes = _current.getAttributes();
        int attrCount = attributes.getLength();
        for(int i = 0; i < attrCount; i++)
        {
            org.w3c.dom.Node attribute = attributes.item(i);
            String name = attribute.getNodeName();
            if(name.equals(lengthStr))
            {
                try
                {
                    return Integer.parseInt(attribute.getNodeValue());
                }
                catch(NumberFormatException ex)
                {
                    throw new Ice.MarshalException();
                }
            }
        }

        throw new Ice.MarshalException();
    }

    private String
    getWritePrefix()
    {
        String name = _os.currentElement();
        assert(name.length() != 0);
        return getPrefix(name);
    }

    private String
    getReadPrefix()
    {
        assert(!_nodeStack.isEmpty());
        return getPrefix(((org.w3c.dom.Node)_nodeStack.getLast()).getNodeName());
    }

    private static String
    getPrefix(String s)
    {
        int pos = s.indexOf(':');
        if(pos != -1)
        {
            return s.substring(0, pos + 1);
        }
        else
        {
            return "";
        }
    }

    private static final class DynamicObjectFactory extends Ice.LocalObjectImpl implements Ice.ObjectFactory
    {
        DynamicObjectFactory(Class c)
        {
            _class = c;
        }

        public Ice.Object
        create(String type)
        {
            try
            {
                return (Ice.Object)_class.newInstance();
            }
            catch(Exception ex)
            {
                Ice.SyscallException e = new Ice.SyscallException();
                e.initCause(ex);
                throw e;
            }
        }

        public void
        destroy()
        {
        }

        private Class _class;
    }

    private Ice.ObjectFactory
    loadObjectFactory(String id)
    {
        Ice.ObjectFactory factory = null;

        try
        {
            Class c = Class.forName(typeToClass(id));
            //
            // Ensure the class is instantiable. The constants are
            // defined in the JVM specification (0x200 = interface,
            // 0x400 = abstract).
            //
            int modifiers = c.getModifiers();
            if((modifiers & 0x200) == 0 && (modifiers & 0x400) == 0)
            {
                Ice.ObjectFactory dynamicFactory = new DynamicObjectFactory(c);
                //
                // We will try to install the dynamic factory, but another thread
                // may install a factory first.
                //
                while(factory == null)
                {
                    try
                    {
                        _communicator.addObjectFactory(dynamicFactory, id);
                        factory = dynamicFactory;
                    }
                    catch(Ice.AlreadyRegisteredException ex)
                    {
                        //
                        // Another thread already installed the factory, so try
                        // to obtain it. It's possible (but unlikely) that the factory
                        // will have already been removed, in which case the return
                        // value will be null and the while loop will attempt to
                        // install the dynamic factory again.
                        //
                        factory = _communicator.findObjectFactory(id);
                    }
                }
            }
        }
        catch(ClassNotFoundException ex)
        {
            // Ignore
        }
        catch(Exception ex)
        {
            Ice.NoObjectFactoryException e = new Ice.NoObjectFactoryException();
	    e.type = id;
            e.initCause(ex);
            throw e;
        }

        return factory;
    }

    private static String
    typeToClass(String id)
    {
        assert(id.startsWith("::"));
        return id.substring(2).replaceAll("::", ".");
    }

    private Ice.Communicator _communicator;

    //
    // The sequence element name
    //
    private static final String seqElementName = "e";

    //
    // For reading.
    //
    private org.w3c.dom.Document _document;
    private org.w3c.dom.Node _current;
    private java.util.LinkedList _nodeStack;
    private java.util.HashMap _readObjects;

    //
    // For writing.
    //

    //
    // XML Output stream.
    //
    private IceUtil.XMLOutput _os;

    //
    // Current document level.
    //
    private int _level;

    //
    // Next id for marshalling objects.
    //
    private int _nextId;
    private static class ObjectInfo
    {
        ObjectInfo(String i, boolean w)
        {
            id = i;
            written = w;
        }

        String id; // The id of the associated object
        boolean written; // Has the object been written?
    }
    private java.util.IdentityHashMap _objects;
    private boolean _dump;

    private static class DOMTreeErrorReporter implements org.xml.sax.ErrorHandler
    {
        DOMTreeErrorReporter(Ice.Logger logger)
        {
            _logger = logger;
            _sawErrors = false;
        }

        public void
        warning(org.xml.sax.SAXParseException ex)
            throws org.xml.sax.SAXException
        {
            String s = "file: \"" + ex.getSystemId() +
                "\", line: " + ex.getLineNumber() +
                ", column: " + ex.getColumnNumber() +
                "\nmessage: " + ex.getMessage();
            _logger.warning(s);
        }

        public void
        error(org.xml.sax.SAXParseException ex)
            throws org.xml.sax.SAXException
        {
            _sawErrors = true;
            String s = "file: \"" + ex.getSystemId() +
                "\", line: " + ex.getLineNumber() +
                ", column: " + ex.getColumnNumber() +
                "\nmessage: " + ex.getMessage();
            _logger.error(s);
        }

        public void
        fatalError(org.xml.sax.SAXParseException ex)
            throws org.xml.sax.SAXException
        {
            _sawErrors = true;
            String s = "file: \"" + ex.getSystemId() +
                "\", line: " + ex.getLineNumber() +
                ", column: " + ex.getColumnNumber() +
                "\nmessage: " + ex.getMessage();
            _logger.error(s);
        }

        boolean
        getSawErrors()
        {
            return _sawErrors;
        }

        private Ice.Logger _logger;
        private boolean _sawErrors;
    }
}