protected class BalancedCluster.PoolTransfer extends Object
Modifier and Type | Field and Description |
---|---|
private int |
mCapacity
The maximum number of transfer jobs that are allowed for this
particular pool.
|
private boolean |
mLocalTransfer
boolean indicating whether the transfer job needs to run on local site
|
private int |
mNext
The index of the job to which the next transfer for the pool would
be scheduled.
|
private String |
mPool
The staging site for which these transfers are grouped.
|
private List |
mTXContainers
The list of
TransferContainer that correspond to
each transfer job. |
Constructor and Description |
---|
BalancedCluster.PoolTransfer()
The default constructor.
|
BalancedCluster.PoolTransfer(String pool,
boolean localTransfer,
int number)
Convenience constructor.
|
Modifier and Type | Method and Description |
---|---|
BalancedCluster.TransferContainer |
addTransfer(Collection<FileTransfer> files,
int level,
int type)
Adds a a collection of
FileTransfer objects to the
appropriate TransferContainer. |
BalancedCluster.TransferContainer |
addTransfer(FileTransfer file,
int level,
int type)
Adds a single
FileTransfer objects to the
appropriate TransferContainer. |
String |
getPoolName()
Return the pool for which the transfers are grouped
|
private String |
getRegJobName(int counter,
int level)
Generates the name of the transfer job, that is unique for the given
workflow.
|
Iterator |
getTransferContainerIterator()
Returns the iterator to the list of transfer containers.
|
private String |
getTXJobName(int counter,
int type,
int level)
Generates the name of the transfer job, that is unique for the given
workflow.
|
private int mCapacity
private int mNext
private String mPool
private List mTXContainers
TransferContainer
that correspond to
each transfer job.private boolean mLocalTransfer
public BalancedCluster.PoolTransfer()
public BalancedCluster.PoolTransfer(String pool, boolean localTransfer, int number)
pool
- the pool name for which transfers are being grouped.localTransfer
- whether the transfers need to be run on local sitenumber
- the number of transfer jobs that are going to be created
for the pool.public BalancedCluster.TransferContainer addTransfer(Collection<FileTransfer> files, int level, int type)
FileTransfer
objects to the
appropriate TransferContainer. The collection is added to a single
TransferContainer, and the pointer is then updated to the next container.files
- the collection FileTransfer
to be added.level
- the level of the workflowtype
- the type of transfer jobpublic BalancedCluster.TransferContainer addTransfer(FileTransfer file, int level, int type)
FileTransfer
objects to the
appropriate TransferContainer. The collection is added to a single
TransferContainer, and the pointer is then updated to the next container.file
- level
- the level of the workflowtype
- the type of transfer jobpublic Iterator getTransferContainerIterator()
private String getRegJobName(int counter, int level)
counter
- the index for the registration job.level
- the level of the workflow.public String getPoolName()
private String getTXJobName(int counter, int type, int level)
counter
- the index for the transfer job.type
- the type of transfer job.level
- the level of the workflow.