SDM

People Publications Projects

Table: Files

• int fileId (primarykey) //db assigned id
• int dirId (foreign key)
• varchar(4000) fileName
• int fileAttributesId (foreign key)

Table: FileAttributes

• int fileAttributesId (primarykey) //db assigned id
• varchar(2000) path //db internal column
• long hashValue //db internal column
• long size
• timestamp createdAtTime
• timestamp lastModificationTime
• varchar(255) fileStorageType (e.g. Durable|Volatile|Permanent)
• varchar(255) retentionPolicyInfo
• varchar(255) accessLatency
• varchar(255) fileLocality
• varchar(255) typ (e.g. File|Directory|Link)
• int lifeTimeAssigned
• int lifeTimeLeft
• varchar(255) userID
• varchar(255) ownerPermission (e.g. srm,RWX)
• varchar(255) groupID
• varchar(255) groupPermission (e.g. srm,RWX)
• varchar(255) otherPermission (e.g. RWX)
• varchar(255) checkSumType
• varchar(255) checkSumValue

Table: FileAttributesSP

• int fileAttributesSPId (primarykey) //db assigned id
• int fileAttributesId //foreign key to fileAttributes table
• varchar(1000) spaceToken
• long hashValue

Table: Request

• varchar(255) rId (primarykey) //bestman assigned id
• int userId (foreign key)
• varchar(4000) userRequestDesc
• varchar(255) authID
• int requestLevelInputId (foreign key) (optional column only use for asyn requests)
• varchar(500) status
• varchar(4000) explanation
• varchar(500) bandwidthStatus
• varchar(255) requestType
• varchar(255) fileType
• varchar(255) spaceToken (foreign key)
• varchar(1000) targetFileRetentionPolicy (e.g. (replica|output|custodial)
• varchar(1000) targetFileAccessLatency (e.g. (online|nearline)
• varchar(1000) transferParametersAccessPattern (e.g. (TransferMode|!ProcessingMode)
• varchar(1000) transferParametersConnectionType (e.g. (WAN|LAN)
• varchar(1000) transferParametersClientNetworks
• varchar(1000) transferParametersTransferProtocols
• Date createdTime
• Date statusTime
• int desiredTotalRequestTime
• int totalNumFilesInRequest
• int numOfCompletedFiles
• int numOfWaitingFiles
• int numOfFailedFiles

Table: Component

• int componentId (primarykey) //db assigned id
• varchar(500) componentName //required
• varchar(500) mountingPoint //required //(name and mounting must be unique for each row)
• varchar(500) componentType //enumerated type //(e.g. custodial|online)
• int totalSize
• varchar(4000) description //(e.g. RAID)

Table: User

• int id (primarykey) //db assigned id
• varchar(2000) userId (unique not null)

Table: SpaceAssignment

• varchar(255) spaceToken (primarykey)
• varchar(500) uid (foreign key)
• int componentId (foreign key)
• varchar(4000) userDesc
• long totalSize
• long guaranteedSize
• long unUsedSize
• int lifeTimeAssigned
• Date lifeTimeStart

Table: BandwidthCommited

• int id (primary key)
• int rid
• timestamp ts
• timestamp te
• long bw

Table: RequestLevelInputForGet

• varchar(255) rid (primary key)
• int desiredPinLifeTime
• varchar(4000) storageSysInfo

Table: RequestLevelInputForPut

• varchar(255) rid (primary key)
• int desiredPinLifeTime
• int desiredFileLifeTime
• varchar(4000) storageSysInfo
• varchar(255) overWriteMode (e.g. Never|Always|when_file_are_different)

Table: RequestLevelInputForCopy

• varchar(255) rid (primary key)
• int desiredSURLLifetime
• varchar(4000) sourceStorageSysInfo
• varchar(4000) targetStorageSysInfo
• varchar(255) overWriteMode (e.g. Never|Always|when_file_are_different)

Table: RequestLevelInputForBringOnline

• varchar(255) rid (primary key)
• int desiredPinLifetime
• int deferredStartTime
• varchar(4000) storageSysInfo

Table: RequestLevelInputForChangeSpace

• varchar(255) rid (primary key)
• varchar(4000) storageSysInfo

Table: DirOption

• varchar(255) rid ((partial primary key)
• varchar(2000) localSURL (partial primary key)
• varchar(2000) remoteSURL (partial primary key)
• boolean isSourceADirectory
• boolean allLevelRecursive
• int numOfLevels

Table: RequestExecution

• varchar(255) rid (partial primarykey)
• varchar(4000) localSURL (partial primarykey)
• varchar(4000) remoteSURL (partial primarykey)
• long expectedSize
• int dirOption (foreign key)
• varchar(4000) TURL
• varchar(255) spaceToken
• Date statusTime
• int newPinLifetime
• varchar(255) status
• varchar(4000) explanation

Table: RequestLevelInputForLs

• varchar(255) rid (primarykey)
• boolean fullDetailedList
• boolean allLevelRecursive
• int numOfLevels
• int offset
• int count
• varchar(4000) storageSystemInfo

Table: RequestLevelInputForReserveSpace

• varchar(255) rid (primarykey)
• varchar(4000) userSpaceTokenDesc
• long desiredSizeOfTotalSpace
• long desiredSizeOfGuaranteedSpace
• int desiredLifeTimeOfReservedSpace
• int estimatedProcessingTime
• varchar(4000) storageSysInfo

Table: RequestLevelInputForUpdateSpace

• varchar(255) rid (primarykey)
• int newLifeTime
• long newSizeOfTotalSpaceDesired
• long newSizeOfGuaranteedSpaceDesired
• varchar(4000) storageSysInfo

Basic API's

• checkSchemaExistence : boolean checkSchemaExistence()
• checkSchemaExistence will check for schema existence in the beginning of the program
• createTables : createTables()
• createTables will create the table
• findUsersFromDatabase : int[] findUsersFromDatabse()
• returns the ids of the users from the database
• findQueuedRequestIds: String[] findQueuedRequestIds(int uid, int limit)
• findQueuedRequestIds will fetch the next limit no of requests. to be processed, returns the array of rids.
• findNextFileInRequest: Vector findNextFileInRequest(String rid, int limit)
• findNextFileInRequest will fetch the next limit no. of files in the requests. to be processed, returns the File level information, each element in the vector is a hashtable and the hashtable contains the file level information.
• addUser :boolean addUser(String uid);
• adds the user into the user table
• uid cannot be null or empty
• deleteUser :boolean deleteUser(String uid);
• deletes the user from user table
• uid cannot be null or empty
• updateUser :boolean updateUser(String uid,Hashtable ht);
• updates the user table for the given uid
• hashtable contains the key,value pairs where keys are columns of user table.
• uid and hashtable cannot be null or empty
• getMappedIdsForDN : String[] getMappedIdsForDN(String DN);
• returns the matching mappedId's for DN.
• not implemented yet.
• updateRequest : boolean updateRequest(String rid, Hashtable ht);
• udpates the attributes in the request table
• rid or hashtable cannot be null or empty
• hashtable contains the key,value pairs where keys are the columns of the RequestTable
• updateRequestExec : boolean updateRequestExec(String rid, String localSURL, String remoteSURL,
• Hashtable ht);
• udpates the attributes in the request executation table
• rid, localSURL cannot be null or empty
• when remoteSURL is null or empty, "NA" is assigned to it.
• hashtable contains the key,value pairs where keys are the columns of the RequestExecution table
• updateFileAttributes : void updateFileAttributes(String path, Hashtable ht)
• updates entries in the FileAttributes table, for the given path
• path and hashtable cannot be null or empty
• hashtable contains key,value pairs, where keys are the columns of the Files table.
• updatePinLifeTime : boolean updatePinLifeTime(String rid, String localSURL, int lifeTime)
• updates lifeTime in the RequestExecution table, for the given rid and localSURL
• rid, localSURL cannot be null or empty
• updateFileLifeTime : boolean updateFileLifeTime(String path, int newFileLifeTime)
• updates lifeTimeAssigned in the FileAttributes table for the given path
• path cannot be null or empty
• getAttributesFromRequest:HashMap getAttributesFromRequest(String rid)
• returns hashmap contains the values of entries in the request level table
• getAttributesFromRequestExec:HashMap getAttributesFromRequestExec(String rid)
• returns hashmap contains the values of entries in the requestexec level table
• getAttributesFromFileAttributes:HashMap getAttributesFromFileAttributes(String rid)
• returns hashmap contains the values of entries in the FileAttributes table
• insertIntoBandwidthCommited:void insertIntoBandwidthCommited(String rid, long timestart, long timeend, long bandwidthwindow)
• deleteFromBandwidthCommited:void deleteFromBandwidthCommited(String rid)
• deletes the rows matching rid
• getAttributesFromBandwidthCommited:Vector getAttributesFromBandwidthCommited(String rid)
• returns vector contains the values of entries in the Bandwidth table, each entry is a Hashmap
• contains the attributes of Bandwidthcommited

DataTransfer API's

• store : boolean store(SrmPrepareToGetRequest request, String rid,String uid)
• stores the get request information in the RequestLevelInputForGetTable and in the Request table and in the RequestExecution table
• rid and uid cannot be null or empty
• request cannot be null
• store : boolean store(SrmPrepareToPutRequest request, String rid, String uid)
• stores the put request information in the RequestLevelInputForPutTable and in the Request table and in the RequestExecution table
• rid and uid cannot be null or empty
• request cannot be null
• store : boolean store(SrmPrepareToBringOnlineRequest request, String rid, String uid)
• stores the bringonline request information in the RequestLevelInputForBringOnlineTable and in the Request table and in the RequestExecution table
• rid and uid cannot be null or empty
• request cannot be null
• store : boolean store(SrmPrepareToCopyRequest request, String rid, String uid)
• stores the copy request information in the RequestLevelInputForCopyTable and in the Request table and in the RequestExecution table
• rid and uid cannot be null or empty
• request cannot be null
• deleteRow: boolean deleteRow(String rid)
• delete a row in the Request table and request Execution table and from the associated RequestLevelInputFor(get|put|copy...)Table
• rid cannot be null or empty
• srmGetRequestSummary TRequestSummary[] srmGetRequestSummary(String[] requestToken, String userId)
• gets the request summary for the provided request tokens
• userId cannot be null and requesttokens cannot be null or empty
• srmGetRequestTokens TRequestTokenReturn[] srmGetRequestTokens(String userRequestDesc, String userId)
• retrieves request tokens matching for the userRequestDesc
• userRequestDesc and userId cannot be null
• srmExtendFileLifeTime TSURLLifetimeReturnStatus[] srmExtendFileLifeTime(String requestToken, String[] surls, int newFileLifeTime, int newPinLifetime)
• update the newfilelifetime in the Files table and newPinLifeTime in the RequestExec table.
• requestToken cannot be null or empty
• surls cannot be null or empty

Directory Related api's

• store : boolean store(SrmLsRequest request, String rid, String uid)
• stores the ls request information in the RequestLevelInputForLsTable and in the Request table and in the RequestExecution table
• rid and uid cannot be null or empty
• request cannot be null
• mkDir : boolean mkdir(String path)
• compute hashvalues for the path, create the entries in the directory table recursively
• path cannot be null or empty
• createFile : boolean createFile(String path)
• creates the file entries in the files table.
• path cannot be null or empty
• rmDir : boolean rmdir(String path, boolean recursive)
• If recursive is false, directory needs to be empty.
• If recursive is true, it deletes the entries recursively, along with entries from the file table path cannot be null or empty
• rmFile: boolean rmfile(String path)
• Removes the entry from the files table
• path cannot be null or empty
• mv : boolean mv(String source, String target)
• Re-calculate hash values and update the directory/files table source and target cannot be null or empty
• list : TMetaDataPathDetail[] ls(String path, boolean recursive)
• returns in the directory listing for the given path.
• If recursive is true, returns the directory listing recursively.
• path cannot be null or empty
• space related api's
• store : boolean store(SrmReserveSpaceRequest request, String rid, String uid)
• stores the reserve space request information in the RequestLevelInputForReserveSpaceTable
• rid and uid cannot be null or empty
• request cannot be null
• store : boolean store(SrmChangeSpaceForFilesRequest request, String rid, String uid)
• stores the change space request information in the RequestLevelInputForChangeSpaceTable
• rid and uid cannot be null or empty
• request cannot be null
• store : boolean store(SrmUpdateSpaceRequest request, String rid, String uid)
• stores the update space request information in the RequestLevelInputForUpdateSpaceTable
• rid and uid cannot be null or empty
• request cannot be null
• srmGetSpaceMetaData TMetaDataSpace[] srmGetSpaceMetaData(String userId, String[] spacetoken)
• retrieves the space metadata for the given space token
• srmGetSpaceTokens String[] srmGetSpaceTokens(String userSpaceTokenDesc, String uid)
• retrieves the space tokens matching the given userSpaceTokenDesc and uid
• addComponent boolean addComponent(String name, int totalSize, String type, String description, String mountingPoint)
• inserts into Component table.
• name and mountingPoint cannot be null or empty.
• name and mountingPoint needs to be unique for each row.
• updateComponent boolean updateComponent(String name, Hashtable ht)
• updates into Component table
• name cannot be null or empty.
• hashtable contains the key,value pairs, where keys are the columns of component table
• deleteComponent boolean deleteComponent (String name)
• deletes from the SpaceAssignment table all the spaceTokens associated with this component and deletes from Component table
• name cannot be null or empty.
• addSpaceToken boolean addSpaceToken(String name, String uid, String spaceToken, String userDesc, long totalSize, long guaranteedSize, int lifeTimeAssigned)
• inserts into SpaceAssignment table.
• name and uid and spaceToken cannot be null or empty.
• updateSpaceToken boolean updateSpaceToken(String spaceToken, Hashtable ht)
• updates SpaceAssignment table.
• spacetoken and ht cannot be null or empty.
• ht contains the key,value pairs where keys are columns of SpaceAssignment table
• deleteSpaceToken boolean deleteSpaceToken(String spaceToken)
• deletes space token from SpaceAssignment table.
• spacetoken cannot be null or empty.
• getLifeTimeOfSpaceToken : int getLifeTimeOfSpaceToken(String uid, String spaceToken)
• returns the lifetimeAssigned for the given spacetoken
• uid and spaceToken cannot be null or empty
• findSURLSForSpaceToken : string[] findSURLSForSpaceToken(String spaceToken)
• returns the SURLS[] for the given spacetoken
• spaceToken cannot be null or empty