From: <ha...@us...> - 2008-10-02 18:44:06
|
Revision: 2215 http://cogkit.svn.sourceforge.net/cogkit/?rev=2215&view=rev Author: hategan Date: 2008-10-02 18:43:35 +0000 (Thu, 02 Oct 2008) Log Message: ----------- fixed list Modified Paths: -------------- trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/ListCommand.java Modified: trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/ListCommand.java =================================================================== --- trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/ListCommand.java 2008-10-02 18:43:12 UTC (rev 2214) +++ trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/file/coaster/commands/ListCommand.java 2008-10-02 18:43:35 UTC (rev 2215) @@ -10,14 +10,16 @@ package org.globus.cog.abstraction.impl.file.coaster.commands; import java.io.File; -import java.io.IOException; import java.util.ArrayList; import java.util.Collection; +import java.util.Iterator; import java.util.List; import org.globus.cog.abstraction.impl.file.GridFileImpl; import org.globus.cog.abstraction.impl.file.PermissionsImpl; import org.globus.cog.abstraction.interfaces.GridFile; +import org.globus.cog.karajan.workflow.service.ProtocolException; +import org.globus.cog.karajan.workflow.service.channels.AbstractKarajanChannel; import org.globus.cog.karajan.workflow.service.commands.Command; public class ListCommand extends Command { @@ -27,22 +29,21 @@ super(NAME); addOutData(name); } - - public Collection getResult() { + + public Collection getResult() throws ProtocolException { List l = new ArrayList(); int i = 0; int sz = getInDataSize(); if (sz % 7 != 0) { - errorReceived("Reply size mismatch", new IOException( - "Reply size mismatch")); + throw new ProtocolException("Reply size mismatch"); } while (i < sz) { GridFile f = new GridFileImpl(); f.setAbsolutePathName(getInDataAsString(i++)); + f.setName(new File(f.getAbsolutePathName()).getName()); + f.setLastModified(getInDataAsString(i++)); f.setFileType((byte) getInDataAsInt(i++)); - f.setLastModified(getInDataAsString(i++)); - f.setName(new File(f.getAbsolutePathName()).getName()); f.setSize(getInDataAsLong(i++)); f.setUserPermissions(new PermissionsImpl(getInDataAsInt(i++))); f.setGroupPermissions(new PermissionsImpl(getInDataAsInt(i++))); This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |