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 remote pool for which these transfers are grouped.
|
private List |
mTXContainers
The list of
TransferContainer that correspond to
each transfer job. |
Constructor and Description |
---|
PoolTransfer()
The default constructor.
|
PoolTransfer(String pool,
boolean localTransfer,
int number)
Convenience constructor.
|
Modifier and Type | Method and Description |
---|---|
Bundle.TransferContainer |
addTransfer(Collection files,
int level,
int type)
Adds a a collection of
FileTransfer objects to the
appropriate TransferContainer. |
String |
addTransfer(FileTransfer transfer,
int type)
Adds a file transfer 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)
Generates the name of the transfer job, that is unique for the given
workflow.
|
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 PoolTransfer()
public 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 Bundle.TransferContainer addTransfer(Collection 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 String addTransfer(FileTransfer transfer, int type)
transfer
- the FileTransfer
containing the
information about a single transfer.type
- 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.private String getTXJobName(int counter, int type)
counter
- the index for the transfer job.type
- the type of transfer job.