|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.globus.ftp.dc.TransferThreadManager
public class TransferThreadManager
Field Summary | |
---|---|
protected DataChannelFactory |
dataChannelFactory
|
protected GridFTPServerFacade |
facade
|
protected GridFTPSession |
gSession
|
protected BasicServerControlChannel |
localControlChannel
|
protected SocketPool |
socketPool
|
protected TaskThread |
taskThread
|
protected int |
transferThreadCount
|
Constructor Summary | |
---|---|
TransferThreadManager(SocketPool socketPool,
GridFTPServerFacade facade,
BasicServerControlChannel myControlChannel,
GridFTPSession gSession)
|
Method Summary | |
---|---|
void |
activeClose(TransferContext context,
int connections)
use only in mode E |
void |
activeConnect(HostPort hp,
int connections)
Act as the active side. |
void |
close()
|
int |
getTransferThreadCount()
|
void |
passiveConnect(DataSink sink,
TransferContext context,
int connections,
java.net.ServerSocket serverSocket)
Accept connections from the remote server, and start transfer threads that will read incoming data and store in the sink. |
void |
passiveConnect(DataSource source,
TransferContext context,
java.net.ServerSocket serverSocket)
Accept connection from the remote server and start transfer thread that will read incoming data and store in the sink. |
void |
startTransfer(DataSink sink,
TransferContext context,
int connections,
boolean reusable)
This should be used once the remote active server connected to us. |
void |
startTransfer(DataSource source,
TransferContext context,
int connections,
boolean reusable)
This should be used once the remote active server connected to us. |
void |
stopTaskThread()
|
void |
transferThreadStarting()
|
void |
transferThreadTerminating()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected SocketPool socketPool
protected GridFTPServerFacade facade
protected BasicServerControlChannel localControlChannel
protected GridFTPSession gSession
protected TaskThread taskThread
protected int transferThreadCount
protected DataChannelFactory dataChannelFactory
Constructor Detail |
---|
public TransferThreadManager(SocketPool socketPool, GridFTPServerFacade facade, BasicServerControlChannel myControlChannel, GridFTPSession gSession)
Method Detail |
---|
public void activeConnect(HostPort hp, int connections)
public void activeClose(TransferContext context, int connections)
public void startTransfer(DataSource source, TransferContext context, int connections, boolean reusable) throws ServerException
reusable
- if set to false, the sockets will not be reused after
the transfer
ServerException
public void startTransfer(DataSink sink, TransferContext context, int connections, boolean reusable) throws ServerException
reusable
- if set to false, the sockets will not be reused after
the transfer
ServerException
public void passiveConnect(DataSink sink, TransferContext context, int connections, java.net.ServerSocket serverSocket) throws ServerException
connections
- the number of expected connections
ServerException
public void passiveConnect(DataSource source, TransferContext context, java.net.ServerSocket serverSocket) throws ServerException
ServerException
public int getTransferThreadCount()
public void transferThreadStarting()
public void transferThreadTerminating()
public void stopTaskThread()
public void close()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |