edu.isi.pegasus.planner.transfer
public class RemoteTransfer extends Object
Modifier and Type | Class and Description |
---|---|
private static class |
RemoteTransfer.TransferState
An inner class that holds the state for a particular site,as to whether to
execute transfers remotely or not.
|
Modifier and Type | Field and Description |
---|---|
static String |
ALL_SITES
The constant to apply to all sites.
|
static String |
ALL_TRANSFERS_REMOTE_PROPERTY
The property name to get the sites for which all transfers need to
be executed remotely.
|
static String |
INTER_TRANSFERS_REMOTE_PROPERTY
The property name to get the sites for which inter site transfers need
to be executed remotely.
|
private LogManager |
mLogger
The handle to the logging object.
|
private static Map |
mPropertyTable
An internal table that maps remote transfer type to the corresponding
property.
|
private PegasusProperties |
mProps
The handle to the properties object holding the properties relevant to
Pegasus.
|
private Map |
mStateMap
The map indexed by site name, that contains the state for all the sites.
|
static String |
STAGE_IN_TRANSFERS_REMOTE_PROPERTY
The property name to get the sites for which stage-in transfers need to
be executed remotely.
|
static String |
STAGE_OUT_TRANSFERS_REMOTE_PROPERTY
The property name to get the sites for which stage-out transfers need to
be executed remotely.
|
Constructor and Description |
---|
RemoteTransfer()
The default constructor.
|
RemoteTransfer(PegasusProperties properties)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
buildState()
Builds up the remote transfers state for all the sites.
|
private void |
buildState(int type)
Adds to the existing state table, state information for a particular
type of transfers.
|
private boolean |
containsKey(String site)
Returns whether there is an entry for a particular site or not.
|
private RemoteTransfer.TransferState |
get(String site)
Returns the TPT state for a particular site.
|
private Set |
getThirdPartySites(String value)
Returns a set of third party sites.
|
boolean |
interOnRemoteSite(String site)
Returns a boolean indicating whether to execute inter site transfers on
remote site or not.
|
void |
print()
Prints out the third party state for the various sites.
|
private static Map |
propertyTable()
Singleton access to the type table
Contains the mapping of a property to the third party transfer type
|
private void |
put(String site,
RemoteTransfer.TransferState state)
Inserts an entry in to the State Map, that maintains state of various
sites.
|
boolean |
stageInOnRemoteSite(String site)
Returns a boolean indicating whether to execute stage-in transfers on
remote site or not.
|
boolean |
stageOutOnRemoteSite(String site)
Returns a boolean indicating whether to execute stage-out transfers on
remote site or not.
|
public static final String ALL_SITES
public static final String ALL_TRANSFERS_REMOTE_PROPERTY
public static final String STAGE_IN_TRANSFERS_REMOTE_PROPERTY
public static final String INTER_TRANSFERS_REMOTE_PROPERTY
public static final String STAGE_OUT_TRANSFERS_REMOTE_PROPERTY
private static Map mPropertyTable
private PegasusProperties mProps
private LogManager mLogger
private Map mStateMap
public RemoteTransfer()
public RemoteTransfer(PegasusProperties properties)
properties
- handle to the properties required.private static Map propertyTable()
public void buildState()
private void buildState(int type)
type
- the type of transfer.public boolean stageInOnRemoteSite(String site)
public boolean interOnRemoteSite(String site)
public boolean stageOutOnRemoteSite(String site)
public void print()
private boolean containsKey(String site)
site
- the site handle for a site.private void put(String site, RemoteTransfer.TransferState state)
site
- the site handle for a site.state
- the thirdparty state for the site.private RemoteTransfer.TransferState get(String site)
site
- the site handle for the site.