public class GridFTPServerFacade extends FTPServerFacade
FTPServerFacade.LocalControlChannel
Modifier and Type | Field and Description |
---|---|
protected GridFTPSession |
gSession |
protected SocketPool |
socketPool |
protected StripeContextManager |
stripeRetrContextManager |
protected TransferThreadManager |
transferThreadManager |
ANY_PORT, dataChannelFactory, DEFAULT_QUEUE, localControlChannel, remoteControlChannel, remoteServerAddress, serverSocket, session
Constructor and Description |
---|
GridFTPServerFacade(GridFTPControlChannel remoteControlChannel) |
Modifier and Type | Method and Description |
---|---|
void |
abort()
close data channels, but not control, nor the server
|
static Socket |
authenticate(Socket simpleSocket,
boolean isClientSocket,
GSSCredential credential,
int protection,
DataChannelAuthentication dcau)
authenticate socket.
|
void |
close() |
protected TransferContext |
createTransferContext() |
TransferThreadManager |
createTransferThreadManager() |
void |
retrieve(DataSource source)
Retrieve the data from the data source and write to the data channel.
|
void |
setActive(HostPort hp)
Asynchronous; return before completion.
|
void |
setCredential(GSSCredential cred) |
void |
setDataChannelAuthentication(DataChannelAuthentication authentication) |
void |
setDataChannelProtection(int protection) |
void |
setOptions(Options opts)
Do nothing; this class does not support any options
|
HostPort |
setPassive(int port,
int queue)
Start the local server
|
void |
setStripedActive(HostPortList hpl) |
HostPortList |
setStripedPassive() |
HostPortList |
setStripedPassive(int port,
int queue) |
void |
setTCPBufferSize(int size)
This method needs to be called BEFORE the local socket(s) get created.
|
void |
store(DataSink sink)
Store the data from the data channel to the data sink.
|
protected void |
transferAbort() |
authorize, cannotPropagateError, exceptionToControlChannel, exceptionToControlChannel, getControlChannel, getSession, setPassive, setProtectionBufferSize, setTransferMode, setTransferType, stopTaskThread, unblockServer
protected GridFTPSession gSession
protected SocketPool socketPool
protected TransferThreadManager transferThreadManager
protected StripeContextManager stripeRetrContextManager
public GridFTPServerFacade(GridFTPControlChannel remoteControlChannel)
public void setCredential(GSSCredential cred)
public void setDataChannelProtection(int protection)
public void setDataChannelAuthentication(DataChannelAuthentication authentication)
public void setOptions(Options opts)
FTPServerFacade
setOptions
in class FTPServerFacade
public void setTCPBufferSize(int size) throws ClientException
ClientException
protected void transferAbort()
transferAbort
in class FTPServerFacade
public void setActive(HostPort hp) throws UnknownHostException, ClientException, IOException
FTPServerFacade
setActive
in class FTPServerFacade
UnknownHostException
ClientException
IOException
public void setStripedActive(HostPortList hpl) throws UnknownHostException, IOException
UnknownHostException
IOException
public HostPort setPassive(int port, int queue) throws IOException
FTPServerFacade
setPassive
in class FTPServerFacade
port
- required server port; can be set to ANY_PORTqueue
- max size of queue of awaiting new connection
requestsIOException
public HostPortList setStripedPassive() throws IOException
IOException
public HostPortList setStripedPassive(int port, int queue) throws IOException
IOException
public void store(DataSink sink)
store
in class FTPServerFacade
sink
- source of datapublic void retrieve(DataSource source)
retrieve
in class FTPServerFacade
source
- source of datapublic void abort() throws IOException
FTPServerFacade
abort
in class FTPServerFacade
IOException
public void close() throws IOException
close
in class FTPServerFacade
IOException
public static Socket authenticate(Socket simpleSocket, boolean isClientSocket, GSSCredential credential, int protection, DataChannelAuthentication dcau) throws Exception
Exception
protected TransferContext createTransferContext()
createTransferContext
in class FTPServerFacade
public TransferThreadManager createTransferThreadManager()
Copyright © 2016. All rights reserved.