You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@archiva.apache.org by ol...@apache.org on 2011/11/05 19:50:29 UTC
svn commit: r1198011 - in /archiva/trunk/archiva-modules:
archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/
archiva-web/archiva-webapp/src/main/webapp/WEB-INF/
archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webd...
Author: olamy
Date: Sat Nov 5 18:50:28 2011
New Revision: 1198011
URL: http://svn.apache.org/viewvc?rev=1198011&view=rev
Log:
[MRM-815] aggregate indices for repository groups.
delete temporary on session end with a session listener
periodical taks to cleanup too old temp group index.
Added:
archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndex.java (with props)
archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndexCleaner.java (with props)
archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/util/TemporaryGroupIndexSessionCleaner.java (with props)
Modified:
archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/DefaultIndexMerger.java
archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/IndexMerger.java
archiva/trunk/archiva-modules/archiva-web/archiva-webapp/src/main/webapp/WEB-INF/web.xml
archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/ArchivaDavResourceFactory.java
Modified: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/DefaultIndexMerger.java
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/DefaultIndexMerger.java?rev=1198011&r1=1198010&r2=1198011&view=diff
==============================================================================
--- archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/DefaultIndexMerger.java (original)
+++ archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/DefaultIndexMerger.java Sat Nov 5 18:50:28 2011
@@ -23,7 +23,6 @@ import org.apache.archiva.admin.model.ma
import org.apache.archiva.common.plexusbridge.MavenIndexerUtils;
import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
import org.apache.archiva.common.plexusbridge.PlexusSisuBridgeException;
-import org.apache.commons.io.FileUtils;
import org.apache.maven.index.NexusIndexer;
import org.apache.maven.index.context.IndexingContext;
import org.apache.maven.index.context.UnsupportedExistingLuceneIndexException;
@@ -31,14 +30,13 @@ import org.apache.maven.index.packer.Ind
import org.apache.maven.index.packer.IndexPackingRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import javax.inject.Inject;
import java.io.File;
import java.io.IOException;
import java.util.Collection;
-import java.util.Date;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
@@ -62,7 +60,7 @@ public class DefaultIndexMerger
private IndexPacker indexPacker;
- private List<TemporaryIndex> temporaryIndexes = new CopyOnWriteArrayList<TemporaryIndex>();
+ private List<TemporaryGroupIndex> temporaryGroupIndexes = new CopyOnWriteArrayList<TemporaryGroupIndex>();
@Inject
public DefaultIndexMerger( PlexusSisuBridge plexusSisuBridge, MavenIndexerUtils mavenIndexerUtils )
@@ -73,7 +71,7 @@ public class DefaultIndexMerger
indexPacker = plexusSisuBridge.lookup( IndexPacker.class, "default" );
}
- public File buildMergedIndex( Collection<String> repositoriesIds, boolean packIndex )
+ public IndexingContext buildMergedIndex( Collection<String> repositoriesIds, boolean packIndex )
throws IndexMergerException
{
File tempRepoFile = Files.createTempDir();
@@ -104,8 +102,8 @@ public class DefaultIndexMerger
IndexPackingRequest request = new IndexPackingRequest( indexingContext, indexLocation );
indexPacker.packIndex( request );
}
- temporaryIndexes.add( new TemporaryIndex( tempRepoFile, tempRepoId ) );
- return indexingContext.getIndexDirectoryFile();
+ temporaryGroupIndexes.add( new TemporaryGroupIndex( tempRepoFile, tempRepoId ) );
+ return indexingContext;
}
catch ( IOException e )
{
@@ -117,70 +115,30 @@ public class DefaultIndexMerger
}
}
-
- @Scheduled( fixedDelay = 900000 )
- public void cleanTemporaryIndex()
+ @Async
+ public void cleanTemporaryGroupIndex( TemporaryGroupIndex temporaryGroupIndex )
{
- for ( TemporaryIndex temporaryIndex : temporaryIndexes )
+ if ( temporaryGroupIndex == null )
{
- // cleanup files older than 30 minutes
- if ( new Date().getTime() - temporaryIndex.creationTime > 1800000 )
- {
- try
- {
- IndexingContext context = indexer.getIndexingContexts().get( temporaryIndex.indexId );
- if ( context != null )
- {
- indexer.removeIndexingContext( context, true );
- }
- else
- {
- FileUtils.deleteDirectory( temporaryIndex.directory );
- }
- temporaryIndexes.remove( temporaryIndex );
- log.debug( "remove directory {}", temporaryIndex.directory );
- }
- catch ( IOException e )
- {
- log.warn( "failed to remove directory:" + temporaryIndex.directory, e );
- }
- }
- temporaryIndexes.remove( temporaryIndex );
+ return;
}
- }
-
- private static class TemporaryIndex
- {
- private long creationTime = new Date().getTime();
- private File directory;
-
- private String indexId;
-
- TemporaryIndex( File directory, String indexId )
+ try
{
- this.directory = directory;
- this.indexId = indexId;
+ IndexingContext indexingContext = indexer.getIndexingContexts().get( temporaryGroupIndex.getIndexId() );
+ if ( indexingContext != null )
+ {
+ indexer.removeIndexingContext( indexingContext, true );
+ }
}
-
- @Override
- public int hashCode()
+ catch ( IOException e )
{
- return Long.toString( creationTime ).hashCode();
+ log.warn( "fail to delete temporary group index {}", temporaryGroupIndex.getIndexId(), e );
}
+ }
- @Override
- public boolean equals( Object o )
- {
- if ( this == o )
- {
- return true;
- }
- if ( !( o instanceof TemporaryIndex ) )
- {
- return false;
- }
- return this.creationTime == ( (TemporaryIndex) o ).creationTime;
- }
+ public Collection<TemporaryGroupIndex> getTemporaryGroupIndexes()
+ {
+ return this.temporaryGroupIndexes;
}
}
Modified: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/IndexMerger.java
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/IndexMerger.java?rev=1198011&r1=1198010&r2=1198011&view=diff
==============================================================================
--- archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/IndexMerger.java (original)
+++ archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/IndexMerger.java Sat Nov 5 18:50:28 2011
@@ -18,6 +18,8 @@ package org.apache.archiva.indexer.merge
* under the License.
*/
+import org.apache.maven.index.context.IndexingContext;
+
import java.io.File;
import java.util.Collection;
@@ -28,11 +30,20 @@ import java.util.Collection;
public interface IndexMerger
{
/**
+ * default tmp created group index ttl in minutes
+ */
+ static final int DEFAULT_GROUP_INDEX_TTL = 1;
+
+ /**
* @param repositoriesIds repositories Ids to merge content
- * @param packIndex will generate a downloadable index
+ * @param packIndex will generate a downloadable index
* @return a temporary directory with a merge index (directory marked deleteOnExit)
* @throws IndexMergerException
*/
- File buildMergedIndex( Collection<String> repositoriesIds, boolean packIndex )
+ IndexingContext buildMergedIndex( Collection<String> repositoriesIds, boolean packIndex )
throws IndexMergerException;
+
+ void cleanTemporaryGroupIndex( TemporaryGroupIndex temporaryGroupIndex );
+
+ Collection<TemporaryGroupIndex> getTemporaryGroupIndexes();
}
Added: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndex.java
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndex.java?rev=1198011&view=auto
==============================================================================
--- archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndex.java (added)
+++ archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndex.java Sat Nov 5 18:50:28 2011
@@ -0,0 +1,95 @@
+package org.apache.archiva.indexer.merger;
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import java.io.File;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author Olivier Lamy
+ */
+public class TemporaryGroupIndex
+ implements Serializable
+{
+ private long creationTime = new Date().getTime();
+
+ private File directory;
+
+ private String indexId;
+
+ public TemporaryGroupIndex( File directory, String indexId )
+ {
+ this.directory = directory;
+ this.indexId = indexId;
+ }
+
+ public long getCreationTime()
+ {
+ return creationTime;
+ }
+
+ public TemporaryGroupIndex setCreationTime( long creationTime )
+ {
+ this.creationTime = creationTime;
+ return this;
+ }
+
+ public File getDirectory()
+ {
+ return directory;
+ }
+
+ public TemporaryGroupIndex setDirectory( File directory )
+ {
+ this.directory = directory;
+ return this;
+ }
+
+ public String getIndexId()
+ {
+ return indexId;
+ }
+
+ public TemporaryGroupIndex setIndexId( String indexId )
+ {
+ this.indexId = indexId;
+ return this;
+ }
+
+ @Override
+ public int hashCode()
+ {
+ return Long.toString( creationTime ).hashCode();
+ }
+
+ @Override
+ public boolean equals( Object o )
+ {
+ if ( this == o )
+ {
+ return true;
+ }
+ if ( !( o instanceof TemporaryGroupIndex ) )
+ {
+ return false;
+ }
+ return this.creationTime == ( (TemporaryGroupIndex) o ).creationTime;
+ }
+}
Propchange: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndex.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndex.java
------------------------------------------------------------------------------
svn:keywords = Author Date Id Revision
Added: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndexCleaner.java
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndexCleaner.java?rev=1198011&view=auto
==============================================================================
--- archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndexCleaner.java (added)
+++ archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndexCleaner.java Sat Nov 5 18:50:28 2011
@@ -0,0 +1,85 @@
+package org.apache.archiva.indexer.merger;
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
+import org.apache.archiva.common.plexusbridge.PlexusSisuBridgeException;
+import org.apache.maven.index.NexusIndexer;
+import org.apache.maven.index.context.IndexingContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import javax.inject.Inject;
+import java.io.IOException;
+import java.util.Date;
+
+/**
+ * @author Olivier Lamy
+ * @since 1.4-M2
+ */
+@Service
+public class TemporaryGroupIndexCleaner
+{
+ private Logger log = LoggerFactory.getLogger( getClass() );
+
+ @Inject
+ private IndexMerger indexMerger;
+
+ private NexusIndexer indexer;
+
+ @Inject
+ public TemporaryGroupIndexCleaner( PlexusSisuBridge plexusSisuBridge )
+ throws PlexusSisuBridgeException
+ {
+ indexer = plexusSisuBridge.lookup( NexusIndexer.class );
+ }
+
+ // 900000
+ @Scheduled( fixedDelay = 900000 )
+ public void cleanTemporaryIndex()
+ {
+ for ( TemporaryGroupIndex temporaryGroupIndex : indexMerger.getTemporaryGroupIndexes() )
+ {
+ // cleanup files older than 60 minutes 3600000
+ if ( new Date().getTime() - temporaryGroupIndex.getCreationTime() > 3600000 )
+ {
+ try
+ {
+ IndexingContext context = indexer.getIndexingContexts().get( temporaryGroupIndex.getIndexId() );
+ if ( context != null )
+ {
+ indexer.removeIndexingContext( context, true );
+ }
+ else
+ {
+ indexMerger.cleanTemporaryGroupIndex( temporaryGroupIndex );
+ }
+ indexMerger.getTemporaryGroupIndexes().remove( temporaryGroupIndex );
+ log.debug( "remove directory {}", temporaryGroupIndex.getDirectory() );
+ }
+ catch ( IOException e )
+ {
+ log.warn( "failed to remove directory:" + temporaryGroupIndex.getDirectory(), e );
+ }
+ }
+ }
+ }
+}
Propchange: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndexCleaner.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/TemporaryGroupIndexCleaner.java
------------------------------------------------------------------------------
svn:keywords = Author Date Id Revision
Modified: archiva/trunk/archiva-modules/archiva-web/archiva-webapp/src/main/webapp/WEB-INF/web.xml
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-web/archiva-webapp/src/main/webapp/WEB-INF/web.xml?rev=1198011&r1=1198010&r2=1198011&view=diff
==============================================================================
--- archiva/trunk/archiva-modules/archiva-web/archiva-webapp/src/main/webapp/WEB-INF/web.xml (original)
+++ archiva/trunk/archiva-modules/archiva-web/archiva-webapp/src/main/webapp/WEB-INF/web.xml Sat Nov 5 18:50:28 2011
@@ -89,6 +89,11 @@
<listener-class>net.sf.ehcache.constructs.web.ShutdownListener</listener-class>
</listener>
+ <!-- to cleanup temporary group index created during a session -->
+ <listener>
+ <listener-class>org.apache.archiva.webdav.util.TemporaryGroupIndexSessionCleaner</listener-class>
+ </listener>
+
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>
Modified: archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/ArchivaDavResourceFactory.java
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/ArchivaDavResourceFactory.java?rev=1198011&r1=1198010&r2=1198011&view=diff
==============================================================================
--- archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/ArchivaDavResourceFactory.java (original)
+++ archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/ArchivaDavResourceFactory.java Sat Nov 5 18:50:28 2011
@@ -31,6 +31,7 @@ import org.apache.archiva.configuration.
import org.apache.archiva.configuration.RepositoryGroupConfiguration;
import org.apache.archiva.indexer.merger.IndexMerger;
import org.apache.archiva.indexer.merger.IndexMergerException;
+import org.apache.archiva.indexer.merger.TemporaryGroupIndex;
import org.apache.archiva.indexer.search.RepositorySearch;
import org.apache.archiva.model.ArchivaRepositoryMetadata;
import org.apache.archiva.model.ArtifactReference;
@@ -52,6 +53,7 @@ import org.apache.archiva.scheduler.repo
import org.apache.archiva.security.ServletAuthenticator;
import org.apache.archiva.webdav.util.MimeTypes;
import org.apache.archiva.webdav.util.RepositoryPathUtil;
+import org.apache.archiva.webdav.util.TemporaryGroupIndexSessionCleaner;
import org.apache.archiva.webdav.util.WebdavMethodUtil;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.FilenameUtils;
@@ -65,6 +67,7 @@ import org.apache.jackrabbit.webdav.DavS
import org.apache.jackrabbit.webdav.DavSession;
import org.apache.jackrabbit.webdav.lock.LockManager;
import org.apache.jackrabbit.webdav.lock.SimpleLockManager;
+import org.apache.maven.index.context.IndexingContext;
import org.apache.maven.model.DistributionManagement;
import org.apache.maven.model.Model;
import org.apache.maven.model.Relocation;
@@ -98,6 +101,7 @@ import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
+import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
@@ -1198,16 +1202,29 @@ public class ArchivaDavResourceFactory
try
{
HttpSession session = request.getSession();
- Map<String, File> testValue = (Map<String, File>) session.getAttribute( "TMP_GROUP_INDEXES" );
- if ( testValue == null )
+
+ Map<String, TemporaryGroupIndex> temporaryGroupIndexMap =
+ (Map<String, TemporaryGroupIndex>) session.getAttribute(
+ TemporaryGroupIndexSessionCleaner.TEMPORARY_INDEX_SESSION_KEY );
+ if ( temporaryGroupIndexMap == null )
{
- testValue = new HashMap<String, File>();
+ temporaryGroupIndexMap = new HashMap<String, TemporaryGroupIndex>();
}
- File tmp = testValue.get( groupId );
- if ( tmp != null )
+ TemporaryGroupIndex tmp = temporaryGroupIndexMap.get( groupId );
+
+ if ( tmp != null && tmp.getDirectory() != null && tmp.getDirectory().exists() )
{
- return tmp;
+ if ( System.currentTimeMillis() - tmp.getCreationTime() > ( IndexMerger.DEFAULT_GROUP_INDEX_TTL * 60
+ * 1000 ) )
+ {
+ log.debug( "tmp group index is too old so delete it" );
+ indexMerger.cleanTemporaryGroupIndex( tmp );
+ }
+ else
+ {
+ return tmp.getDirectory();
+ }
}
Set<String> authzRepos = new HashSet<String>();
@@ -1232,10 +1249,14 @@ public class ArchivaDavResourceFactory
}
}
}
-
- File mergedRepoDir = indexMerger.buildMergedIndex( authzRepos, true );
- testValue.put( groupId, mergedRepoDir );
- session.setAttribute( "TMP_GROUP_INDEXES", testValue );
+ IndexingContext indexingContext = indexMerger.buildMergedIndex( authzRepos, true );
+ File mergedRepoDir = indexingContext.getIndexDirectoryFile();
+ TemporaryGroupIndex temporaryGroupIndex =
+ new TemporaryGroupIndex( mergedRepoDir, indexingContext.getId() ).setCreationTime(
+ new Date().getTime() );
+ temporaryGroupIndexMap.put( groupId, temporaryGroupIndex );
+ session.setAttribute( TemporaryGroupIndexSessionCleaner.TEMPORARY_INDEX_SESSION_KEY,
+ temporaryGroupIndexMap );
return mergedRepoDir;
}
catch ( RepositoryAdminException e )
Added: archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/util/TemporaryGroupIndexSessionCleaner.java
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/util/TemporaryGroupIndexSessionCleaner.java?rev=1198011&view=auto
==============================================================================
--- archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/util/TemporaryGroupIndexSessionCleaner.java (added)
+++ archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/util/TemporaryGroupIndexSessionCleaner.java Sat Nov 5 18:50:28 2011
@@ -0,0 +1,74 @@
+package org.apache.archiva.webdav.util;
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import org.apache.archiva.indexer.merger.IndexMerger;
+import org.apache.archiva.indexer.merger.TemporaryGroupIndex;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.context.WebApplicationContext;
+import org.springframework.web.context.support.WebApplicationContextUtils;
+
+import javax.servlet.http.HttpSessionEvent;
+import javax.servlet.http.HttpSessionListener;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * this http session listener will delete repository group index requested by a user
+ * at this end of the http session
+ *
+ * @author Olivier Lamy
+ * @since 1.4-M2
+ */
+public class TemporaryGroupIndexSessionCleaner
+ implements HttpSessionListener
+{
+
+ private Logger log = LoggerFactory.getLogger( getClass() );
+
+ private IndexMerger indexMerger;
+
+ public static final String TEMPORARY_INDEX_SESSION_KEY = TemporaryGroupIndexSessionCleaner.class.getName();
+
+ public void sessionCreated( HttpSessionEvent httpSessionEvent )
+ {
+ // ensure the map is here to avoid NPE
+ httpSessionEvent.getSession().setAttribute( TEMPORARY_INDEX_SESSION_KEY,
+ new HashMap<String, TemporaryGroupIndex>() );
+ WebApplicationContext webApplicationContext = WebApplicationContextUtils.getRequiredWebApplicationContext(
+ httpSessionEvent.getSession().getServletContext() );
+ indexMerger = webApplicationContext.getBean( IndexMerger.class );
+ }
+
+ public void sessionDestroyed( HttpSessionEvent httpSessionEvent )
+ {
+ Map<String, TemporaryGroupIndex> tempFilesPerKey =
+ (Map<String, TemporaryGroupIndex>) httpSessionEvent.getSession().getAttribute(
+ TEMPORARY_INDEX_SESSION_KEY );
+
+ for ( TemporaryGroupIndex temporaryGroupIndex : tempFilesPerKey.values() )
+ {
+ log.info( "cleanup temporaryGroupIndex {} directory {}", temporaryGroupIndex.getIndexId(),
+ temporaryGroupIndex.getDirectory().getAbsolutePath() );
+ indexMerger.cleanTemporaryGroupIndex( temporaryGroupIndex );
+ }
+ }
+}
+}
Propchange: archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/util/TemporaryGroupIndexSessionCleaner.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: archiva/trunk/archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/util/TemporaryGroupIndexSessionCleaner.java
------------------------------------------------------------------------------
svn:keywords = Author Date Id Revision