svn commit: r1140038 - /archiva/trunk/archiva-modules/archiva-scheduler/archiva-scheduler-indexing/src/test/java/org/apache/archiva/scheduler/indexing/ArchivaIndexingTaskExecutorTest.java

[olamy]

Author: olamy
Date: Mon Jun 27 07:53:59 2011
New Revision: 1140038

URL: http://svn.apache.org/viewvc?rev=1140038&view=rev
Log:
take of already existing context to prevent lucene locks

Modified:
    
archiva/trunk/archiva-modules/archiva-scheduler/archiva-scheduler-indexing/src/test/java/org/apache/archiva/scheduler/indexing/ArchivaIndexingTaskExecutorTest.java

Modified: 
archiva/trunk/archiva-modules/archiva-scheduler/archiva-scheduler-indexing/src/test/java/org/apache/archiva/scheduler/indexing/ArchivaIndexingTaskExecutorTest.java
URL: 
http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-scheduler/archiva-scheduler-indexing/src/test/java/org/apache/archiva/scheduler/indexing/ArchivaIndexingTaskExecutorTest.java?rev=1140038&r1=1140037&r2=1140038&view=diff
==============================================================================
--- 
archiva/trunk/archiva-modules/archiva-scheduler/archiva-scheduler-indexing/src/test/java/org/apache/archiva/scheduler/indexing/ArchivaIndexingTaskExecutorTest.java
 (original)
+++ 
archiva/trunk/archiva-modules/archiva-scheduler/archiva-scheduler-indexing/src/test/java/org/apache/archiva/scheduler/indexing/ArchivaIndexingTaskExecutorTest.java
 Mon Jun 27 07:53:59 2011
@@ -80,8 +80,6 @@ public class ArchivaIndexingTaskExecutor
 
     private IndexingContext context;
 
-    private NexusIndexer nexusIndexer;
-
     @Inject
     PlexusSisuBridge plexusSisuBridge;
 
@@ -114,9 +112,7 @@ public class ArchivaIndexingTaskExecutor
         indexingExecutor.setIndexerEngine( indexerEngine );
         indexingExecutor.setIndexPacker( indexPacker );
 
-        nexusIndexer = plexusSisuBridge.lookup( NexusIndexer.class );
-
-        context = ArtifactIndexingTask.createContext( repositoryConfig, 
nexusIndexer );
+        context = ArtifactIndexingTask.createContext( repositoryConfig, 
indexer );
 
 
     }
@@ -125,8 +121,13 @@ public class ArchivaIndexingTaskExecutor
     public void tearDown()
         throws Exception
     {
-        context.close( true );
-        indexer.removeIndexingContext( context, true );
+        //context.close( true );
+        //indexer.removeIndexingContext( context, true );
+
+        for (IndexingContext indexingContext : 
indexer.getIndexingContexts().values())
+        {
+            indexer.removeIndexingContext( indexingContext, true );
+        }
 
         // delete created index in the repository
         File indexDir = new File( repositoryConfig.getLocation(), ".indexer" );
@@ -159,11 +160,15 @@ public class ArchivaIndexingTaskExecutor
             indexer.constructQuery( MAVEN.ARTIFACT_ID, new 
StringSearchExpression( "archiva-index-methods-jar-test" ) ),
             Occur.SHOULD );
 
-        IndexingContext context = indexer.addIndexingContext( 
repositoryConfig.getId(), repositoryConfig.getId(),
+        if (!indexer.getIndexingContexts().containsKey( 
repositoryConfig.getId() ))
+        {
+            IndexingContext context = indexer.addIndexingContext( 
repositoryConfig.getId(), repositoryConfig.getId(),
                                                               new File( 
repositoryConfig.getLocation() ),
                                                               new File( 
repositoryConfig.getLocation(), ".indexer" ),
                                                               null, null, 
ArchivaNexusIndexerUtil.FULL_INDEX );
-        context.setSearchable( true );
+            context.setSearchable( true );
+        }
+
 
         FlatSearchRequest request = new FlatSearchRequest( q );
         FlatSearchResponse response = indexer.searchFlat( request );
@@ -179,7 +184,6 @@ public class ArchivaIndexingTaskExecutor
         assertEquals( "archiva-index-methods-jar-test", 
artifactInfo.artifactId );
         assertEquals( "test-repo", artifactInfo.repository );
 
-        context.close( true );
     }
 
     @Test
@@ -202,7 +206,7 @@ public class ArchivaIndexingTaskExecutor
             indexer.constructQuery( MAVEN.ARTIFACT_ID, new 
StringSearchExpression( "archiva-index-methods-jar-test" ) ),
             Occur.SHOULD );
 
-        IndexSearcher searcher = nexusIndexer.getIndexingContexts().get( 
repositoryConfig.getId() ).getIndexSearcher();
+        IndexSearcher searcher = indexer.getIndexingContexts().get( 
repositoryConfig.getId() ).getIndexSearcher();
         TopDocs topDocs = searcher.search( q, null, 10 );
 
         searcher.close();
@@ -234,7 +238,7 @@ public class ArchivaIndexingTaskExecutor
             indexer.constructQuery( MAVEN.ARTIFACT_ID, new 
StringSearchExpression( "archiva-index-methods-jar-test" ) ),
             Occur.SHOULD );
 
-        IndexSearcher searcher = nexusIndexer.getIndexingContexts().get( 
repositoryConfig.getId() ).getIndexSearcher();
+        IndexSearcher searcher = indexer.getIndexingContexts().get( 
repositoryConfig.getId() ).getIndexSearcher();
 
         TopDocs topDocs = searcher.search( q, null, 10 );
 
@@ -248,7 +252,7 @@ public class ArchivaIndexingTaskExecutor
 
         searcher.close();
 
-        context = ArtifactIndexingTask.createContext( repositoryConfig, 
nexusIndexer );
+        context = ArtifactIndexingTask.createContext( repositoryConfig, 
indexer );
 
         // remove added artifact from index
         task = new ArtifactIndexingTask( repositoryConfig, artifactFile, 
ArtifactIndexingTask.Action.DELETE, context );
@@ -264,7 +268,7 @@ public class ArchivaIndexingTaskExecutor
             indexer.constructQuery( MAVEN.ARTIFACT_ID, new 
StringSearchExpression( "archiva-index-methods-jar-test" ) ),
             Occur.SHOULD );
 
-        searcher = nexusIndexer.getIndexingContexts().get( 
repositoryConfig.getId() ).getIndexSearcher();
+        searcher = indexer.getIndexingContexts().get( repositoryConfig.getId() 
).getIndexSearcher();
 
         topDocs = searcher.search( q, null, 10 );