Class RM

  • All Implemented Interfaces:
    CleanupImplementation

    public class RM
    extends java.lang.Object
    implements CleanupImplementation
    Use's RM to do removal of the files on the remote sites.
    Version:
    $Revision$
    Author:
    Karan Vahi
    • Field Detail

      • DEFAULT_RM_LOGICAL_NAME

        public static final java.lang.String DEFAULT_RM_LOGICAL_NAME
        The default logical name to rm executable.
        See Also:
        Constant Field Values
      • DEFAULT_RM_LOCATION

        public static final java.lang.String DEFAULT_RM_LOCATION
        The default path to rm executable.
        See Also:
        Constant Field Values
      • DEFAULT_PRIORITY_KEY

        public static final java.lang.String DEFAULT_PRIORITY_KEY
        The default priority key associated with the cleanup jobs.
        See Also:
        Constant Field Values
      • mSiteStore

        protected SiteStore mSiteStore
        Handle to the site catalog.
      • mProps

        private PegasusProperties mProps
        The handle to the properties passed to Pegasus.
    • Constructor Detail

      • RM

        public RM()
        The default constructor.
    • Method Detail

      • createCleanupJob

        public Job createCleanupJob​(java.lang.String id,
                                    java.util.List files,
                                    Job job)
        Creates a cleanup job that removes the files from remote working directory. This will eventually make way to it's own interface.
        Specified by:
        createCleanupJob in interface CleanupImplementation
        Parameters:
        id - the identifier to be assigned to the job.
        files - the list of PegasusFile that need to be cleaned up.
        job - the primary compute job with which this cleanup job is associated.
        Returns:
        the cleanup job.
      • getTCEntry

        protected TransformationCatalogEntry getTCEntry​(java.lang.String site)
        Returns the TCEntry object for the rm executable on a grid site.
        Parameters:
        site - the site corresponding to which the entry is required.
        Returns:
        the TransformationCatalogEntry corresponding to the site.
      • defaultTCEntry

        private static TransformationCatalogEntry defaultTCEntry()
        Returns a default TransformationCatalogEntry object for the rm executable.
        Returns:
        default TransformationCatalogEntry