Package org.globus.ftp.vanilla
Class FTPServerFacade.LocalControlChannel
java.lang.Object
org.globus.ftp.vanilla.BasicClientControlChannel
org.globus.ftp.vanilla.FTPServerFacade.LocalControlChannel
- All Implemented Interfaces:
BasicServerControlChannel
- Enclosing class:
- FTPServerFacade
protected class FTPServerFacade.LocalControlChannel
extends BasicClientControlChannel
implements BasicServerControlChannel
This inner class represents a local control channel.
One process can write replies using BasicServerControlChannel
interface, and the other can read replies using
BasicClientControlChannel interface.
-
Field Summary
Fields inherited from class org.globus.ftp.vanilla.BasicClientControlChannel
WAIT_FOREVER
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.globus.ftp.vanilla.BasicClientControlChannel
waitFor
-
Constructor Details
-
LocalControlChannel
public LocalControlChannel()
-
-
Method Details
-
push
-
pop
- Throws:
InterruptedException
-
ready
public boolean ready() -
getReplyCount
public int getReplyCount()- Specified by:
getReplyCount
in interfaceBasicServerControlChannel
- Returns:
- number of replies sent so far
-
resetReplyCount
public void resetReplyCount()Description copied from interface:BasicServerControlChannel
set reply count to 0. If this function is used consequently at the beginning of each transfer, then reply count will always indicate number of messages of last transfer.- Specified by:
resetReplyCount
in interfaceBasicServerControlChannel
-
read
- Specified by:
read
in classBasicClientControlChannel
- Throws:
IOException
FTPReplyParseException
ServerException
-
write
Description copied from interface:BasicServerControlChannel
write reply to the control channel- Specified by:
write
in interfaceBasicServerControlChannel
-
waitFor
public void waitFor(Flag aborted, int ioDelay, int maxWait) throws ServerException, IOException, InterruptedException Description copied from class:BasicClientControlChannel
Block until reply is waiting in the control channel, or after timeout (maxWait), or when flag changes to true. If maxWait == WAIT_FOREVER, do not timeout.- Specified by:
waitFor
in classBasicClientControlChannel
maxWait
- timeout in miliseconds- Throws:
ServerException
IOException
InterruptedException
-
abortTransfer
public void abortTransfer()- Specified by:
abortTransfer
in classBasicClientControlChannel
-