| java.lang.Object org.apache.mina.common.AbstractPollingIoProcessor
AbstractPollingIoProcessor | abstract public class AbstractPollingIoProcessor implements IoProcessor<T>(Code) | | An abstract implementation of
IoProcessor which helps
transport developers to write an
IoProcessor easily.
author: The Apache MINA Project (dev@mina.apache.org) version: $Rev: 627803 $, $Date: 2008-02-14 10:03:14 -0700 (Thu, 14 Feb 2008) $ |
Inner Class :protected static enum SessionState | |
AbstractPollingIoProcessor | protected AbstractPollingIoProcessor(Executor executor)(Code) | | |
add | final public void add(T session)(Code) | | |
dispose | final public void dispose()(Code) | | |
flush | final public void flush(T session)(Code) | | |
isDisposed | final public boolean isDisposed()(Code) | | |
isDisposing | final public boolean isDisposing()(Code) | | |
isInterestedInRead | abstract protected boolean isInterestedInRead(T session)(Code) | | is this session registered for reading
Parameters: session - the session queried true is registered for reading |
isInterestedInWrite | abstract protected boolean isInterestedInWrite(T session)(Code) | | is this session registered for writing
Parameters: session - the session queried true is registered for writing |
isReadable | abstract protected boolean isReadable(T session)(Code) | | Is the session ready for reading
Parameters: session - the session queried true is ready, false if not ready |
isWritable | abstract protected boolean isWritable(T session)(Code) | | Is the session ready for writing
Parameters: session - the session queried true is ready, false if not ready |
remove | final public void remove(T session)(Code) | | |
select | abstract protected boolean select(int timeout) throws Exception(Code) | | poll those sessions for the given timeout
Parameters: timeout - milliseconds before the call timeout if no event appear true if at least a session is ready for read or for write throws: Exception - if some low level IO error occurs |
selectedSessions | abstract protected Iterator<T> selectedSessions()(Code) | | |
setInterestedInRead | abstract protected void setInterestedInRead(T session, boolean interested) throws Exception(Code) | | register a session for reading
Parameters: session - the session registered Parameters: interested - true for registering, false for removing |
setInterestedInWrite | abstract protected void setInterestedInWrite(T session, boolean interested) throws Exception(Code) | | register a session for writing
Parameters: session - the session registered Parameters: interested - true for registering, false for removing |
state | abstract protected SessionState state(T session)(Code) | | |
updateTrafficMask | final public void updateTrafficMask(T session)(Code) | | |
wakeup | abstract protected void wakeup()(Code) | | |
|
|