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, unblockServerprotected 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)
FTPServerFacadesetOptions in class FTPServerFacadepublic void setTCPBufferSize(int size)
throws ClientException
ClientExceptionprotected void transferAbort()
transferAbort in class FTPServerFacadepublic void setActive(HostPort hp) throws UnknownHostException, ClientException, IOException
FTPServerFacadesetActive in class FTPServerFacadeUnknownHostExceptionClientExceptionIOExceptionpublic void setStripedActive(HostPortList hpl) throws UnknownHostException, IOException
UnknownHostExceptionIOExceptionpublic HostPort setPassive(int port, int queue) throws IOException
FTPServerFacadesetPassive in class FTPServerFacadeport - required server port; can be set to ANY_PORTqueue - max size of queue of awaiting new connection
requestsIOExceptionpublic HostPortList setStripedPassive() throws IOException
IOExceptionpublic HostPortList setStripedPassive(int port, int queue) throws IOException
IOExceptionpublic void store(DataSink sink)
store in class FTPServerFacadesink - source of datapublic void retrieve(DataSource source)
retrieve in class FTPServerFacadesource - source of datapublic void abort()
throws IOException
FTPServerFacadeabort in class FTPServerFacadeIOExceptionpublic void close()
throws IOException
close in class FTPServerFacadeIOExceptionpublic static Socket authenticate(Socket simpleSocket, boolean isClientSocket, GSSCredential credential, int protection, DataChannelAuthentication dcau) throws Exception
Exceptionprotected TransferContext createTransferContext()
createTransferContext in class FTPServerFacadepublic TransferThreadManager createTransferThreadManager()
Copyright © 2015. All rights reserved.