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

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

Revision: 2211
          http://cogkit.svn.sourceforge.net/cogkit/?rev=2211&view=rev
Author:   hategan
Date:     2008-10-02 18:40:51 +0000 (Thu, 02 Oct 2008)

Log Message:
-----------
added delete handler

Modified Paths:
--------------
    trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/CoasterRequestManager.java

Added Paths:
-----------
    trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/handlers/DeleteHandler.java

Modified: trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/CoasterRequestManager.java
===================================================================
--- trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/CoasterRequestManager.java	2008-10-02 18:38:40 UTC (rev 2210)
+++ trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/CoasterRequestManager.java	2008-10-02 18:40:51 UTC (rev 2211)
@@ -11,6 +11,7 @@
 
 import org.globus.cog.abstraction.impl.execution.coaster.SubmitJobCommand;
 import org.globus.cog.abstraction.impl.file.coaster.commands.ChmodCommand;
+import org.globus.cog.abstraction.impl.file.coaster.commands.DeleteCommand;
 import org.globus.cog.abstraction.impl.file.coaster.commands.ExistsCommand;
 import org.globus.cog.abstraction.impl.file.coaster.commands.FileInfoCommand;
 import org.globus.cog.abstraction.impl.file.coaster.commands.GetFileCommand;
@@ -21,6 +22,7 @@
 import org.globus.cog.abstraction.impl.file.coaster.commands.RenameCommand;
 import org.globus.cog.abstraction.impl.file.coaster.commands.RmdirCommand;
 import org.globus.cog.abstraction.impl.file.coaster.handlers.ChmodHandler;
+import org.globus.cog.abstraction.impl.file.coaster.handlers.DeleteHandler;
 import org.globus.cog.abstraction.impl.file.coaster.handlers.ExistsHandler;
 import org.globus.cog.abstraction.impl.file.coaster.handlers.FileInfoHandler;
 import org.globus.cog.abstraction.impl.file.coaster.handlers.GetFileHandler;
@@ -44,6 +46,7 @@
         addHandler(ServiceShutdownHandler.NAME, ServiceShutdownHandler.class);
         
         addHandler(ExistsCommand.NAME, ExistsHandler.class);
+        addHandler(DeleteCommand.NAME, DeleteHandler.class);
         addHandler(MkdirCommand.NAME, MkdirHandler.class);
         addHandler(ListCommand.NAME, ListHandler.class);
         addHandler(RmdirCommand.NAME, RmdirHandler.class);

Added: trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/handlers/DeleteHandler.java
===================================================================
--- trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/handlers/DeleteHandler.java	                        (rev 0)
+++ trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/handlers/DeleteHandler.java	2008-10-02 18:40:51 UTC (rev 2211)
@@ -0,0 +1,34 @@
+//----------------------------------------------------------------------
+//This code is developed as part of the Java CoG Kit project
+//The terms of the license can be found at http://www.cogkit.org/license
+//This message may not be removed or altered.
+//----------------------------------------------------------------------
+
+/*
+ * Created on Sep 26, 2008
+ */
+package org.globus.cog.abstraction.impl.file.coaster.handlers;
+
+import java.io.File;
+
+import org.apache.log4j.Logger;
+import org.globus.cog.karajan.workflow.service.ProtocolException;
+
+public class DeleteHandler extends CoasterFileRequestHandler {
+	public static final Logger logger = Logger.getLogger(DeleteHandler.class);
+
+    public void requestComplete() throws ProtocolException {
+    	File f = normalize(getInDataAsString(0));
+    	if (!f.delete()) {
+    	    if (f.exists()) {
+    	        sendError("Failed to delete " + f.getAbsolutePath());
+    	    }
+    	    else {
+    	        sendReply("OK");
+    	    }
+    	}
+    	else {
+    	    sendReply("OK");
+    	}
+    }
+}


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