Application: gvSIG desktop

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">

<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">

    <appender name="CONSOLE" class="org.apache.log4j.ConsoleAppender">

        <layout class="org.apache.log4j.PatternLayout">

            <param name="ConversionPattern" value="%d{HH:mm:ss,SSS} %-5p [%c{2}.%M()]\n  %m%n"/>

        </layout>

    </appender>

  <category name="org.gvsig.fmap.dal">

    <priority value="WARN"/>

  </category>

    <root>

        <priority value="INFO" />

        <appender-ref ref="CONSOLE" />

    </root>

</log4j:configuration>

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 *

 * 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 2

 * 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.

 *

 */

/*

* AUTHORS (In addition to CIT):

* 2008 IVER T.I. S.A.   {{Task}}

*/

package org.gvsig.fmap.dal;

/**

 * DataServerExplorer parameter container. Provides a way to obtain the name 

 * of the specific data explorer type described by this parameters.

 * 

 */

public interface DataServerExplorerParameters extends DataParameters {

	/**

	 * Returns the name of the data explorer type of the DataServerExplorer

	 * represented by this DataServerExplorerParameters

	 * 

	 * @return a String containing the name of the data explorer type

	 */

	public String getExplorerName();

}

package org.gvsig.fmap.dal.resource;

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

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

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

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

/**

 * Encapsulates a system resource (file, database connection, etc). 

 * It is used to manage usage and availability of shared system 

 * resources. This interface allows monitoring a resource and helps 

 * preventing dead locks on it as well as being freed as soon as

 * it is not being used.

 * 

 * Data providers can provide implementations for their own resources. This

 * is specially interesting when resources require a specific treatment

 * beyond the standard shared file or connection, for instance to manage 

 * connections to a server through its own connection pool.

 */

public interface Resource {

	/**

	 * Returns the resource's name.

	 * 

	 * @return resource's name

	 * 

	 * @throws AccessResourceException

	 */

	public String getName() throws AccessResourceException;

	/**

	 * Returns the resource parameters. These parameters contain

	 * all the necessary information to access the resource.

	 * 

	 * @return resource parameters.

	 */

	public ResourceParameters getParameters();

	/**

	 * Returns the date and time in which this resource was opened for the last

	 * time.

	 * 

	 * @return date and time in which this resource was opened for the last

	 *         time, in milliseconds.

	 */

	public long getLastTimeOpen();

	/**

	 * Returns the date and time in which this resource was accessed for the

	 * last time.

	 * 

	 * @return date and time in which this resource was accessed for the last

	 *         time, in milliseconds.

	 */

	public long getLastTimeUsed();

	/**

	 * Returns whether this resource is already in use by someone.

	 * 

	 * @return

	 * 		true if this resource is in use, false if not.

	 */

	public boolean inUse();

	/**

	 * Returns whether this resource is opened.

	 * 

	 * @return

	 * 		true if this resource is opened, false if not.

	 */

	public boolean isOpen();

	/**

	 * Returns the number of times this resource has been opened 

	 * since it was created.

	 * 

	 * @return 

	 * 		number of times this resource has been opened 

	 * since it was created.

	 */

	public int openCount();

	/**

	 * Executes an action which uses the current {@link Resource}.

	 * 

	 * @param runnable

	 *            to execute

	 * @return the action return value

	 * @throws ResourceException

	 *             if there is an error executing the action

	 */

	public Object execute(ResourceAction action)

			throws ResourceExecuteException;

	/**

	 * If the resource is not in use, calling this method will send a close request 

	 * to all consumers referencing this resource. If the resource is in use, 

	 * calling this method will do nothing.

	 * 

	 * @throws ResourceException

	 */

	public void closeRequest() throws ResourceException;

	/**

	 * Adds a consumer to this resource. This will create a weak reference 

	 * to the consumer in this resource's consumer list.

	 * 

	 * @param consumer

	 * 				the consumer that will be added to this resource's consumer list.

	 */

	public void addConsumer(ResourceConsumer consumer);

	/**

	 * Removes a consumer from this resource's consumer list.

	 * 

	 * @param consumer

	 * 				the consumer that will be removed.

	 */

	public void removeConsumer(ResourceConsumer consumer);

	/**

	 * Returns this resource's current number of consumers.

	 * 

	 * @return

	 * 		current number of consumers of this resource.

	 */

	public int getConsumersCount();

	/**

	 * Returns an object that represents the resource. The actual type

	 * depends on the resource provider. It could be a string with a 

	 * descriptive name or something more elaborated.

	 * 

	 * @return

	 * 		an object that represents the resource.

	 * 

	 * @throws AccessResourceException

	 */

	public Object get() throws AccessResourceException;

	/**

	 * Returns a custom object containing extended data relative to 

	 * this resource.

	 * 

	 * This is part of a simple mechanism to allow passing further data to 

	 * the resource that may be necessary for optimal treatment.

	 * 

	 * @return

	 * 		data related to this resource

	 */

	public Object getData();

	/**

	 * Sets a custom object as this resource's extended data.

     *

	 * This is part of a simple mechanism to allow passing further data to 

	 * the resource that may be necessary for optimal treatment.

	 *

	 * @param data

	 * 			a custom object containing data related to this resource.

	 */

	public void setData(Object data);

}

package org.gvsig.fmap.dal.resource;

import org.gvsig.fmap.dal.DataParameters;

/**

 * Interface that contains any resource parameters.

 * Each specific subtype of resource will extend this

 * interface with its own relevant parameters.

 *

 */

public interface ResourceParameters extends DataParameters {

	/**

	 * Returns the type name of the related resource.

	 * 

	 * @return

	 * 		type name of the resource.

	 */

	public String getTypeName();

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 * 

 * 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 2

 * 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.

 * 

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 {}  {{Task}}

 */

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

import java.util.ArrayList;

import java.util.List;

import org.gvsig.fmap.dal.DALLocator;

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

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

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

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

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

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

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

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

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * Resource implementation which is able to show an unique interface to a group

 * of Resources.

 * 

 * @author 2009- <a href="cordinyana@gvsig.org">C?sar Ordi?ana</a> - gvSIG team

 */

public class MultiResource extends AbstractResource {

	public static final String TYPE_NAME = "multi";

	public static final String DESCRIPTION = "Group of multiple resources";

	private static final Logger LOG =

			LoggerFactory.getLogger(MultiResource.class);

	private List resources = new ArrayList();

	// Initially, the first one

	private int defaultResourcePos = 0;

	/**

	 * Creates a new {@link MultiResource} from the given parameters.

	 * 

	 * @param parameters

	 *            to create the resource from

	 * @throws InitializeException

	 *             if there is an error creating the resource

	 */

	public MultiResource(MultiResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	private List getResources() {

		return resources;

	}

	/**

	 * Adds a new {@link ResourceProvider} to the list of Resources managed by

	 * this group.

	 * 

	 * @param parameters

	 *            to create the resource from

	 * @param defaultResource

	 *            if the added resource is to be used as the multi resource

	 *            default one

	 * @throws InitializeException

	 *             if there is an error adding the resource

	 */

	public void addResource(ResourceParameters parameters,

			boolean defaultResource) throws InitializeException {

		ResourceProvider resourceProvider =

				((ResourceManagerProviderServices) DALLocator.getResourceManager()).createResource(parameters);

		resources.add(resourceProvider);

		if (defaultResource) {

			defaultResourcePos = resources.size() - 1;

		}

	}

	/**

	 * Adds a new {@link ResourceProvider} to the list of Resources managed by

	 * this group.

	 * 

	 * @param name

	 *            of the resource to add

	 * @param params

	 *            parameters to create the resource with

	 * @param defaultResource

	 *            if the added resource is to be used as the multi resource

	 *            default one

	 * @throws InitializeException

	 *             if there is an error adding the resource

	 */

	public void addResource(String name, Object[] params,

			boolean defaultResource) throws InitializeException {

		ResourceProvider resourceProvider =

				((ResourceManagerProviderServices) DALLocator.getResourceManager()).createResource(

						name, params);

		resources.add(resourceProvider);

		if (defaultResource) {

			defaultResourcePos = resources.size() - 1;

		}

	}

	public boolean isThis(ResourceParameters parameters)

			throws ResourceException {

		if (parameters instanceof MultiResourceParameters) {

			MultiResourceParameters multiParams =

					(MultiResourceParameters) parameters;

			return multiParams.getName() != null

					&& multiParams.getName().equals(

							getMultiResourceParameters().getName());

		}

		return false;

	}

	public void notifyChanges() throws ResourceNotifyChangesException {

		List resources = getResources();

		for (int i = 0; i < resources.size(); i++) {

			((ResourceProvider) getResources().get(i)).notifyChanges();

		}

	}

	public void notifyClose() throws ResourceNotifyCloseException {

		List resources = getResources();

		for (int i = 0; i < resources.size(); i++) {

			((ResourceProvider) getResources().get(i)).notifyClose();

		}

	}

	public void notifyDispose() throws ResourceNotifyDisposeException {

		List resources = getResources();

		for (int i = 0; i < resources.size(); i++) {

			((ResourceProvider) getResources().get(i)).notifyDispose();

		}

	}

	public void notifyOpen() throws ResourceNotifyOpenException {

		List resources = getResources();

		for (int i = 0; i < resources.size(); i++) {

			((ResourceProvider) getResources().get(i)).notifyOpen();

		}

	}

	public void prepare() throws PrepareResourceException {

		List resources = getResources();

		for (int i = 0; i < resources.size(); i++) {

			((ResourceProvider) getResources().get(i)).prepare();

		}

	}

	public void closeRequest() throws ResourceException {

		List resources = getResources();

		for (int i = 0; i < resources.size(); i++) {

			((ResourceProvider) getResources().get(i)).closeRequest();

		}

	}

	public Object get() throws AccessResourceException {

		ResourceProvider defaultResource = getDefaultResource();

		if (defaultResource == null) {

			return null;

		} else {

			return defaultResource.get();

		}

	}

	public Object getData() {

		ResourceProvider defaultResource = getDefaultResource();

		if (defaultResource == null) {

			return null;

		} else {

			return defaultResource.getData();

		}

	}

	private MultiResourceParameters getMultiResourceParameters() {

		return (MultiResourceParameters) getParameters();

	}

	public String getName() throws AccessResourceException {

		StringBuffer buffer =

				new StringBuffer().append("MultiResource ").append(

						getMultiResourceParameters().getName()).append(":: ");

		List resources = getResources();

		for (int i = 0; i < resources.size(); i++) {

			buffer.append(((ResourceProvider) resources.get(i)).getName());

			if (defaultResourcePos == i) {

				buffer.append(" (default)");

			}

			if (i < resources.size() - 1) {

				buffer.append(", ");

			}

		}

		return buffer.toString();

	}

	public String toString() {

		try {

			return getName();

		} catch (AccessResourceException e) {

			LOG.error("Error getting the resource name", e);

		}

		return super.toString();

	}

	private ResourceProvider getDefaultResource() {

		if (getResources().size() > 0) {

			return (ResourceProvider) getResources().get(defaultResourcePos);

		} else {

			return null;

		}

	}

	public void setData(Object data) {

		ResourceProvider defaultResource = getDefaultResource();

		if (defaultResource != null) {

			defaultResource.setData(data);

		}

	}

}

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

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

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

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

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

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

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

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

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

public interface ResourceProvider extends Resource {

	public void notifyOpen() throws ResourceNotifyOpenException;

	public void notifyClose() throws ResourceNotifyCloseException;

	public void notifyDispose() throws ResourceNotifyDisposeException;

	public void notifyChanges() throws ResourceNotifyChangesException;

	public void prepare() throws PrepareResourceException;

	public boolean isThis(ResourceParameters parameters)

			throws ResourceException;

}

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

public interface ResourceConsumer {

	public boolean closeResourceRequested(ResourceProvider resource);

	public void resourceChanged(ResourceProvider resource);

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

* 

* 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 2

* 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.

* 

*/

/*

* AUTHORS (In addition to CIT):

* 2009 {}  {{Task}}

*/

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

import org.gvsig.fmap.dal.feature.spi.memory.MemoryResource;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dynobject.DelegatedDynObject;

import org.gvsig.tools.dynobject.DynClass;

import org.gvsig.tools.dynobject.DynObjectManager;

/**

 * Parameters for the creation of a multi resource.

 * 

 * @author 2009- <a href="cordinyana@gvsig.org">C?sar Ordi?ana</a> - gvSIG team

 */

public class MultiResourceParameters extends AbstractResourceParameters {

	public static final String DYNCLASS_NAME = "MultiResourceParameters";

	private static final String FIELD_NAME = "name";

	private DelegatedDynObject delegatedDynObject;

	/**

	 * Creates a new {@link MultiResourceParameters}.

	 */

	public MultiResourceParameters() {

		this.delegatedDynObject =

				(DelegatedDynObject) ToolsLocator.getDynObjectManager()

						.createDynObject(registerDynClass());

	}

	/**

	 * Creates a new {@link MultiResourceParameters}.

	 * 

	 * @param name

	 *            for the parameters. Will be used as the name of the

	 *            {@link MemoryResource} created with this parametres.

	 */

	public MultiResourceParameters(String name) {

		this();

		setName(name);

	}

	protected DelegatedDynObject getDelegatedDynObject() {

		return delegatedDynObject;

	}

	public String getTypeName() {

		return MultiResource.TYPE_NAME;

	}

	public String getName() {

		return (String) getDelegatedDynObject().getDynValue(FIELD_NAME);

	}

	public void setName(String name) {

		getDelegatedDynObject().setDynValue(FIELD_NAME, name);

	}

	/**

	 * Registers the {@link DynClass} of this parameters attributes.

	 * 

	 * @return the dyn class of this parameters

	 */

	private DynClass registerDynClass() {

		DynObjectManager dynman = ToolsLocator.getDynObjectManager();

		DynClass dynClass = dynman.get(DYNCLASS_NAME);

		if (dynClass == null) {

			dynClass = dynman.add(DYNCLASS_NAME);

			dynClass.addDynFieldString(FIELD_NAME).setDescription(

					"The name of the multi resource");

		}

		return dynClass;

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 *

 * 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 2

 * 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.

 *

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 IVER T.I   {{Task}}

 */

/**

 *

 */

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

import java.lang.ref.WeakReference;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

import org.gvsig.fmap.dal.resource.impl.DefaultResourceNotification;

import org.gvsig.tools.observer.Observer;

import org.gvsig.tools.observer.WeakReferencingObservable;

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

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

/**

 * <p>

 * Base implementation for Resource

 * </p>

 * 

 * <p>

 * This implementation not define the {@link Resource#begin()} and

 * {@link Resource#end()}

 * </p>

 * 

 * @author jmvivo

 * 

 */

public abstract class AbstractResource implements ResourceProvider,

		WeakReferencingObservable {

	private DelegateWeakReferencingObservable delegateObservable;

	private List consumers;

	private long lastTimeOpen;

	private long lastTimeUsed;

	private ResourceParameters parameters;

	private ResourceParameters preparedParameters;

	private Object data;

	private int openCount;

	/**

	 * Number of times an execute is being simultaneously performed with this

	 * resource.

	 */

	private int executeCount = 0;

	protected final Object lock;

	protected AbstractResource(ResourceParameters parameters)

			throws InitializeException {

		consumers = new ArrayList();

		lastTimeOpen = System.currentTimeMillis();

		lastTimeUsed = lastTimeOpen;

		openCount = 0;

		preparedParameters = null;

		delegateObservable = new DelegateWeakReferencingObservable(this);

		lock = new Object();

		try {

			this.parameters = (ResourceParameters) parameters.getCopy();

		} catch (CopyParametersException e) {

			throw new InitializeException(e);

		}

	}

	protected final void updateLastTimeUsed() {

		lastTimeUsed = System.currentTimeMillis();

	}

	protected final void updateLastTimeOpen() {

		lastTimeOpen = System.currentTimeMillis();

		lastTimeUsed = lastTimeOpen;

	}

	public final long getLastTimeOpen() {

		return lastTimeOpen;

	}

	public final long getLastTimeUsed() {

		return lastTimeUsed;

	}

	public final ResourceParameters getParameters() {

		if (preparedParameters != null) {

			return preparedParameters;

		}

		return this.parameters;

	}

	public void prepare(ResourceParameters params)

			throws PrepareResourceException {

		ResourceNotification notification =

				new DefaultResourceNotification(this,

						ResourceNotification.PREPARE, params);

		this.delegateObservable.notifyObservers(notification);

	}

	public void prepare() throws PrepareResourceException {

		if (preparedParameters == null) {

			try {

				ResourceParameters params =

						(ResourceParameters) parameters.getCopy();

				prepare(params);

				preparedParameters = params;

			} catch (CopyParametersException e) {

				throw new PrepareResourceException(this, e);

			}

		}

	}

	public void notifyOpen() throws ResourceNotifyOpenException {

		this.notifyObserver(ResourceNotification.OPEN);

		updateLastTimeOpen();

		openCount++;

	}

	public void notifyClose() throws ResourceNotifyCloseException {

		if (openCount <= 0) {

			throw new IllegalStateException();

		}

		this.notifyObserver(ResourceNotification.CLOSE);

		openCount--;

	}

	public void notifyChanges() throws ResourceNotifyChangesException {

		this.notifyObserver(ResourceNotification.CHANGED);

		Iterator it = consumers.iterator();

		while (it.hasNext()) {

			ResourceConsumer consumer =

					(ResourceConsumer) ((WeakReference) it.next()).get();

			if (consumer != null) {

				consumer.resourceChanged(this);

			} else {

				it.remove();

			}

		}

	}

	public boolean isOpen() {

		return this.openCount > 0;

	}

	public int openCount() {

		return this.openCount;

	}

	public void addObserver(Observer o) {

		this.delegateObservable.addObserver(o);

	}

	public void deleteObserver(Observer o) {

		this.delegateObservable.deleteObserver(o);

	}

	public void deleteObservers() {

		this.delegateObservable.deleteObservers();

	}

	public final void addObservers(BaseWeakReferencingObservable observers) {

		this.delegateObservable.addObservers(observers);

	}

	public final void addConsumer(ResourceConsumer consumer) {

		this.updateConsumersList();

		consumers.add(new WeakReference(consumer));

	}

	public final void removeConsumer(ResourceConsumer consumer) {

		ResourceConsumer cur;

		Iterator it = consumers.iterator();

		while (it.hasNext()) {

			cur = (ResourceConsumer) ((WeakReference) it.next()).get();

			if (cur == null || (cur == consumer)) {

				it.remove();

			}

		}

	}

	public int getConsumersCount() {

		this.updateConsumersList();

		return consumers.size();

	}

	private synchronized void updateConsumersList() {

		Iterator it = consumers.iterator();

		WeakReference ref;

		while (it.hasNext()) {

			ref = (WeakReference) it.next();

			if (ref.get() == null) {

				it.remove();

			}

		}

	}

	public void closeRequest() throws ResourceException {

		if (inUse()) {

			return;

		}

		if (consumers != null) {

			for (int i = 0; i < consumers.size(); i++) {

			}

		}

		if (consumers != null) {

			Iterator it = consumers.iterator();

			while (it.hasNext()) {

				ResourceConsumer consumer =

						(ResourceConsumer) ((WeakReference) it.next()).get();

				if (consumer != null) {

					consumer.closeResourceRequested(this);

				} else {

					it.remove();

				}

			}

		}

	}

	public void setData(Object data) {

		this.data = data;

	}

	public Object getData() {

		return this.data;

	}

	protected void notifyObserver(String type) {

		if (delegateObservable != null) {

			this.delegateObservable.notifyObservers(new DefaultResourceNotification(

					this, type));

		}

	}

	public void notifyDispose() throws ResourceNotifyDisposeException {

		this.notifyObserver(ResourceNotification.DISPOSE);

		if (consumers != null) {

			consumers.clear();

		}

		lastTimeOpen = 0l;

		lastTimeUsed = 0l;

		data = null;

		if (delegateObservable != null) {

			delegateObservable.deleteObservers();

		}

	}

	public final boolean inUse() {

		return executeCount > 0;

	}

	public Object execute(ResourceAction action)

			throws ResourceExecuteException {

		Object value = null;

		synchronized (lock) {

			executeBegins();

			try {

				value = performExecution(action);

			} catch (Exception e) {

				throw new ResourceExecuteException(this, e);

			} finally {

				executeEnds();

			}

		}

		return value;

	}

	protected Object performExecution(ResourceAction action) throws Exception {

		return action.run();

	}

	protected final void executeBegins() {

		executeCount++;

	}

	protected final void executeEnds() {

		updateLastTimeUsed();

		executeCount--;

	}

	/**

	 * Returns the name of the {@link Resource}.

	 * 

	 * @throws AccessResourceException

	 *             if there is an error while accessing the resource

	 */

	public abstract String getName() throws AccessResourceException;

	/**

	 * Returns the real resource represented by this object.

	 * 

	 * @throws AccessResourceException

	 *             if there is an error while accessing the resource

	 */

	public abstract Object get() throws AccessResourceException;

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 *

 * 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 2

 * 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.

 *

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 IVER T.I   {{Task}}

 */

/**

 *

 */

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

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

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

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

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

/**

 * <p>

 * Abstract Implementation for Resource that allows the concurrent access.

 * </p>

 * 

 * @author jmvivo

 * 

 */

public abstract class AbstractNonBlockingResource extends AbstractResource {

	/**

	 * @param parameters

	 * @throws InitializeException

	 */

	public AbstractNonBlockingResource(ResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	public Object execute(ResourceAction action)

			throws ResourceExecuteException {

		Object value = null;

		synchronized (lock) {

			executeBegins();

		}

		try {

			value = performExecution(action);

		} catch (Exception e) {

			throw new ResourceExecuteException(this, e);

		} finally {

			synchronized (lock) {

				executeEnds();

			}

		}

		return value;

	}

}

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

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

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

public abstract class AbstractResourceParameters extends AbstractDataParameters

		implements ResourceParameters {

}

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

import java.util.List;

import org.gvsig.fmap.dal.DataParameters;

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.ResourceManager;

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

public interface ResourceManagerProviderServices extends ResourceManager {

	public boolean register(String type, String description, Class handler,

			Class params);

	public DataParameters createParameters(String type)

			throws InitializeException;

	public ResourceProvider createAddResource(ResourceParameters params)

			throws InitializeException;

	public ResourceProvider createResource(ResourceParameters params)

			throws InitializeException;

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

			throws InitializeException;

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

			throws InitializeException;

	public void remove(Resource resource) throws DataException;

	public void remove(String name) throws DataException;

	public List getResourceProviders();

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* 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 2

* 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.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2008 IVER T.I   {{Task}}

*/

/**

 *

 */

package org.gvsig.fmap.dal.resource;

/**

 * A resource notification is related to a change in the state of a resource.

 * It is sent to all resource observers when appropriate. The notification contains

 * the type of change and access to the resource information.

 * 

 * This includes:

 * 

 * <ul>

 * 	<li>A resource has been opened</li>

 *  <li>A resource has been closed</li>

 *  <li>A resource has been prepared</li>

 *  <li>A resource property has been changed</li>

 *  <li>A resource is being disposed</li>

 *  <li>A resource is being opened</li>

 *  <li>A resource is being closed</li>

 * </ul>	

 * 

 * @author jmvivo

 */

public interface ResourceNotification {

	/** A resource has been opened */

	public static final String OPENED = "Opened_Resource";

	/** A resource has been closed */

	public static final String CLOSED = "Closed_Resource";

	/** A resource has been prepared */

	public static final String PREPARE = "Prepare_Resource";

	/** A resource property has been changed */

	public static final String CHANGED = "Changed_Resource";

	/** A resource is being disposed */

	public static final String DISPOSE = "Begin_Dispose_Resource";

	/** A resource is being opened */

	public static final String OPEN = "Begin_Open_Resource";

	/** A resource is being closed */

	public static final String CLOSE = "Begin_Close_Resource";

	/**

	 * Returns the parameters of the resource that caused

	 * this notification.

	 * 

	 * @return

	 * 		the parameters of this notification's source

	 */

	public ResourceParameters getParameters();

	/**

	 * Returns the resource that caused this notification.

	 * 

	 * @return

	 * 		this notification's source

	 */

	public Resource getResource();

	/**

	 * Returns the type of this notification.

	 * 

	 * @return

	 * 		this notification's type. For the allowed values see the 

	 * constants defined in this interface.

	 */

	public String getType();

}

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

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

public class DisposeResorceManagerException extends DataListException {

	/**

	 *

	 */

	private static final long serialVersionUID = -1818272776768733342L;

	private final static String MESSAGE_FORMAT = "Exception disposing.";

	private final static String MESSAGE_KEY = "_DisposeResorceManagerException";

	public DisposeResorceManagerException() {

		super(MESSAGE_FORMAT, MESSAGE_KEY, serialVersionUID);

	}

}

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

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

public class PrepareResourceException extends ResourceException {

	/**

	 *

	 */

	private static final long serialVersionUID = 2198478752691400900L;

	private final static String MESSAGE_FORMAT = "Exception preparing '%(resource)s'.";

	private final static String MESSAGE_KEY = "_PrepareResourceException";

	public PrepareResourceException(Resource resource, Throwable cause) {

		super(resource, MESSAGE_FORMAT, cause, MESSAGE_KEY, serialVersionUID);

	}

}

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

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

public class ResourceNotRegisteredException extends InitializeException {

	/**

	 *

	 */

	private static final long serialVersionUID = -3783563399272946137L;

	private final static String MESSAGE_FORMAT = "The '%(resourceType)' resource type is not registered.";

	private final static String MESSAGE_KEY = "_ResourceNotRegisteredException";

	public ResourceNotRegisteredException(String resourceType) {

		super(MESSAGE_FORMAT, MESSAGE_KEY, serialVersionUID);

		this.values.put("resourceType", resourceType);

	}

}

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

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

public class ResourceNotifyCloseException extends ResourceException {

	/**

	 *

	 */

	private static final long serialVersionUID = -805056352573291250L;

	private final static String MESSAGE_FORMAT = "Resource '%(resource)s' changed.";

	private final static String MESSAGE_KEY = "_ResourceNotifyCloseExceptionn";

	public ResourceNotifyCloseException(Resource resource) {

		super(resource, MESSAGE_FORMAT, MESSAGE_KEY, serialVersionUID);

	}

}

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

import java.util.HashMap;

import java.util.Map;

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

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

public abstract class ResourceException extends DataException {

	/**

	 *

	 */

	private static final long serialVersionUID = 1L;

	protected Map values = new HashMap();

	private Resource resource;

	public ResourceException(String messageFormat, Throwable cause,

			String messageKey, long code) {

		super(messageFormat, cause, messageKey, code);

	}

	public ResourceException(String messageFormat, String messageKey, long code) {

		super(messageFormat, messageKey, code);

	}

	public ResourceException(Resource resource, String messageFormat,

			Throwable cause, String messageKey, long code) {

		super(messageFormat, cause, messageKey, code);

		this.resource = resource;

		try {

			setValue("resource", resource.getName());

		} catch (AccessResourceException e) {

			setValue("resource", "unknow");

		}

	}

	public ResourceException(Resource resource, String messageFormat,

			String messageKey, long code) {

		super(messageFormat, messageKey, code);

		this.resource = resource;

		try {

			setValue("resource", resource.getName());

		} catch (AccessResourceException e) {

			setValue("resource", "unknow");

		}