continuum-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From c...@apache.org
Subject svn commit: r725894 - /continuum/branches/continuum-distributed-builds/continuum-builder/src/main/java/org/apache/continuum/builder/distributed/manager/DefaultDistributedBuildManager.java
Date Fri, 12 Dec 2008 02:54:49 GMT
Author: ctan
Date: Thu Dec 11 18:54:49 2008
New Revision: 725894

URL: http://svn.apache.org/viewvc?rev=725894&view=rev
Log:
fixed remove task queue executor for build agent

Modified:
    continuum/branches/continuum-distributed-builds/continuum-builder/src/main/java/org/apache/continuum/builder/distributed/manager/DefaultDistributedBuildManager.java

Modified: continuum/branches/continuum-distributed-builds/continuum-builder/src/main/java/org/apache/continuum/builder/distributed/manager/DefaultDistributedBuildManager.java
URL: http://svn.apache.org/viewvc/continuum/branches/continuum-distributed-builds/continuum-builder/src/main/java/org/apache/continuum/builder/distributed/manager/DefaultDistributedBuildManager.java?rev=725894&r1=725893&r2=725894&view=diff
==============================================================================
--- continuum/branches/continuum-distributed-builds/continuum-builder/src/main/java/org/apache/continuum/builder/distributed/manager/DefaultDistributedBuildManager.java
(original)
+++ continuum/branches/continuum-distributed-builds/continuum-builder/src/main/java/org/apache/continuum/builder/distributed/manager/DefaultDistributedBuildManager.java
Thu Dec 11 18:54:49 2008
@@ -38,7 +38,6 @@
 import org.codehaus.plexus.personality.plexus.lifecycle.phase.Contextualizable;
 import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
 import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable;
 import org.codehaus.plexus.personality.plexus.lifecycle.phase.StoppingException;
 import org.codehaus.plexus.util.StringUtils;
 import org.slf4j.Logger;
@@ -184,16 +183,14 @@
 
         try
         {
-            if ( taskQueueExecutors.remove( buildAgentUrl ) != null )
-            {
-                Startable startable = (Startable) executor;
-                executor.stop();
-            }
+            executor.stop();
         }
         catch ( StoppingException e )
         {
             throw new ContinuumException( "Error while stopping task queue executor", e );
         }
+
+        taskQueueExecutors.remove( buildAgentUrl );
     }
 
     public boolean isBuildAgentBusy( String buildAgentUrl )



Mime
View raw message