You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@maven.apache.org by og...@apache.org on 2008/11/12 20:16:17 UTC

svn commit: r713458 - in /maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src: main/java/org/apache/maven/mercury/repository/local/flat/ test/java/org/apache/maven/mercury/repository/local/flat/

Author: ogusakov
Date: Wed Nov 12 11:16:09 2008
New Revision: 713458

URL: http://svn.apache.org/viewvc?rev=713458&view=rev
Log:
modified the concurrent pattern

Modified:
    maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/main/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryWriterFlat.java
    maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/test/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryFlatTest.java

Modified: maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/main/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryWriterFlat.java
URL: http://svn.apache.org/viewvc/maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/main/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryWriterFlat.java?rev=713458&r1=713457&r2=713458&view=diff
==============================================================================
--- maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/main/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryWriterFlat.java (original)
+++ maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/main/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryWriterFlat.java Wed Nov 12 11:16:09 2008
@@ -108,10 +108,7 @@
     LocalRepositoryWriterFlat [] workers = new LocalRepositoryWriterFlat[ nWorkers ];
     
     for( int i=0; i<nWorkers; i++ )
-    {
       workers[ i ] = new LocalRepositoryWriterFlat( _repo, _repoDir, aq );
-      workers[ i ].start();
-    }
     
     for( Artifact artifact : artifacts )
     {
@@ -126,6 +123,9 @@
       aq.addArtifact( new ArifactWriteData( artifact, vFacs ) );
     }
     aq.addArtifact( LAST_ARTIFACT );
+
+    for( int i=0; i<nWorkers; i++ )
+      workers[ i ].start();
     
     boolean alive = true;
     while( alive )

Modified: maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/test/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryFlatTest.java
URL: http://svn.apache.org/viewvc/maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/test/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryFlatTest.java?rev=713458&r1=713457&r2=713458&view=diff
==============================================================================
--- maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/test/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryFlatTest.java (original)
+++ maven/mercury/trunk/mercury-repo/mercury-repo-local-flat/src/test/java/org/apache/maven/mercury/repository/local/flat/LocalRepositoryFlatTest.java Wed Nov 12 11:16:09 2008
@@ -94,7 +94,7 @@
   public void testWriteFlatWithPom()
   throws Exception
   {
-    String test = "testWriteFlatWithGroup()";
+    String test = "testWriteFlatWithPom()";
     
     _repo.setCreatePoms( true );
     
@@ -154,7 +154,7 @@
   public void testWriteFlatWithGroupAndPom()
   throws Exception
   {
-    String test = "testWriteFlatWithGroup()";
+    String test = "testWriteFlatWithGroupAndPom()";
     
     _repo.setCreateGroupFolders( true );
     _repo.setCreatePoms( true );