Linux

Mac OS X

Contact the Delegation Factory Service and get an EPR for the Delegation Resource that contains your delegated credential.

 public static EndpointReferenceType
        delegateCredential(String host, String port) throws Exception {
        ClientSecurityDescriptor desc = new ClientSecurityDescriptor();
        // Credential to sign with, assuming default credential
        GlobusCredential credential = GlobusCredential.getDefaultCredential();
        desc.setGSITransport(Constants.GSI_TRANSPORT)
        Util.registerTransport();
        desc.setAuthz('host');

        String factoryUrl = PROTOCOL + "://" + host + ":"
                        + port + SERVICE_URL_ROOT
                        + DelegationConstants.FACTORY_PATH;

        // lifetime in seconds
        int lifetime = TERM_TIME * 60;

        // Get the public key to delegate on.
        EndpointReferenceType delegEpr = AddressingUtils
                .createEndpointReference(factoryUrl, null);
        X509Certificate[] certsToDelegateOn = DelegationUtil
                .getCertificateChainRP(delegEpr, desc);
        X509Certificate certToSign = certsToDelegateOn[0];
        return DelegationUtil.delegate(factoryUrl,
                    credential, certToSign, lifetime, false,
                    desc);
    }
    

Now construct a TransferRequestType Object:

    TransferType[] transferArray = new TransferType[1];
    transferArray[0] = new TransferType();
    transferArray[0].setSourceUrl("gsiftp://foo/bar");
    transferArray[0].setDestinationUrl("gsiftp://blah/");
    RFTOptionsType rftOptions = new RFTOptionsType();
    rftOptions.setBinary(true);
    // You can set more options like parallel streams, buffer sizes etc
    // Refer to Public Interface guide of RFT for more details
    TransferRequestType request = new TransferRequestType();
    request.setRftOptions(rftOptions);
    request.setTransfer(transferArray);
    request.setTransferCredentialEndpoint(delegateCredential(host,port));
    

Now contact the RFT factory and create an RFT resource:

      public static EndpointReferenceType createRFT(String rftFactoryAddress,
            BaseRequestType request) 
    throws Exception {
        endpoint = new URL(rftFactoryAddress);
        factoryPort = rftFactoryLocator
                .getReliableFileTransferFactoryPortTypePort(endpoint);
        CreateReliableFileTransferInputType input =
            new CreateReliableFileTransferInputType();
        //input.setTransferJob(transferType);
        if(request instanceof TransferRequestType) {
            input.setTransferRequest((TransferRequestType)request);
        } else {
            input.setDeleteRequest((DeleteRequestType)request);
        }
        Calendar termTime = Calendar.getInstance();
        termTime.add(Calendar.HOUR, 1);
        input.setInitialTerminationTime(termTime);
        setSecurity((Stub)factoryPort);
        CreateReliableFileTransferOutputType response = factoryPort
                .createReliableFileTransfer(input);

        return response.getReliableTransferEPR();
    }

Now contact the RFT service Implementation and call start to actually start the transfer:

ReliableFileTransferPortType rft = rftLocator
                .getReliableFileTransferPortTypePort(rftepr);
        setSecurity((Stub)rft);

        //For secure notifications
        subscribe(rft);
        System.out.println("Subscribed for overall status");
        //End subscription code
        Calendar termTime = Calendar.getInstance();
        termTime.add(Calendar.MINUTE, TERM_TIME);
        SetTerminationTime reqTermTime = new SetTerminationTime();
        reqTermTime.setRequestedTerminationTime(termTime);
        System.out.println("Termination time to set: " + TERM_TIME
                + " minutes");
        SetTerminationTimeResponse termRes = rft
                .setTerminationTime(reqTermTime);
        StartOutputType startresp = rft.start(new Start());

Contact the Delegation Factory Service and get an EPR for the Delegation Resource that contains your delegated credential.

 public static EndpointReferenceType
        delegateCredential(String host, String port) throws Exception {
        ClientSecurityDescriptor desc = new ClientSecurityDescriptor();
        // Credential to sign with, assuming default credential
        GlobusCredential credential = GlobusCredential.getDefaultCredential();
        desc.setGSITransport(Constants.GSI_TRANSPORT)
        Util.registerTransport();
        desc.setAuthz('host');

        String factoryUrl = PROTOCOL + "://" + host + ":"
                        + port + SERVICE_URL_ROOT
                        + DelegationConstants.FACTORY_PATH;

        // lifetime in seconds
        int lifetime = TERM_TIME * 60;

        // Get the public key to delegate on.
        EndpointReferenceType delegEpr = AddressingUtils
                .createEndpointReference(factoryUrl, null);
        X509Certificate[] certsToDelegateOn = DelegationUtil
                .getCertificateChainRP(delegEpr, desc);
        X509Certificate certToSign = certsToDelegateOn[0];
        return DelegationUtil.delegate(factoryUrl,
                    credential, certToSign, lifetime, false,
                    desc);
    }
    

Now construct a DeleteRequestType object:

    DeleteType[] deleteArray = new DeleteType[1];
    deleteArray[0] = new DeleteType();
    deleteArray[0].setFile("gsiftp://foo/bar");
    DeleteOptionsType deleteOptions = new DeleteOptionsType();
    deleteOptions.setSubjectName("SUBJECT-NAME");
    DeleteRequestType request = new DeleteRequestType();
    request.setDeleteOptions(deleteOptions);
    request.setDeletion(deleteArray);
    request.setTransferCredentialEndpoint(delegateCredential(host,port));
    

Now contact the RFT factory and create an RFT resource:

      public static EndpointReferenceType createRFT(String rftFactoryAddress,
            BaseRequestType request) 
    throws Exception {
        endpoint = new URL(rftFactoryAddress);
        factoryPort = rftFactoryLocator
                .getReliableFileTransferFactoryPortTypePort(endpoint);
        CreateReliableFileTransferInputType input =
            new CreateReliableFileTransferInputType();
        //input.setTransferJob(transferType);
        if(request instanceof TransferRequestType) {
            input.setTransferRequest((TransferRequestType)request);
        } else {
            input.setDeleteRequest((DeleteRequestType)request);
        }
        Calendar termTime = Calendar.getInstance();
        termTime.add(Calendar.HOUR, 1);
        input.setInitialTerminationTime(termTime);
        setSecurity((Stub)factoryPort);
        CreateReliableFileTransferOutputType response = factoryPort
                .createReliableFileTransfer(input);

        return response.getReliableTransferEPR();
    }

Now contact the RFT service Implementation and call start to actually start the transfer:

ReliableFileTransferPortType rft = rftLocator
                .getReliableFileTransferPortTypePort(rftepr);
        setSecurity((Stub)rft);

        //For secure notifications
        subscribe(rft);
        System.out.println("Subscribed for overall status");
        //End subscription code
        Calendar termTime = Calendar.getInstance();
        termTime.add(Calendar.MINUTE, TERM_TIME);
        SetTerminationTime reqTermTime = new SetTerminationTime();
        reqTermTime.setRequestedTerminationTime(termTime);
        System.out.println("Termination time to set: " + TERM_TIME
                + " minutes");
        SetTerminationTimeResponse termRes = rft
                .setTerminationTime(reqTermTime);
        StartOutputType startresp = rft.start(new Start());