Srm

Default(protocol_attr, rse_settings, logger=logging.log)

Implementing access to RSEs using the SRM protocol.

lfns2pfns(lfns)

Returns a fully qualified PFN for the file referred by path.

Parameters:

Name	Type	Description	Default
path		The path to the file.	required

Returns:

Type	Description
	Fully qualified PFN.

parse_pfns(pfns)

Splits the given PFN into the parts known by the protocol. During parsing the PFN is also checked for validity on the given RSE with the given protocol.

Parameters:

Name	Type	Description	Default
pfn		a fully qualified PFN	required

Returns:

Type	Description
	a dict containing all known parts of the PFN for the protocol e.g. scheme, path, filename

Raises:

Type	Description
RSEFileNameNotSupported	if the provided PFN doesn't match with the protocol settings

path2pfn(path)

Returns a fully qualified PFN for the file referred by path.

Parameters:

Name	Type	Description	Default
path		The path to the file.	required

Returns:

Type	Description
	Fully qualified PFN.

connect()

Establishes the actual connection to the referred RSE. As a quick and dirty implementation we just use this method to check if the lcg tools are available. If we decide to use gfal, init should be done here.

Raises:

Type	Description
RSEAccessDenied	Cannot connect.

get(path, dest, transfer_timeout=None)

Provides access to files stored inside connected the RSE.

Parameters:

Name	Type	Description	Default
path		Physical file name of requested file	required
dest		Name and path of the files when stored at the client	required
transfer_timeout		Transfer timeout (in seconds)	None

Raises:

Type	Description
DestinationNotAccessible	if the destination storage was not accessible.
ServiceUnavailable	if some generic error occurred in the library.
SourceNotFound	if the source file was not found on the referred storage.

put(source, target, source_dir, transfer_timeout=None)

Allows to store files inside the referred RSE.

Parameters:

Name	Type	Description	Default
source		path to the source file on the client file system	required
target		path to the destination file on the storage	required
source_dir		Path where the to be transferred files are stored in the local file system	required
transfer_timeout		Transfer timeout (in seconds)	None

Raises:

Type	Description
DestinationNotAccessible	if the destination storage was not accessible.
ServiceUnavailable	if some generic error occurred in the library.
SourceNotFound	if the source file was not found on the referred storage.

delete(path)

Deletes a file from the connected RSE.

Parameters:

Name	Type	Description	Default
path		path to the to be deleted file	required

Raises:

Type	Description
ServiceUnavailable	if some generic error occurred in the library.
SourceNotFound	if the source file was not found on the referred storage.

rename(path, new_path)

Allows to rename a file stored inside the connected RSE.

Parameters:

Name	Type	Description	Default
path		path to the current file on the storage	required
new_path		path to the new file on the storage	required

Raises:

Type	Description
DestinationNotAccessible	if the destination storage was not accessible.
ServiceUnavailable	if some generic error occurred in the library.
SourceNotFound	if the source file was not found on the referred storage.

exists(path)

Checks if the requested file is known by the referred RSE.

Parameters:

Name	Type	Description	Default
path		Physical file name	required

Returns:

Type	Description
	True if the file exists, False if it doesn't

Raises:

Type	Description
SourceNotFound	if the source file was not found on the referred storage.

__parse_srm_error__(err_code, out, err)

Parse the error message to return error code.

close()

Closes the connection to RSE.