Application: gvSIG desktop

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 gvSIG Association.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 3

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 * For any additional information, do not hesitate to contact us

 * at info AT gvsig.com, or visit our website www.gvsig.com.

 */

package org.gvsig.fmap.dal.resource.impl;

import java.io.File;

import java.lang.reflect.InvocationTargetException;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Timer;

import java.util.TimerTask;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataParameters;

import org.gvsig.fmap.dal.exception.CopyParametersException;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.exception.InitializeException;

import org.gvsig.fmap.dal.resource.Resource;

import org.gvsig.fmap.dal.resource.ResourceParameters;

import org.gvsig.fmap.dal.resource.exception.AccessResourceException;

import org.gvsig.fmap.dal.resource.exception.DisposeResorceManagerException;

import org.gvsig.fmap.dal.resource.exception.ResourceException;

import org.gvsig.fmap.dal.resource.exception.ResourceNotClosedOnDisposeManagerException;

import org.gvsig.fmap.dal.resource.exception.ResourceNotRegisteredException;

import org.gvsig.fmap.dal.resource.spi.AbstractResource;

import org.gvsig.fmap.dal.resource.spi.MultiResource;

import org.gvsig.fmap.dal.resource.spi.ResourceManagerProviderServices;

import org.gvsig.fmap.dal.resource.spi.ResourceProvider;

import org.gvsig.fmap.dal.spi.DataStoreProviderServices;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dynobject.exception.DynFieldNotFoundException;

import org.gvsig.tools.observer.Observer;

import org.gvsig.tools.observer.impl.DelegateWeakReferencingObservable;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class DefaultResourceManager implements ResourceManagerProviderServices {

        final static private String DATA_MANAGER_RESOURCE = "Data.manager.resources";

        final static private String DATA_MANAGER_RESOURCE_PARAMS = "Data.manager.resources.params";

        // FIXME: rellenar las cadenas

        private static final String DATA_MANAGER_RESOURCE_DESCRIPTION = "DAL Resources types";

        private static final String DATA_MANAGER_RESOURCE_PARAMS_DESCRIPTION = "DAL Resources types Parameters";

        private Map<String,Resource> resources = new HashMap();

        private DelegateWeakReferencingObservable delegateObservable = new DelegateWeakReferencingObservable(this);

        private Timer timer = null;

        private Logger logger;

        private long mlsecondsToBeIdle = 0;

        public DefaultResourceManager() {

                /*

                 * Create te extensions point in te registry.

                 */

                ToolsLocator.getExtensionPointManager().add(DATA_MANAGER_RESOURCE,

                                DATA_MANAGER_RESOURCE_DESCRIPTION);

                ToolsLocator.getExtensionPointManager().add(

                                DATA_MANAGER_RESOURCE_PARAMS,

                                DATA_MANAGER_RESOURCE_PARAMS_DESCRIPTION);

        }

        public Logger getLogger() {

                if (this.logger == null) {

                        this.logger = LoggerFactory.getLogger(this.getClass());

                }

                return this.logger;

        }

        public synchronized void remove(Resource resource)

                        throws DataException {

                remove(resource.getName());

        }

        public synchronized void remove(String name)

                        throws DataException {

                ResourceProvider res = (ResourceProvider) this.resources.get(name);

                if (res == null){

                        throw new IllegalArgumentException("Resource not register:" + name);

                }

                if (res.getConsumersCount() < 1) {

                        this.resources.remove(name);

                        res.notifyDispose();

                }

                res = null;

        }

    public synchronized Resource getResource(String key) {

                return (Resource)this.resources.get(key);

        }

    public synchronized Iterator<Resource> iterator() {

                return this.resources.values().iterator();

        }

        public void addObserver(Observer o) {

                // TODO a?adir el observador a los recursos que ya existiesen

                this.delegateObservable.addObserver(o);

        }

        public void deleteObserver(Observer o) {

                this.delegateObservable.deleteObserver(o);

        }

        public void deleteObservers() {

                this.delegateObservable.deleteObservers();

        }

        public synchronized void collectResources() throws

                        DataException {

                ResourceProvider res;

                Iterator iter = this.resources.entrySet().iterator();

                while (iter.hasNext()) {

                        Entry entry = (Entry) iter.next();

                        res = (ResourceProvider) entry.getValue();

                        if (res.getConsumersCount() < 1) {

                                res.closeRequest();

                                res.notifyDispose();

                                iter.remove();

                                continue;

                        }

                        if (mlsecondsToBeIdle > 0

                                        && System.currentTimeMillis()

                                                        - res.getLastTimeUsed() > mlsecondsToBeIdle) {

                        }

                }

        }

    private synchronized AbstractResource findResource(ResourceParameters params) {

                AbstractResource res;

                Iterator iter = this.resources.values().iterator();

                while (iter.hasNext()) {

                        res = (AbstractResource) iter.next();

                        try {

                                if (res.isThis(params)) {

                                        return res;

                                }

                        } catch (ResourceException e) {

                                getLogger()

                                                .warn(

                                                                "Se ha producido un error comprobando si se puede reutilizar el recurso.",

                                                                e);

                        } catch (CopyParametersException e) {

                                getLogger()

                                                .warn(

                                                                "Se ha producido un error comprobando si se puede reutilizar el recurso.",

                                                                e);

                        }

                }

                return null;

        }

    private synchronized AbstractResource addResource(AbstractResource resource)

                        throws AccessResourceException {

                resources.put(resource.getName(), resource);

                resource.addObservers(this.delegateObservable);

                return resource;

        }

        public void startResourceCollector(long milis, Observer observer) {

                if (this.timer == null){

                        this.timer = new Timer();

                } else{

                        this.timer.cancel();

                }

                // TODO observer

                this.timer.scheduleAtFixedRate(new TimerTask() {

                        public void run() {

                                try {

                                        DALLocator.getResourceManager().collectResources();

                                } catch (DataException e) {

                                        // TODO Notificar con el observer

                                }

                        }

                }, milis, milis);

        }

        public void stopResourceCollector() {

                if (this.timer != null) {

                        this.timer.cancel();

                }

        }

        public DataParameters createParameters(

                String type, 

                Object[] args

            ) throws InitializeException {

            try {

                ResourceParameters parameters;

                if (args == null) {

                    parameters = (ResourceParameters) ToolsLocator.getExtensionPointManager()

                        .get(DATA_MANAGER_RESOURCE_PARAMS).create(type);

                } else {

                    parameters = (ResourceParameters) ToolsLocator.getExtensionPointManager()

                        .get(DATA_MANAGER_RESOURCE_PARAMS).create(type, args);

                }

                if (parameters == null){

                    throw new ResourceNotRegisteredException(type);

                }

//                if( !type.equalsIgnoreCase(parameters.getTypeName()) ) {

//                    getLogger().info("Change default provider name of resource from {} to {}.", 

//                            parameters.getTypeName(), type

//                    );

//                    parameters.setDynValue(DataStoreProviderServices.PROVIDER_PARAMTER_NAME, type);

//                }

                return parameters;

            } catch (Exception e) {

                    throw new InitializeException(type, e);

            }

        }

        public DataParameters createParameters(String type)

                        throws InitializeException {

                return createParameters(type, null);

        }

        public ResourceProvider createAddResource(String type, Object[] params)

                        throws InitializeException {

                return createAddResource((ResourceParameters) createParameters(type,

                                params));

        }

        public ResourceProvider createResource(String type, Object[] params)

                        throws InitializeException {

                return createResource((ResourceParameters) createParameters(type,

                                params));

        }

        public ResourceProvider createResource(ResourceParameters params)

                        throws InitializeException {

                AbstractResource resource = this.findResource(params);

                if (resource != null) {

                        return resource;

                }

                try {

                        resource = (AbstractResource) ToolsLocator

                                        .getExtensionPointManager().get(DATA_MANAGER_RESOURCE)

                                        .create(

                                                        params.getTypeName(), new Object[] { params }

                                );

                        if (resource == null) {

                                throw new ResourceNotRegisteredException(params.getTypeName());

                        }

                } catch (InstantiationException e) {

                        throw new InitializeException(e);

                } catch (IllegalAccessException e) {

                        throw new InitializeException(e);

                } catch (SecurityException e) {

                        throw new InitializeException(e);

                } catch (IllegalArgumentException e) {

                        throw new InitializeException(e);

                } catch (NoSuchMethodException e) {

                        throw new InitializeException(e);

                } catch (InvocationTargetException e) {

                        throw new InitializeException(e);

                }

                return resource;

        }

        public ResourceProvider createAddResource(ResourceParameters params)

                        throws InitializeException {

                try {

                    String name = params.getResurceID();

                    Resource res = (Resource)(this.resources.get(name));

                    if( res!=null ) {

                        return (AbstractResource)res;

                    }

                    return addResource((AbstractResource) createResource(params));

                } catch (AccessResourceException e) {

                        throw new InitializeException(params.getTypeName(), e);

                }

        }

        public boolean register(String type, String description,

                        Class resourceHandler, Class resourceParams) {

                ToolsLocator.getExtensionPointManager().add(DATA_MANAGER_RESOURCE,

                                DATA_MANAGER_RESOURCE_DESCRIPTION).append(type, description,

                                                resourceHandler);

                ToolsLocator.getExtensionPointManager().add(

                                DATA_MANAGER_RESOURCE_PARAMS,

                                DATA_MANAGER_RESOURCE_PARAMS_DESCRIPTION).append(type,

                                description, resourceParams);

                return true;

        }

        public List getResourceProviders() {

                return ToolsLocator.getExtensionPointManager().get(

                                DATA_MANAGER_RESOURCE).getNames();

        }

    public synchronized void closeResources() throws DataException {

                this.collectResources();

                Resource res;

                Iterator iter = this.resources.values().iterator();

                while (iter.hasNext()) {

                        res = (Resource) iter.next();

                        res.closeRequest();

                }

        }

    public synchronized void dispose() throws DisposeResorceManagerException {

        DisposeResorceManagerException exception = new DisposeResorceManagerException();

        try {

            this.collectResources();

        } catch (DataException e) {

            exception.add(e);

        }

        Resource res;

        Iterator iter = this.resources.values().iterator();

        while (iter.hasNext()) {

            res = (Resource) iter.next();

            try {

                if (res.openCount() > 0) {

                    exception.add(

                            new ResourceNotClosedOnDisposeManagerException(

                                    res));

                }

                res.closeRequest();

                iter.remove();

            } catch (ResourceException e) {

                exception.add(e);

            }

        }

        this.resources = null;

        this.delegateObservable.deleteObservers();

        this.delegateObservable = null;

        if (!exception.isEmpty()) {

            throw exception;

        }

    }

        public int getTimeToBeIdle() {

                if (mlsecondsToBeIdle == 0) {

                        return 0;

                }

                return (int) (mlsecondsToBeIdle / 1000);

        }

        public void setTimeToBeIdle(int seconds) {

                if (seconds < 0) {

                        throw new IllegalArgumentException("seconds must be >= 0");

                }

                mlsecondsToBeIdle = seconds * 1000;

        }

}