[Cogkit-svn] SF.net SVN: cogkit:[2214] trunk/current/src/cog/modules/provider-coaster/ src/org/globus/cog/abstraction/impl/file/coaster/commands/GetFileCommand. java

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

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

Log Message:
-----------
fixed get

Modified Paths:
--------------
    trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/GetFileCommand.java

Modified: trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/GetFileCommand.java
===================================================================
--- trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/GetFileCommand.java	2008-10-02 18:42:31 UTC (rev 2213)
+++ trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/GetFileCommand.java	2008-10-02 18:43:12 UTC (rev 2214)
@@ -23,7 +23,8 @@
     private String local;
     private ProgressMonitor pm;
 
-    public GetFileCommand(String remote, String local, ProgressMonitor pm) throws FileNotFoundException {
+    public GetFileCommand(String remote, String local, ProgressMonitor pm)
+            throws FileNotFoundException {
         super(NAME);
         addOutData(remote);
         this.local = local;
@@ -32,15 +33,20 @@
     }
 
     protected void addInData(byte[] data) {
-        if (len == -1) {
-            len = unpackLong(data);
+        if (this.getErrorFlag()) {
+            super.addInData(data);
         }
         else {
-            try {
-                fos.write(data);
+            if (len == -1) {
+                len = unpackLong(data);
             }
-            catch (IOException e) {
-                errorReceived(e.getMessage(), e);
+            else {
+                try {
+                    fos.write(data);
+                }
+                catch (IOException e) {
+                    errorReceived(e.getMessage(), e);
+                }
             }
         }
     }


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