// **********************************************************************
//
// Copyright (c) 2001
// MutableRealms, Inc.
// Huntsville, AL, USA
//
// All Rights Reserved
//
// **********************************************************************

package Ice;

public class ObjectAdapterI implements ObjectAdapter
{
    public String
    getName()
    {
        return _name; // _name is immutable
    }

    public Communicator
    getCommunicator()
    {
        return _instance.communicator(); // _instance is immutable
    }

    public synchronized void
    activate()
    {
        
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        final int sz = _incomingConnectionFactories.size();
        for (int i = 0; i < sz; i++)
        {
            IceInternal.IncomingConnectionFactory factory =
                (IceInternal.IncomingConnectionFactory)_incomingConnectionFactories.get(i);
            factory.activate();
        }
    }

    public synchronized void
    hold()
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        final int sz = _incomingConnectionFactories.size();
        for (int i = 0; i < sz; i++)
        {
            IceInternal.IncomingConnectionFactory factory =
                (IceInternal.IncomingConnectionFactory)_incomingConnectionFactories.get(i);
            factory.hold();
        }
    }

    public synchronized void
    deactivate()
    {
        if (_deactivated)
        {
            //
            // Ignore deactivation requests if the Object Adapter has
            // already been deactivated.
            //
            return;
        }

        final int sz = _incomingConnectionFactories.size();
        for (int i = 0; i < sz; i++)
        {
            IceInternal.IncomingConnectionFactory factory =
                (IceInternal.IncomingConnectionFactory)_incomingConnectionFactories.get(i);
            factory.destroy();
        }
        _incomingConnectionFactories.clear();

        _instance.outgoingConnectionFactory().removeAdapter(this);

        _activeServantMap.clear();

        java.util.Iterator p = _locatorMap.values().iterator();
        while (p.hasNext())
        {
            ServantLocator locator = (ServantLocator)p.next();
            locator.deactivate();
        }
        _locatorMap.clear();

        _deactivated = true;
    }

    public synchronized ObjectPrx
    add(Ice.Object servant, Identity ident)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        //
        // Create a copy of the Identity argument, in case the caller
        // reuses it
        //
        Identity id = new Identity();
        id.category = ident.category;
        id.name = ident.name;
        _activeServantMap.put(id, servant);

        return newProxy(ident);
    }

    public synchronized ObjectPrx
    addWithUUID(Ice.Object servant)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        long now = System.currentTimeMillis();
        Identity ident = new Identity();
        ident.category = "";
        ident.name = Util.generateUUID();

        _activeServantMap.put(ident, servant);

        return newProxy(ident);
    }

    public synchronized void
    remove(Identity ident)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        _activeServantMap.remove(ident);
    }

    public synchronized void
    addServantLocator(ServantLocator locator, String prefix)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        _locatorMap.put(prefix, locator);
    }

    public synchronized void
    removeServantLocator(String prefix)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        ServantLocator locator = (ServantLocator)_locatorMap.remove(prefix);
        if (locator != null)
        {
            locator.deactivate();
        }
    }

    public synchronized ServantLocator
    findServantLocator(String prefix)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        return (ServantLocator)_locatorMap.get(prefix);
    }

    public synchronized RequestQueue
    createRequestQueue(String category)
    {
	return null; // Not implemented yet.
    }

    public synchronized RequestQueue
    findRequestQueue(String category)
    {
	return null; // Not implemented yet.
    }

    public synchronized Ice.Object
    identityToServant(Identity ident)
    {
        return (Ice.Object)_activeServantMap.get(ident);
    }

    public Ice.Object
    proxyToServant(ObjectPrx proxy)
    {
        IceInternal.Reference ref = ((ObjectPrxHelper)proxy).__reference();
        return identityToServant(ref.identity);
    }

    public synchronized ObjectPrx
    createProxy(Identity ident)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        return newProxy(ident);
    }

    public synchronized ObjectPrx
    createReverseProxy(Identity ident)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        //
        // Create a reference and return a reverse proxy for this reference.
        //
        IceInternal.Endpoint[] endpoints = new IceInternal.Endpoint[0];
        IceInternal.Reference ref =
            _instance.referenceFactory().create(ident, "", IceInternal.Reference.ModeTwoway, false, endpoints,
                                                endpoints, null, this);

        return _instance.proxyFactory().referenceToProxy(ref);
    }

    public synchronized void
    addRouter(RouterPrx router)
    {
        if (_deactivated)
        {
            throw new ObjectAdapterDeactivatedException();
        }

        IceInternal.RouterInfo routerInfo = _instance.routerManager().get(router);
        if (routerInfo != null)
        {
            //
            // Add the router's server proxy endpoints to this object
            // adapter.
            //
            ObjectPrxHelper proxy = (ObjectPrxHelper)routerInfo.getServerProxy();
            IceInternal.Endpoint[] endpoints = proxy.__reference().endpoints;
            for (int i = 0; i < endpoints.length; i++)
            {
                _routerEndpoints.add(endpoints[i]);
            }
            java.util.Collections.sort(_routerEndpoints); // Must be sorted.
            for (int i = 0; i < _routerEndpoints.size() - 1; i++)
            {
                java.lang.Object o1 = _routerEndpoints.get(i);
                java.lang.Object o2 = _routerEndpoints.get(i + 1);
                if (o1.equals(o2))
                {
                    _routerEndpoints.remove(i);
                }
            }

            //
            // Associate this object adapter with the router. This way,
            // new outgoing connections to the router's client proxy will
            // use this object adapter for callbacks.
            //
            routerInfo.setAdapter(this);

            //
            // Also modify all existing outgoing connections to the
            // router's client proxy to use this object adapter for
            // callbacks.
            //      
            _instance.outgoingConnectionFactory().setRouter(routerInfo.getRouter());
        }
    }

    public synchronized IceInternal.Connection[]
    getIncomingConnections()
    {
        java.util.ArrayList connections = new java.util.ArrayList();
        final int sz = _incomingConnectionFactories.size();
        for (int i = 0; i < sz; i++)
        {
            IceInternal.IncomingConnectionFactory factory =
                (IceInternal.IncomingConnectionFactory)_incomingConnectionFactories.get(i);
            IceInternal.Connection[] cons = factory.connections();
            for (int j = 0; j < cons.length; j++)
            {
                connections.add(cons[j]);
            }
        }

        IceInternal.Connection[] arr = new IceInternal.Connection[connections.size()];
        connections.toArray(arr);
        return arr;
    }

    //
    // Only for use by IceInternal.ObjectAdapterFactory
    //
    public
    ObjectAdapterI(IceInternal.Instance instance, String name, String endpts)
    {
        _instance = instance;
        _deactivated = false;
        _name = name;

        String s = endpts.toLowerCase();

        int beg = 0;
        int end;

        try
        {
            while (true)
            {
                end = s.indexOf(':', beg);
                if (end == -1)
                {
                    end = s.length();
                }

                if (end == beg)
                {
                    break;
                }

                String es = s.substring(beg, end);

                //
                // Don't store the endpoint in the adapter. The Connection
                // might change it, for example, to fill in the real port
                // number if a zero port number is given.
                //
                IceInternal.Endpoint endp = IceInternal.Endpoint.endpointFromString(instance, es);
                _incomingConnectionFactories.add(new IceInternal.IncomingConnectionFactory(instance, endp, this));

                if (end == s.length())
                {
                    break;
                }

                beg = end + 1;
            }
        }
        catch (LocalException ex)
        {
            if (!_deactivated)
            {
                deactivate();
            }
            throw ex;
        }

//
// Object Adapters without incoming connection factories are
// permissible, as such Object Adapters can still be used with a
// router. (See addRouter.)
//
/*
        if (_incomingConnectionFactories.isEmpty())
        {
            throw new EndpointParseException();
        }
*/

        try
        {
            String value = _instance.properties().getProperty("Ice.PrintAdapterReady");
            if (Integer.parseInt(value) >= 1)
            {
                System.out.println(_name + " readY");
            }
        }
        catch (NumberFormatException ex)
        {
            // TODO: Do anything?
        }
    }

    protected void
    finalize()
        throws Throwable
    {
        if (!_deactivated)
        {
            deactivate();
        }

        super.finalize();
    }

    private ObjectPrx
    newProxy(Identity ident)
    {
        IceInternal.Endpoint[] endpoints =
            new IceInternal.Endpoint[_incomingConnectionFactories.size() + _routerEndpoints.size()];

        //
        // First we add all endpoints from all incoming connection
        // factories.
        //
        int sz = _incomingConnectionFactories.size();
        for (int i = 0; i < sz; i++)
        {
            IceInternal.IncomingConnectionFactory factory =
                (IceInternal.IncomingConnectionFactory)_incomingConnectionFactories.get(i);
            endpoints[i] = factory.endpoint();
        }

        //
        // Now we also add the endpoints of the router's server proxy, if
        // any. This way, object references created by this object adapter
        // will also point to the router's server proxy endpoints.
        //
        sz = _routerEndpoints.size();
        for (int i = 0; i < sz; i++)
        {
            endpoints[i] = (IceInternal.Endpoint)_routerEndpoints.get(i);
        }

        //
        // Create a reference and return a proxy for this reference.
        //
        IceInternal.Reference reference = _instance.referenceFactory().create(ident, "", IceInternal.Reference.ModeTwoway, false,
                                                                              endpoints, endpoints, null, null);
        return _instance.proxyFactory().referenceToProxy(reference);
    }

    public boolean
    isLocal(ObjectPrx proxy)
    {
        IceInternal.Reference ref = ((ObjectPrxHelper)proxy).__reference();
        final IceInternal.Endpoint[] endpoints = ref.endpoints;

        //
        // Proxies which have at least one endpoint in common with the
        // endpoints used by this object adapter's incoming connection
        // factories are considered local.
        //
        for (int i = 0; i < endpoints.length; i++)
        {
            final int sz = _incomingConnectionFactories.size();
            for (int j = 0; j < sz; j++)
            {
                IceInternal.IncomingConnectionFactory factory =
                    (IceInternal.IncomingConnectionFactory)_incomingConnectionFactories.get(j);
                if (factory.equivalent(endpoints[i]))
                {
                    return true;
                }
            }
        }

        //
        // Proxies which have at least one endpoint in common with the
        // router's server proxy endpoints (if any), are also considered
        // local.
        //
        for (int i = 0; i < endpoints.length; i++)
        {
            if (java.util.Collections.binarySearch(_routerEndpoints, endpoints[i]) >= 0) // _routerEndpoints is sorted.
            {
                return true;
            }
        }

        return false;
    }

    private IceInternal.Instance _instance;
    private boolean _deactivated;
    private String _name;
    private java.util.HashMap _activeServantMap = new java.util.HashMap();
    private java.util.HashMap _locatorMap = new java.util.HashMap();
    private java.util.ArrayList _incomingConnectionFactories =
        new java.util.ArrayList();
    private java.util.ArrayList _routerEndpoints = new java.util.ArrayList();
}