Interface MasterInterface

All Superinterfaces:

ProviderInterface, Remote

All Known Implementing Classes:

MasterServer

public interface MasterInterface
extends ProviderInterface

The Interface MasterInterface.

Method Summary

Modifier and Type	Method	Description
DataAccessInterface	getDataFileAccessInterface()	Gets the data file access interface.
Destination	getDestination(String name)	Gets the destination.
ECauthToken	getECauthToken(String user)	Gets the ecauth token.
String	getETag(long dataTransferId)	Gets the ETag for a given dataTransferId.
IncomingProfile	getIncomingProfile(String incomingUser, String incomingPassword, String from)	Gets the incoming profile.
String	getIncomingUserHash(String incomingUser)	Return a hash of the specified incoming user (the string is in the form userid:password).
byte[]	getS3AuthorizationSignature(String incomingUser, String prefix, String data, String algorithm)	Return a hash of the specified incoming user (the string is in the form userid:password).
void	importDestination(Destination fromDestination, Association[] linkedAssociations, boolean copySharedHost)	Import destination from another Master Server.
boolean	isValidDataFile(long dataFileId)	Checks if is valid data file.
long	proxyHostIsAlive(String name)	Proxy host is alive.
void	updateData(Host host)	Update data.
void	updateData(String hostId, String data)	Update data.
void	updateDataTransfers(DataTransfer[] transfers)	Update data transfers.
DownloadProgress[]	updateDownloadProgress(DownloadProgress[] progress)	Update download progress.
void	updateIncomingConnectionIds(String serverName, List<IncomingConnection> incomingConnections)	Update incoming connection ids.
boolean	updateLocalTransferStatus(String master, boolean standby, String destination, String target, String uniqueName, String status)	Update data transfer status from another Master Server.
void	updateLocation(Host host)	Update location.

Methods inherited from interface ecmwf.common.ecaccess.ProviderInterface

isAvailable, isRegistred, subscribe

Method Details

updateIncomingConnectionIds

void updateIncomingConnectionIds(String serverName,
 List<IncomingConnection> incomingConnections)
                          throws RemoteException

Update incoming connection ids.

Parameters:

serverName - the server name

incomingConnections - the incoming connections

Throws:

RemoteException - the remote exception

proxyHostIsAlive

long proxyHostIsAlive(String name)
               throws IOException,
RemoteException

Proxy host is alive.

Parameters:

name - the name

Returns:

the long

Throws:

IOException - Signals that an I/O exception has occurred.

RemoteException - the remote exception

updateDataTransfers

void updateDataTransfers(DataTransfer[] transfers)
                  throws IOException,
RemoteException

Update data transfers.

Parameters:

transfers - the transfers

Throws:

IOException - Signals that an I/O exception has occurred.

RemoteException - the remote exception

updateDownloadProgress

DownloadProgress[] updateDownloadProgress(DownloadProgress[] progress)
                                   throws IOException,
RemoteException

Update download progress.

Parameters:

progress - the progress

Returns:

the list of DownloadProgress to interrupt (not found on the MasterServer)

Throws:

IOException - Signals that an I/O exception has occurred.

RemoteException - the remote exception

updateData

void updateData(Host host)
         throws DataBaseException,
RemoteException

Update data.

Parameters:

host - the host

Throws:

DataBaseException - the data base exception

RemoteException - the remote exception

updateData

void updateData(String hostId,
 String data)
         throws DataBaseException,
RemoteException

Update data.

Parameters:

hostId - the host id

data - the host data

Throws:

DataBaseException - the data base exception

RemoteException - the remote exception

updateLocation

void updateLocation(Host host)
             throws DataBaseException,
RemoteException

Update location.

Parameters:

host - the host

Throws:

DataBaseException - the data base exception

RemoteException - the remote exception

getDataFileAccessInterface

DataAccessInterface getDataFileAccessInterface()
                                        throws RemoteException

Gets the data file access interface.

Returns:

the data file access interface

Throws:

RemoteException - the remote exception

getDestination

Destination getDestination(String name)
                    throws RemoteException

Gets the destination.

Parameters:

name - the name

Returns:

the destination

Throws:

RemoteException - the remote exception

isValidDataFile

boolean isValidDataFile(long dataFileId)
                 throws RemoteException

Checks if is valid data file.

Parameters:

dataFileId - the data file id

Returns:

true, if is valid data file

Throws:

RemoteException - the remote exception

getIncomingUserHash

String getIncomingUserHash(String incomingUser)
                    throws RemoteException

Return a hash of the specified incoming user (the string is in the form userid:password).

Parameters:

incomingUser - the incoming user

Returns:

hash, if the user is found

Throws:

RemoteException - the remote exception

getS3AuthorizationSignature

byte[] getS3AuthorizationSignature(String incomingUser,
 String prefix,
 String data,
 String algorithm)
                            throws RemoteException

Return a hash of the specified incoming user (the string is in the form userid:password).

Parameters:

incomingUser - the incoming user

prefix - the prefix (e.g. AWS4)

data - the data

algorithm - the algorithm

Returns:

authorization signature

Throws:

RemoteException - the remote exception

getIncomingProfile

IncomingProfile getIncomingProfile(String incomingUser,
 String incomingPassword,
 String from)
                            throws DataBaseException,
MasterException,
RemoteException

Gets the incoming profile.

Parameters:

incomingUser - the incoming user

incomingPassword - the incoming password

from - the from

Returns:

the incoming profile

Throws:

DataBaseException - the data base exception

MasterException - the master exception

RemoteException - the remote exception

getETag

String getETag(long dataTransferId)
        throws IOException

Gets the ETag for a given dataTransferId.

Parameters:

dataTransferId - the data transfer id

Returns:

the ETag

Throws:

IOException - Signals that an I/O exception has occurred.

getECauthToken

ECauthToken getECauthToken(String user)
                    throws IOException

Gets the ecauth token.

Parameters:

user - the user

Returns:

the ecauth token

Throws:

IOException - Signals that an I/O exception has occurred.

importDestination

void importDestination(Destination fromDestination,
 Association[] linkedAssociations,
 boolean copySharedHost)
                throws DataBaseException,
MasterException,
RemoteException

Import destination from another Master Server.

Parameters:

fromDestination - the from destination

linkedAssociations - the linked associations

copySharedHost - the copy shared host

Throws:

DataBaseException - the data base exception

MasterException - the master exception

RemoteException - the remote exception

updateLocalTransferStatus

boolean updateLocalTransferStatus(String master,
 boolean standby,
 String destination,
 String target,
 String uniqueName,
 String status)
                           throws MasterException,
RemoteException

Update data transfer status from another Master Server.

Parameters:

master - the remote master

standby - the standby flag

destination - the destination name

target - the target name

uniqueName - the unique name

status - the status

Returns:

true, if successful

Throws:

MasterException - the master exception

RemoteException - the remote exception