|
From: <li...@us...> - 2008-07-29 16:58:55
|
Revision: 2116
http://cogkit.svn.sourceforge.net/cogkit/?rev=2116&view=rev
Author: liuwt
Date: 2008-07-29 16:58:49 +0000 (Tue, 29 Jul 2008)
Log Message:
-----------
Modified Paths:
--------------
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTClient.java
Modified: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTClient.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTClient.java 2008-07-29 16:54:40 UTC (rev 2115)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTClient.java 2008-07-29 16:58:49 UTC (rev 2116)
@@ -7,7 +7,6 @@
import java.io.FileWriter;
-import java.rmi.RemoteException;
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
@@ -20,12 +19,9 @@
import org.apache.axis.message.addressing.EndpointReferenceType;
import org.globus.gsi.GSIConstants;
import org.globus.ogce.beans.filetransfer.gui.monitor.QueuePanel;
-import org.globus.rft.generated.BaseRequestType;
import org.globus.rft.generated.Cancel;
import org.globus.rft.generated.GetStatusSet;
import org.globus.rft.generated.GetStatusSetResponse;
-import org.globus.rft.generated.OverallStatus;
-import org.globus.rft.generated.RFTDatabaseFaultType;
import org.globus.rft.generated.RFTFaultResourcePropertyType;
import org.globus.rft.generated.RFTOptionsType;
import org.globus.rft.generated.ReliableFileTransferPortType;
@@ -34,8 +30,6 @@
import org.globus.rft.generated.StartOutputType;
import org.globus.rft.generated.TransferRequestType;
import org.globus.rft.generated.TransferStatusType;
-import org.globus.rft.generated.TransferStatusTypeEnumeration;
-import org.globus.rft.generated.TransferType;
import org.globus.transfer.reliable.client.BaseRFTClient;
import org.globus.transfer.reliable.client.utils.UIConstants;
import org.globus.transfer.reliable.service.RFTConstants;
@@ -96,10 +90,7 @@
//set RFT options
RFTOptionsType rftOptions = new RFTOptionsType();
-// rftOptions.setBinary(options.isBinary());
-// rftOptions.setBlockSize(options.getBlockSize());
-// rftOptions.setDcau(options.isDcau());
-// rftOptions.setNotpt(options.isNotpt());
+
rftOptions.setParallelStreams(options.getParallelStream());
rftOptions.setTcpBufferSize(options.getTcpBufferSize());
@@ -114,10 +105,8 @@
TransferRequestType request = new TransferRequestType();
request.setRftOptions(rftOptions);
- request.setTransfer(rftParam.getTransfers1());
- //request.setAllOrNone(options.isAllOrNone());
- request.setConcurrency(options.getConcurrent());
- //request.setMaxAttempts(options.getMaxAttampts());
+ request.setTransfer(rftParam.getTransfers1());
+ request.setConcurrency(options.getConcurrent());
request.setTransferCredentialEndpoint(epr);
return request;
@@ -138,8 +127,6 @@
throw new IllegalArgumentException(UIConstants.ILLEGAL_HOST);
}
String port = rftParam.getServerPort();
-// String authType = rftParam.getAuthType();
-// String authzType = rftParam.getAuthzType();
if (null == port) {
if (authType.equals(GSIConstants.GSI_TRANSPORT)) {
port = "8443";
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|