|
From: <ha...@us...> - 2007-10-02 21:27:38
|
Revision: 1772
http://cogkit.svn.sourceforge.net/cogkit/?rev=1772&view=rev
Author: hategan
Date: 2007-10-02 14:27:33 -0700 (Tue, 02 Oct 2007)
Log Message:
-----------
better yet, cleanup failures should only cause warnings
Modified Paths:
--------------
trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java
Modified: trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java
===================================================================
--- trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java 2007-10-02 21:19:53 UTC (rev 1771)
+++ trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java 2007-10-02 21:27:33 UTC (rev 1772)
@@ -54,7 +54,6 @@
private GassServer gassServer = null;
private JobOutputStream stdoutStream;
private JobOutputStream stderrStream;
- private boolean cleaned;
public void submit(Task task) throws IllegalSpecException,
InvalidSecurityContextException, InvalidServiceContactException,
@@ -478,14 +477,16 @@
}
private synchronized void cleanup() {
- if (!cleaned) {
+ try {
this.gramJob.removeListener(this);
CallbackHandlerManager.decreaseUsageCount(gramJob.getCredentials());
if (gassServer != null) {
GassServerFactory.decreaseUsageCount(gassServer);
}
- cleaned = true;
}
+ catch (Exception e) {
+ logger.warn("Failed to clean up job", e);
+ }
}
public void outputChanged(String s) {
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|