From: <bsc...@us...> - 2007-03-30 11:23:24
|
Revision: 558 http://svn.sourceforge.net/unicore/?rev=558&view=rev Author: bschuller Date: 2007-03-30 04:23:20 -0700 (Fri, 30 Mar 2007) Log Message: ----------- consistently use XNJSFacade; fix bug with stage-ins using copy / HTTP Modified Paths: -------------- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/job/JobManagementImpl.java unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/sms/HomeStorageImpl.java unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemFactoryImpl.java unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemImpl.java unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTExport.java unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTImport.java unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/Unicore6FileTransferProcessor.java unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/XNJSFacade.java unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/ServiceDiscoveryTest.java unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/TestSuite.java unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/impl/TestBPSupport.java unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/xnjs/TestStaging.java Added Paths: ----------- unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/RunCatWithStageInByCopy.java Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/job/JobManagementImpl.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/job/JobManagementImpl.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/job/JobManagementImpl.java 2007-03-30 11:23:20 UTC (rev 558) @@ -78,13 +78,13 @@ import de.fzj.unicore.uas.impl.sms.StorageManagementHomeImpl.StorageTypes; import de.fzj.unicore.uas.impl.tss.rp.StorageReferenceResourceProperty; import de.fzj.unicore.uas.util.AddressingUtil; +import de.fzj.unicore.uas.xnjs.XNJSFacade; import de.fzj.unicore.wsrflite.Kernel; import de.fzj.unicore.wsrflite.messaging.Message; import de.fzj.unicore.wsrflite.messaging.MessagingImpl; import de.fzj.unicore.wsrflite.utils.Utilities; import de.fzj.unicore.wsrflite.xmlbeans.BaseFault; import de.fzj.unicore.wsrflite.xmlbeans.rp.ImmutableResourceProperty; -import de.fzj.unicore.xnjs.Configuration; import de.fzj.unicore.xnjs.aaa.Client; import de.fzj.unicore.xnjs.ems.Action; @@ -124,7 +124,7 @@ public StartResponseDocument Start(StartDocument in) throws BaseFault { StartResponseDocument res=StartResponseDocument.Factory.newInstance(); try{ - Configuration.getInstance().getEMSManager().run(getUniqueID(), client); + XNJSFacade.getManager().run(getUniqueID(), client); res.addNewStartResponse(); logger.info("Started "+getUniqueID()); return res; @@ -137,7 +137,7 @@ public AbortResponseDocument Abort(AbortDocument in) throws BaseFault { AbortResponseDocument res=AbortResponseDocument.Factory.newInstance(); try{ - Configuration.getInstance().getEMSManager().abort(getUniqueID(), client); + XNJSFacade.getManager().abort(getUniqueID(), client); res.addNewAbortResponse(); return res; }catch(Exception e){ @@ -149,7 +149,7 @@ public HoldResponseDocument Hold(HoldDocument in) throws BaseFault { HoldResponseDocument res=HoldResponseDocument.Factory.newInstance(); try{ - Configuration.getInstance().getEMSManager().pause(getUniqueID(), client); + XNJSFacade.getManager().pause(getUniqueID(), client); res.addNewHoldResponse(); return res; }catch(Exception e){ @@ -161,7 +161,7 @@ public ResumeResponseDocument Resume(ResumeDocument in) throws BaseFault { ResumeResponseDocument res=ResumeResponseDocument.Factory.newInstance(); try{ - Configuration.getInstance().getEMSManager().resume(getUniqueID(), client); + XNJSFacade.getManager().resume(getUniqueID(), client); res.addNewResumeResponse(); return res; }catch(Exception e){ @@ -188,7 +188,7 @@ logger.log(Level.INFO,"Adding action with id "+action.getUUID()+ " for client "+client); } //submit to XNJS... - Configuration.getInstance().getEMSManager().add(action,client).toString(); + XNJSFacade.getManager().add(action,client).toString(); }catch(Exception e){ logger.log(Level.SEVERE,"Could not submit job to XNJS.",e); try{ @@ -331,7 +331,7 @@ //TODO: do we want arbitrarily large logs? String log="Log not available."; - Action a=Configuration.getInstance().getInternalManager().getAction(getUniqueID()); + Action a=XNJSFacade.getAction(getUniqueID()); try{ CharArrayWriter c=new CharArrayWriter(); a.printLogTrace(new PrintWriter(c)); Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/sms/HomeStorageImpl.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/sms/HomeStorageImpl.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/sms/HomeStorageImpl.java 2007-03-30 11:23:20 UTC (rev 558) @@ -2,7 +2,7 @@ import java.util.logging.Level; -import de.fzj.unicore.xnjs.Configuration; +import de.fzj.unicore.uas.xnjs.XNJSFacade; import de.fzj.unicore.xnjs.aaa.Client; /** @@ -26,7 +26,7 @@ if(home==null){ try{ String xlogin=getClient().getAttributes().get(Client.ATTRIBUTE_XLOGIN); - home=Configuration.getInstance().getGrounder(). + home=XNJSFacade.getGrounder(). incarnatePath("","HOME",null,getClient()); if(logger.isLoggable(Level.FINER)){ logger.log(Level.FINER,"Setting home directory for "+ Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemFactoryImpl.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemFactoryImpl.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemFactoryImpl.java 2007-03-30 11:23:20 UTC (rev 558) @@ -62,7 +62,6 @@ import de.fzj.unicore.wsrflite.Kernel; import de.fzj.unicore.wsrflite.utils.Utilities; import de.fzj.unicore.wsrflite.xmlbeans.BaseFault; -import de.fzj.unicore.xnjs.Configuration; import de.fzj.unicore.xnjs.jsdl.AbstractGrounder; /** @@ -157,7 +156,7 @@ protected ApplicationsResourceProperty createApplicationResourceProperty(){ try{ ApplicationsResourceProperty arp=new ApplicationsResourceProperty(); - AbstractGrounder gr=(AbstractGrounder)Configuration.getInstance().getGrounder(); + AbstractGrounder gr=(AbstractGrounder)XNJSFacade.getGrounder(); ApplicationType[] xnjsapps=gr.getDefinedApplicationTypes(); ApplicationResourceType[] apps=new ApplicationResourceType[xnjsapps.length]; Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemImpl.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemImpl.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/impl/tss/TargetSystemImpl.java 2007-03-30 11:23:20 UTC (rev 558) @@ -78,10 +78,10 @@ import de.fzj.unicore.uas.impl.tss.rp.ProcessorResourceProperty; import de.fzj.unicore.uas.impl.tss.rp.StorageReferenceResourceProperty; import de.fzj.unicore.uas.util.AddressingUtil; +import de.fzj.unicore.uas.xnjs.XNJSFacade; import de.fzj.unicore.wsrflite.Kernel; import de.fzj.unicore.wsrflite.utils.Utilities; import de.fzj.unicore.wsrflite.xmlbeans.BaseFault; -import de.fzj.unicore.xnjs.Configuration; import de.fzj.unicore.xnjs.aaa.Client; import de.fzj.unicore.xnjs.ems.Action; @@ -182,7 +182,7 @@ } Client client = getClient(); - Action action = Configuration.getInstance().makeAction(doc); + Action action = XNJSFacade.makeAction(doc); map.put(JobManagementImpl.INITPARAM_CLIENT,client); map.put(JobManagementImpl.INITPARAM_ACTION,action); map.put(JobManagementImpl.INITPARAM_TSS_UNIQUEID, getUniqueID()); Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTExport.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTExport.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTExport.java 2007-03-30 11:23:20 UTC (rev 558) @@ -50,7 +50,6 @@ import de.fzj.unicore.uas.client.BaseUASClient; import de.fzj.unicore.uas.fts.FileTransfer; import de.fzj.unicore.uas.security.IUASSecurityProperties; -import de.fzj.unicore.xnjs.Configuration; import de.fzj.unicore.xnjs.aaa.Client; import de.fzj.unicore.xnjs.ems.Action; import de.fzj.unicore.xnjs.ems.ExecutionException; @@ -116,8 +115,8 @@ //returns a byte array (at most "chunksize" bytes long) protected byte[] readFromFile(long offset,int chunkSize)throws IOException,ExecutionException{ - TSI tsi=Configuration.getInstance().getTargetSystemInterface(client); - Action a=Configuration.getInstance().getInternalManager().getAction(actionId); + TSI tsi=XNJSFacade.getTSI(client); + Action a=XNJSFacade.getAction(actionId); String path=a.getExecutionContext().getWorkingDirectory(); String sourcePath=path+sourceFile; logger.finer("Reading from "+sourcePath); @@ -136,8 +135,8 @@ } protected TSI doGetTSI()throws ExecutionException{ - TSI tsi= Configuration.getInstance().getTargetSystemInterface(client); - Action a=Configuration.getInstance().getInternalManager().getAction(actionId); + TSI tsi= XNJSFacade.getTSI(client); + Action a=XNJSFacade.getAction(actionId); String path=a.getExecutionContext().getWorkingDirectory(); tsi.begin(); tsi.cd(path); Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTImport.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTImport.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/BFTImport.java 2007-03-30 11:23:20 UTC (rev 558) @@ -48,7 +48,6 @@ import de.fzj.unicore.uas.client.BaseUASClient; import de.fzj.unicore.uas.fts.BaselineFileTransferImpl; import de.fzj.unicore.uas.security.IUASSecurityProperties; -import de.fzj.unicore.xnjs.Configuration; import de.fzj.unicore.xnjs.aaa.Client; import de.fzj.unicore.xnjs.ems.Action; import de.fzj.unicore.xnjs.ems.ExecutionException; @@ -112,8 +111,8 @@ * @throws ExecutionException */ protected void writeToFile(byte[] data, boolean append)throws IOException,ExecutionException{ - TSI tsi=Configuration.getInstance().getTargetSystemInterface(client); - Action a=Configuration.getInstance().getInternalManager().getAction(actionId); + TSI tsi=XNJSFacade.getTSI(client); + Action a=XNJSFacade.getAction(actionId); String path=a.getExecutionContext().getWorkingDirectory(); OutputStream os=tsi.getOutputStream(path+targetFile,append); os.write(data); Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/Unicore6FileTransferProcessor.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/Unicore6FileTransferProcessor.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/Unicore6FileTransferProcessor.java 2007-03-30 11:23:20 UTC (rev 558) @@ -40,7 +40,6 @@ import org.ggf.schemas.jsdl.x2005.x11.jsdl.DataStagingType; -import de.fzj.unicore.xnjs.Configuration; import de.fzj.unicore.xnjs.XNJSConstants; import de.fzj.unicore.xnjs.ems.ActionResult; import de.fzj.unicore.xnjs.ems.ActionStatus; @@ -84,9 +83,9 @@ */ public Unicore6FileTransferProcessor(){ super(); - exec=Configuration.getInstance().getExecutionInterface(); - ecm=Configuration.getInstance().getExecutionContextMgr(); - grounder=Configuration.getInstance().getGrounder(); + exec=XNJSFacade.getConfiguration().getExecutionInterface(); + ecm=XNJSFacade.getConfiguration().getExecutionContextMgr(); + grounder=XNJSFacade.getGrounder(); } /* (non-Javadoc) @@ -114,12 +113,11 @@ } else{ for(DataStagingType dst:dstl){ - logger.finer("Staging element: "+dst); try{ URI source=extractSource(dst); URI target=extractTarget(dst); - logger.info(source+"->"+target); - IFileTransfer ft=Configuration.getInstance().getFileTransferEngine(). + logger.info("transferring: "+source+"->"+target); + IFileTransfer ft=XNJSFacade.getConfiguration().getFileTransferEngine(). createFileTransfer(action,source,target); ft.start(); action.addLogTrace("Added filetransfer "+source+" -> "+target); @@ -159,27 +157,32 @@ * get the target of the transfer. * If staging in, the target is the fileName attribute */ - private URI extractTarget(DataStagingType dst) throws Exception { if(XNJSConstants.jsdlStageOutActionType.equals(action.getType())){ return new URI(dst.getTarget().getURI()); } else{ String s=dst.getFileName(); - if(s.startsWith("file://"))return new URI(s); + System.out.println("source="+s); + if(s.startsWith("file://")){ + return new URI(prependWorkDir(s)); + } else { - if(s.startsWith("/"))return new URI("file://"+s); - else return new URI("file:///"+s); + return new URI("file://"+prependWorkDir(s)); } } } + private String prependWorkDir(String s){ + return action.getExecutionContext().getWorkingDirectory()+s; + } + protected void handleRunning() throws ProcessingException { ArrayList<String> ftList=(ArrayList<String>)action.getProcessingContext().get(fileTransferKey); if(ftList==null)throw new ProcessingException("Filetransfer list not found in context"); boolean running=false; for(String ftId: ftList){ - IFileTransfer ft=Configuration.getInstance().getFileTransferEngine().getFileTransfer(ftId); + IFileTransfer ft=XNJSFacade.getConfiguration().getFileTransferEngine().getFileTransfer(ftId); if(ft.getStatus()==IFileTransfer.Status.DONE){ logger.fine("File transfer "+ft.getUniqueId()+" done."); } Modified: unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/XNJSFacade.java =================================================================== --- unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/XNJSFacade.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/main/java/de/fzj/unicore/uas/xnjs/XNJSFacade.java 2007-03-30 11:23:20 UTC (rev 558) @@ -44,8 +44,10 @@ import de.fzj.unicore.xnjs.XNJS; import de.fzj.unicore.xnjs.aaa.Client; import de.fzj.unicore.xnjs.ems.Action; +import de.fzj.unicore.xnjs.ems.Manager; import de.fzj.unicore.xnjs.io.IFileTransferEngine; import de.fzj.unicore.xnjs.jsdl.AbstractGrounder; +import de.fzj.unicore.xnjs.jsdl.IGrounder; import de.fzj.unicore.xnjs.tsi.TSI; /** @@ -162,6 +164,23 @@ } } + public static Manager getManager(){ + if(didInitXNJS==false)doInit(); + try{ + return Configuration.getInstance().getEMSManager(); + }catch(Exception e){ + return null; + } + } + public static IGrounder getGrounder(){ + if(didInitXNJS==false)doInit(); + try{ + return Configuration.getInstance().getGrounder(); + }catch(Exception e){ + return null; + } + } + /** * helper method returning the XNJS config object */ @@ -211,4 +230,9 @@ return Configuration.getInstance().getStorageTSI(storageRoot,client); } + public static TSI getTSI(Client client){ + if(didInitXNJS==false)doInit(); + return Configuration.getInstance().getTargetSystemInterface(client); + } + } Added: unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/RunCatWithStageInByCopy.java =================================================================== --- unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/RunCatWithStageInByCopy.java (rev 0) +++ unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/RunCatWithStageInByCopy.java 2007-03-30 11:23:20 UTC (rev 558) @@ -0,0 +1,68 @@ +package de.fzj.unicore.uas; + +import java.io.File; +import java.io.FileWriter; + +import org.ggf.schemas.jsdl.x2005.x11.jsdl.ApplicationType; +import org.ggf.schemas.jsdl.x2005.x11.jsdl.DataStagingDocument; +import org.ggf.schemas.jsdl.x2005.x11.jsdl.DataStagingType; +import org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument; +import org.ggf.schemas.jsdl.x2005.x11.jsdl.SourceTargetType; +import org.w3.x2005.x08.addressing.EndpointReferenceType; + +import de.fzj.unicore.uas.client.JobClient; +import de.fzj.unicore.xnjs.jsdl.JSDLUtils; + +public class RunCatWithStageInByCopy extends AbstractJobRun { + + String url; + EndpointReferenceType tssepr; + + String testString="this is in import test"; + + private File localFile; + + public RunCatWithStageInByCopy(){ + try{ + localFile=File.createTempFile("uas","uastest"); + localFile.deleteOnExit(); + } + catch(Exception e){ + e.printStackTrace(); + } + } + + @Override + public String getDescription() { + return "Run 'cat' application on default Targetsystem."; + } + + @Override + protected void beforeStart(JobClient jms) throws Exception { + FileWriter fw=new FileWriter(localFile); + fw.write(testString); + fw.close(); + } + + @Override + protected void onFinish(JobClient jms) throws Exception { + String err=getStderr(jms); + if(err.length()>0)throw new Exception("Error occured: "+err); + } + + @Override + protected JobDefinitionDocument getJob() { + JobDefinitionDocument jdd=JobDefinitionDocument.Factory.newInstance(); + ApplicationType app=jdd.addNewJobDefinition().addNewJobDescription().addNewApplication(); + app.setApplicationName("Cat"); + app.setApplicationVersion("1.0"); + DataStagingType s=jdd.getJobDefinition().getJobDescription().addNewDataStaging(); + s.setFileName("/infile"); + SourceTargetType stt=SourceTargetType.Factory.newInstance(); + stt.setURI("file://"+localFile.getAbsolutePath()); + s.setSource(stt); + assertTrue(JSDLUtils.hasStageIn(jdd)); + return jdd; + } + +} Modified: unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/ServiceDiscoveryTest.java =================================================================== --- unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/ServiceDiscoveryTest.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/ServiceDiscoveryTest.java 2007-03-30 11:23:20 UTC (rev 558) @@ -38,9 +38,13 @@ } } + eprs=reg.listServices(TargetSystemFactory.TSF_PORT); + assertTrue(eprs.size()==1); eprs=reg.listServices(TargetSystem.TSS_PORT); + assertTrue(eprs.size()==1); for(EndpointReferenceType epr: eprs){ try{ + System.out.println(epr); new BaseUASClient(epr).getResourceProperty(TargetSystem.RPName); } catch(Exception e){ Modified: unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/TestSuite.java =================================================================== --- unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/TestSuite.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/TestSuite.java 2007-03-30 11:23:20 UTC (rev 558) @@ -34,7 +34,7 @@ sw.start("Init UAS."); uas.start(); //LogManager.getLogManager().reset(); - Logger.getLogger("de").setLevel(Level.SEVERE); +// Logger.getLogger("de").setLevel(Level.SEVERE); Logger.getLogger("org").setLevel(Level.SEVERE); Logger.getLogger("com").setLevel(Level.SEVERE); } @@ -42,8 +42,9 @@ protected void addTests(){ // tests.add(new RunDate()); // tests.add(new RunCat()); + tests.add(new RunCatWithStageInByCopy()); // tests.add(new ServiceDiscoveryTest()); - tests.add(new RunSMSTest()); +// tests.add(new RunSMSTest()); } public void testAll()throws Exception{ Modified: unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/impl/TestBPSupport.java =================================================================== --- unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/impl/TestBPSupport.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/impl/TestBPSupport.java 2007-03-30 11:23:20 UTC (rev 558) @@ -7,7 +7,7 @@ public class TestBPSupport extends TestCase{ public void test1(){ - UASWSResourceImpl i=new UASWSResourceImpl(); + UASWSResourceImpl i=new UASWSResourceImpl(){}; assertTrue(i.getWSResourceInterfaces().toString().contains("QueryResourceProperties")); JobManagementImpl j=new JobManagementImpl(); assertTrue(j.getWSResourceInterfaces().toString().contains("QueryResourceProperties")); Modified: unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/xnjs/TestStaging.java =================================================================== --- unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/xnjs/TestStaging.java 2007-03-29 14:46:35 UTC (rev 557) +++ unicorex/uas-core/trunk/src/test/java/de/fzj/unicore/uas/xnjs/TestStaging.java 2007-03-30 11:23:20 UTC (rev 558) @@ -8,6 +8,9 @@ import junit.framework.TestCase; import de.fzj.unicore.xnjs.ems.Action; +import de.fzj.unicore.xnjs.io.IFileTransfer; +import de.fzj.unicore.xnjs.io.http.HttpTransferCreator; +import de.fzj.unicore.xnjs.io.simple.CopyTransferCreator; public class TestStaging extends TestCase{ @@ -38,6 +41,25 @@ assertEquals(u6ft.getTarget(),"http://somehost:1234?res=mystorage#foo.txt"); } + public void test3()throws Exception { + CopyTransferCreator ft=new CopyTransferCreator(); + IFileTransfer u6ft=ft.createFileTransfer( + new Action(), + new URI("file:///somefile.txt"), + new URI("file:///infile") + ); + assertNotNull(u6ft); + } + public void Xtest4()throws Exception { + HttpTransferCreator ft=new HttpTransferCreator(); + IFileTransfer u6ft=ft.createFileTransfer( + new Action(), + new URI("http://somehost/somefile.txt"), + new URI("file:///infile") + ); + assertNotNull(u6ft); + } + } This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |