[Cogkit-svn] SF.net SVN: cogkit: [1888] trunk/current/src/cog/modules/provider-gt2/src/ org/globus/cog/abstraction/impl

[<ha...@us...>]

Revision: 1888
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1888&view=rev
Author:   hategan
Date:     2008-02-12 09:21:34 -0800 (Tue, 12 Feb 2008)

Log Message:
-----------
updated gt2 provider

Modified Paths:
--------------
    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/file/gridftp/FileResourceImpl.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	2008-02-12 17:20:25 UTC (rev 1887)
+++ trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java	2008-02-12 17:21:34 UTC (rev 1888)
@@ -67,7 +67,11 @@
             throw new TaskSubmissionException(
                     "JobSubmissionTaskHandler cannot handle two active jobs simultaneously");
         }
+        if (this.task.getStatus().getStatusCode() != Status.UNSUBMITTED) {
+            throw new TaskSubmissionException("This task is already submitted");
+        }
         this.task = task;
+        this.task.setStatus(Status.SUBMITTING);
         this.securityContext = getSecurityContext(task);
         this.credential = (GSSCredential) securityContext.getCredentials();
         String rsl;
@@ -137,17 +141,16 @@
         try {
             // check if the task has not been canceled after it was
             // submitted for execution
-            if (this.task.getStatus().getStatusCode() == Status.UNSUBMITTED) {
-                this.gramJob.request(server, spec.isBatchJob(), limitedDeleg);
-                if (logger.isDebugEnabled()) {
-                    logger.debug("Submitted job with Globus ID: "
-                            + this.gramJob.getIDAsString());
-                }
-                this.task.setStatus(Status.SUBMITTED);
-                if (spec.isBatchJob()) {
-                    this.task.setStatus(Status.COMPLETED);
-                }
+
+            this.gramJob.request(server, spec.isBatchJob(), limitedDeleg);
+            if (logger.isDebugEnabled()) {
+                logger.debug("Submitted job with Globus ID: "
+                        + this.gramJob.getIDAsString());
             }
+            this.task.setStatus(Status.SUBMITTED);
+            if (spec.isBatchJob()) {
+                this.task.setStatus(Status.COMPLETED);
+            }
         }
         catch (GramException ge) {
             cleanup();
@@ -159,10 +162,11 @@
                     gsse);
         }
     }
-    
+
     private boolean isLimitedDelegation(SecurityContext sc) {
         if (sc instanceof GlobusSecurityContextImpl) {
-            return ((GlobusSecurityContextImpl) securityContext).getDelegation() != Delegation.FULL_DELEGATION; 
+            return ((GlobusSecurityContextImpl) securityContext)
+                    .getDelegation() != Delegation.FULL_DELEGATION;
         }
         else {
             return true;
@@ -432,8 +436,7 @@
         String gassURL = null;
 
         try {
-            this.gassServer = GassServerFactory
-                    .getGassServer(this.credential);
+            this.gassServer = GassServerFactory.getGassServer(this.credential);
             this.gassServer.registerDefaultDeactivator();
         }
         catch (Exception e) {
@@ -513,14 +516,16 @@
     public void outputClosed() {
     }
 
-    private SecurityContext getSecurityContext(Task task) throws InvalidSecurityContextException {
+    private SecurityContext getSecurityContext(Task task)
+            throws InvalidSecurityContextException {
         SecurityContext sc = task.getService(0).getSecurityContext();
         if (sc == null) {
             // create default credentials
             sc = new GlobusSecurityContextImpl();
             GSSManager manager = ExtendedGSSManager.getInstance();
             try {
-                sc.setCredentials(manager.createCredential(GSSCredential.INITIATE_AND_ACCEPT));
+                sc.setCredentials(manager
+                        .createCredential(GSSCredential.INITIATE_AND_ACCEPT));
             }
             catch (GSSException e) {
                 throw new InvalidSecurityContextException(e);

Modified: trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/file/gridftp/FileResourceImpl.java
===================================================================
--- trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/file/gridftp/FileResourceImpl.java	2008-02-12 17:20:25 UTC (rev 1887)
+++ trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/file/gridftp/FileResourceImpl.java	2008-02-12 17:21:34 UTC (rev 1888)
@@ -24,7 +24,6 @@
 import org.globus.cog.abstraction.interfaces.GridFile;
 import org.globus.cog.abstraction.interfaces.SecurityContext;
 import org.globus.cog.abstraction.interfaces.ServiceContact;
-import org.globus.ftp.GridFTPSession;
 import org.globus.ftp.MlsxEntry;
 import org.globus.ftp.exception.ClientException;
 import org.globus.ftp.exception.ServerException;


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.