GT4 开发：将 Storage Resource Broker 与 Jakarta Commons Virtual File System 集成在一起

<providers>
 <provider class-name=
  "org.apache.commons.vfs.provider
    .srb.SrbFileProvider">
        <scheme name="srb"/>
 </provider>
</providers>

/**
 * A file system provider, which uses direct file access.
 *
 * @author Vladimir Silva
 */
public class SrbFileProvider
    extends AbstractOriginatingFileProvider
{
    private Log log = LogFactory.getLog(SrbFileProvider.class);

    public final static Collection capabilities =
            Collections.unmodifiableCollection
              (Arrays.asList(new Capability[]
    {
        Capability.CREATE,
        Capability.DELETE,
        Capability.RENAME,
        Capability.GET_TYPE,
        Capability.GET_LAST_MODIFIED,
        Capability.SET_LAST_MODIFIED_FILE,
        Capability.SET_LAST_MODIFIED_FOLDER,
        Capability.LIST_CHILDREN,
        Capability.READ_CONTENT,
        Capability.URI,
        Capability.WRITE_CONTENT
    }));

    public SrbFileProvider()
    {
        super();
        setFileNameParser(SrbFileNameParser.getInstance());
    }

    /**
     * Creates the filesystem.
     */
    protected FileSystem doCreateFileSystem(final FileName name
    , final FileSystemOptions fileSystemOptions)
        throws FileSystemException
    {
        // Create the file system
        String Path = name.getPath();

        log.debug("Creating file system with name=" + name
                  + " URI=" + name.getRootURI());
        return
          new SrbFileSystem((GenericFileName)name
            , Path, fileSystemOptions);
    }

    public Collection getCapabilities()
    {
        return capabilities;
    }
}

# SRB MCAT log in parameters
# The password resides in $HOME/.srb/.MdasAuth

# User's Collection (home directory name)
mdasCollectionName '/nccZone/home/srbAdmin.NCC'

# Location of the hhome directory
mdasCollectionHome '/nccZone/home/srbAdmin.NCC'

# SRB domain
mdasDomainName 'NCC'
mdasDomainHome 'NCC'

# User name
srbUser 'srbAdmin'

# Meta data catalog MCAT Host
srbHost 'ebony.rtpnc.epa.gov'

# Default port
#srbPort '5544'

# Default storage resource (machine) name
defaultResource 'nccResc'

# Authorization Schemes
# SRB supports Grid Security Infrastructure authentication! 
# However the server must be
# recompiled with the GSI libraries
#AUTH_SCHEME 'PASSWD_AUTH'
#AUTH_SCHEME 'GSI_AUTH'
AUTH_SCHEME 'ENCRYPT1'

edu.sdsc.grid.io.GeneralFileSystem
    srbFileSystem = FileFactory.newFileSystem(
       new SRBAccount(host     // SRB host
          , port   // SRB port (5544)
          , user   // User
          , pwd    // Pwd
          , home   // User's home dir
          , domain // SRB domain
          , defRes  // SRB default resource (machine)
          , mcatZone)); // MCAT Zone (for federations)

  srbFileSystem = FileFactory.newFileSystem( new SRBAccount());

/**
 * A local file system.
 *
 * @author Vladimir Silva
 */
public class SrbFileSystem extends AbstractFileSystem
        implements FileSystem
{
    private Log log = LogFactory.getLog(SrbFileSystem.class);

    private final GeneralFileSystem srbFileSystem;
    private Map attribs = new HashMap();

    public static final String HOME_DIRECTORY = "HOME_DIRECTORY";

    /**
     * Constructor
     * @param rootName Path to the root folder
     * @param rootFile
     * @param opts FS options
     * @throws FileSystemException
     */
    public SrbFileSystem(final GenericFileName rootName,
                         final String rootFile,
                         final FileSystemOptions opts) throws
            FileSystemException {
        super(rootName, null, opts);

        String host = rootName.getHostName();
        int port = rootName.getPort();
        String user = rootName.getUserName();
        String pwd = rootName.getPassword();

        try {
            // Load some stuff from ~/.srb/MdasEnv user info file
            SRBAccount srbAccount = new SRBAccount();

            String domain;

            // SRB user names are composed by [USER-NAME].[DOMAIN]
            if (user.indexOf(".") != -1) {
                domain = user.substring(user.indexOf(".") + 1);
                user = user.substring(0, user.indexOf("."));
            } else {
                domain = srbAccount.getDomainName();
            }

            String home = srbAccount.getHomeDirectory();
            String mcatZone = srbAccount.getMcatZone();
            String defRes = srbAccount.getDefaultStorageResource();

            // Create SRB connection, mot of the data comes from
            // $HOME/.srb/MdasEnv
            srbFileSystem = FileFactory.newFileSystem(
              new SRBAccount(host     // SRB host
                  , port   // SRB port (5599)
                  , user   // User
                  , pwd    // Pwd
                  , home   // User's home dir
                  , domain // SRB domain
                  , defRes, // SRB default resource (machine)
                  mcatZone)); // MCAT Zone (for federations)

            // save SRB home dir
            attribs.put(HOME_DIRECTORY, home);

            log.debug("Constructor: Created new SRB FileSystem " +
                      srbFileSystem + " with home=" +
                      attribs.get(HOME_DIRECTORY));

        } catch (Exception e) {
            throw new FileSystemException(e.getMessage(), e);
        }
    }

    /**
     * Creates a file object.
     */
    protected FileObject createFile(final FileName name)
    throws  FileSystemException {
        // Create the file
        String fileName = name.getPath();

        log.debug("Creating new file="
          + fileName + " Name=" + name
          + " Parent=" + name.getParent());

        return new SrbFileObject(this, name);
    }

    /**
     * Returns the capabilities of this file system.
     */
    protected void addCapabilities(final Collection caps) {
        caps.addAll(DefaultLocalFileProvider.capabilities);
    }

    protected GeneralFileSystem getSRBFileSystem() {
        return srbFileSystem;
    }

    public Object getAttribute(final String attrName)
     throws FileSystemException {
        return attribs.get(attrName);
    }
}

/**
 * A file object implementation which uses direct file access.
 *
 * @author Vladmir Silva
 */
public class SrbFileObject
 extends AbstractFileObject implements FileObject {
    private Log log = LogFactory.getLog(SrbFileObject.class);

    // SRB file object
    private GeneralFile file;

    // File info: Name, size, last modified
    private FileName fileName;
    private String filePath;
    private MetaDataRecordList attribs;


    // SRB Attributes
    private Map fileAttributes = new HashMap();

    // File Object children
    private Map children = new TreeMap();

    // used to parse SRB date: yyyy-MM-dd-HH.mm.ss
    Calendar calendar = Calendar.getInstance();

    /**
     * For items which matched the query, met the conditions above,
     * the following values will be returned.
     */
    final String[] selectFieldNames = {
      SRBMetaDataSet.FILE_NAME,
      SRBMetaDataSet.FILE_COMMENTS,
      SRBMetaDataSet.FILE_TYPE_NAME,
      SRBMetaDataSet.SIZE,
      SRBMetaDataSet.USER_NAME,
      SRBMetaDataSet.FILE_LAST_ACCESS_TIMESTAMP,
      SRBMetaDataSet.RESOURCE_NAME,
      SRBMetaDataSet.
      DEFINABLE_METADATA_FOR_FILES
    };

    MetaDataSelect selects[] =
      MetaDataSet.newSelection(selectFieldNames);

    /**
     * Creates a non-root file.
     */
    protected SrbFileObject(final SrbFileSystem fileSystem,
                            final FileName name)
    throws FileSystemException {
        super(name, fileSystem);
        this.fileName = name;
        this.filePath = UriParser.decode(name.getPath());
        log.debug("Constructor for file path "
         + filePath + " file name=" + name);
    }

    /**
     * Returns the local file that this file object represents.
     */
    protected GeneralFile getGeneralFile() {
        return file;
    }

    /*
     * Get an SRB Attribute value from a query record
     */
    private Object getSrbAttribute(MetaDataRecordList record, String key)
    {
        return record.getValue(record.getFieldIndex(key));
    }

    /**
     * Set custom SRB attributes for a given File object
     * @param f
     * @param results
     */