Author: rhauch Date: 2008-07-09 11:01:11 -0400 (Wed, 09 Jul 2008) New Revision: 347 Added: trunk/dna-repository/src/main/java/org/jboss/dna/repository/federation/impl/ trunk/dna-repository/src/main/java/org/jboss/dna/repository/federation/impl/FederatingCommandExecutor.java Log: DNA-115 - Create federation service http://jira.jboss.com/jira/browse/DNA-115 Added FederatingCommandExecutor implementation, which is used by the FederatedRepository to execute commands. Added: trunk/dna-repository/src/main/java/org/jboss/dna/repository/federation/impl/FederatingCommandExecutor.java =================================================================== --- trunk/dna-repository/src/main/java/org/jboss/dna/repository/federation/impl/FederatingCommandExecutor.java (rev 0) +++ trunk/dna-repository/src/main/java/org/jboss/dna/repository/federation/impl/FederatingCommandExecutor.java 2008-07-09 15:01:11 UTC (rev 347) @@ -0,0 +1,179 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2008, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file in the + * distribution for a full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.dna.repository.federation.impl; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import net.jcip.annotations.NotThreadSafe; +import org.jboss.dna.common.util.Logger; +import org.jboss.dna.repository.federation.FederatedRegion; +import org.jboss.dna.spi.graph.Name; +import org.jboss.dna.spi.graph.PathNotFoundException; +import org.jboss.dna.spi.graph.commands.GetPropertiesCommand; +import org.jboss.dna.spi.graph.commands.executor.AbstractCommandExecutor; +import org.jboss.dna.spi.graph.commands.impl.BasicGetPropertiesCommand; +import org.jboss.dna.spi.graph.connection.ExecutionEnvironment; +import org.jboss.dna.spi.graph.connection.RepositoryConnection; +import org.jboss.dna.spi.graph.connection.RepositoryConnectionFactories; +import org.jboss.dna.spi.graph.connection.RepositoryConnectionFactory; +import org.jboss.dna.spi.graph.connection.RepositorySource; +import org.jboss.dna.spi.graph.connection.RepositorySourceException; + +/** + * @author Randall Hauch + */ +@NotThreadSafe +public class FederatingCommandExecutor extends AbstractCommandExecutor { + + private final Name mergePlanPropertyName; + private final FederatedRegion cacheRegion; + private final List<FederatedRegion> regions; + private final RepositoryConnectionFactories connectionFactories; + /** The set of all connections, including the cache connection */ + private final Map<String, RepositoryConnection> connectionsBySourceName; + /** A direct reference to the cache connection */ + private RepositoryConnection cacheConnection; + + /** + * @param env the execution environment in which the executor will be run; may not be null + * @param sourceName the name of the {@link RepositorySource} that is making use of this executor; may not be null or empty + * @param cacheRegion the region used for the cached information; may not be null + * @param regions the federated regions; may not be null + * @param connectionFactories the factory for connection factory instances + */ + public FederatingCommandExecutor( ExecutionEnvironment env, + String sourceName, + FederatedRegion cacheRegion, + List<FederatedRegion> regions, + RepositoryConnectionFactories connectionFactories ) { + super(env, sourceName); + assert regions != null; + assert connectionFactories != null; + assert cacheRegion != null; + this.cacheRegion = cacheRegion; + this.regions = regions; + this.connectionFactories = connectionFactories; + this.connectionsBySourceName = new HashMap<String, RepositoryConnection>(); + this.mergePlanPropertyName = env.getValueFactories().getNameFactory().create("dna:mergePlan"); + } + + /** + * {@inheritDoc} + * + * @see org.jboss.dna.spi.graph.commands.executor.AbstractCommandExecutor#close() + */ + @Override + public void close() throws InterruptedException { + try { + super.close(); + } finally { + // Make sure to close ALL open connections ... + for (RepositoryConnection connection : connectionsBySourceName.values()) { + if (connection == null) continue; + try { + connection.close(); + } catch (Throwable t) { + Logger.getLogger(getClass()).debug("Error while closing connection to {0}", connection.getSourceName()); + } + } + connectionsBySourceName.clear(); + } + } + + protected RepositoryConnection getConnectionToCache() throws RepositorySourceException, InterruptedException { + if (this.cacheConnection == null) { + this.cacheConnection = getConnection(this.cacheRegion); + } + assert this.cacheConnection != null; + return this.cacheConnection; + } + + protected RepositoryConnection getConnection( FederatedRegion region ) throws RepositorySourceException, InterruptedException { + String sourceName = region.getSourceName(); + RepositoryConnection connection = connectionsBySourceName.get(sourceName); + if (connection == null) { + RepositoryConnectionFactory connectionFactory = connectionFactories.getConnectionFactory(sourceName); + if (connectionFactory != null) { + connection = connectionFactory.getConnection(); + } + connectionsBySourceName.put(sourceName, connection); + } + return connection; + } + + /** + * {@inheritDoc} + * + * @see org.jboss.dna.spi.graph.commands.executor.AbstractCommandExecutor#execute(org.jboss.dna.spi.graph.commands.GetPropertiesCommand) + */ + @Override + public void execute( GetPropertiesCommand command ) throws RepositorySourceException, InterruptedException { + + // Check the cache first ... + RepositoryConnection cacheConnection = getConnectionToCache(); + BasicGetPropertiesCommand fromCache = new BasicGetPropertiesCommand(command.getPath()); + cacheConnection.execute(getEnvironment(), fromCache); + if (fromCache.getError() instanceof PathNotFoundException) { + } else { + // Get the existing merge plan from the cached properties ... + // MergePlan mergePlan = getMergePlan(fromCache); + // DateTime + // if ( mergePlan.getExpirationTimeInUtc() ) + } + } + + // protected MergePlan getMergePlan( BasicGetPropertiesCommand command ) { + // Property mergePlanProperty = command.getProperties().get(mergePlanPropertyName); + // if (mergePlanProperty == null || mergePlanProperty.isEmpty()) { + // return null; + // } + // ValueFactory<Binary> binaryFactory = getEnvironment().getValueFactories().getBinaryFactory(); + // Binary binaryValue = binaryFactory.create(mergePlanProperty.getValues().next()); + // binaryValue.acquire(); + // ObjectInputStream stream = null; + // MergePlan mergePlan = null; + // RepositorySourceException error = null; + // try { + // stream = new ObjectInputStream(binaryValue.getStream()); + // mergePlan = (MergePlan)stream.readObject(); + // } catch (Throwable err) { + // I18n msg = RepositoryI18n.errorReadingMergePlan; + // error = new RepositorySourceException(getSourceName(), msg.text(command.getPath()), err); + // throw error; + // } finally { + // try { + // if (stream != null) stream.close(); + // } catch (Throwable err) { + // if (error == null) { + // I18n msg = RepositoryI18n.errorReadingMergePlan; + // error = new RepositorySourceException(getSourceName(), msg.text(command.getPath()), err); + // throw error; + // } + // } finally { + // binaryValue.release(); + // } + // } + // return mergePlan; + // } + // +} Property changes on: trunk/dna-repository/src/main/java/org/jboss/dna/repository/federation/impl/FederatingCommandExecutor.java ___________________________________________________________________ Name: svn:mime-type + text/plain