|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.mina.common.AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
org.apache.mina.transport.socket.apr.AprIoProcessor
public final class AprIoProcessor
The class in charge of processing socket level IO events for the AprSocketConnector
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.mina.common.AbstractPollingIoProcessor |
---|
AbstractPollingIoProcessor.SessionState |
Constructor Summary | |
---|---|
AprIoProcessor(Executor executor)
|
Method Summary | |
---|---|
protected Iterator<org.apache.mina.transport.socket.apr.AprSession> |
allSessions()
|
protected void |
destroy(org.apache.mina.transport.socket.apr.AprSession session)
|
protected void |
dispose0()
|
protected void |
init(org.apache.mina.transport.socket.apr.AprSession session)
|
protected boolean |
isInterestedInRead(org.apache.mina.transport.socket.apr.AprSession session)
is this session registered for reading |
protected boolean |
isInterestedInWrite(org.apache.mina.transport.socket.apr.AprSession session)
is this session registered for writing |
protected boolean |
isReadable(org.apache.mina.transport.socket.apr.AprSession session)
Is the session ready for reading |
protected boolean |
isWritable(org.apache.mina.transport.socket.apr.AprSession session)
Is the session ready for writing |
protected int |
read(org.apache.mina.transport.socket.apr.AprSession session,
IoBuffer buffer)
|
protected boolean |
select(int timeout)
poll those sessions for the given timeout |
protected Iterator<org.apache.mina.transport.socket.apr.AprSession> |
selectedSessions()
|
protected void |
setInterestedInRead(org.apache.mina.transport.socket.apr.AprSession session,
boolean value)
register a session for reading |
protected void |
setInterestedInWrite(org.apache.mina.transport.socket.apr.AprSession session,
boolean value)
register a session for writing |
protected AbstractPollingIoProcessor.SessionState |
state(org.apache.mina.transport.socket.apr.AprSession session)
|
protected int |
transferFile(org.apache.mina.transport.socket.apr.AprSession session,
FileRegion region,
int length)
|
protected void |
wakeup()
|
protected int |
write(org.apache.mina.transport.socket.apr.AprSession session,
IoBuffer buf,
int length)
|
Methods inherited from class org.apache.mina.common.AbstractPollingIoProcessor |
---|
add, dispose, flush, isDisposed, isDisposing, remove, updateTrafficMask |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AprIoProcessor(Executor executor)
Method Detail |
---|
protected void dispose0()
dispose0
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
protected boolean select(int timeout) throws Exception
AbstractPollingIoProcessor
select
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
timeout
- milliseconds before the call timeout if no event appear
Exception
- if some low level IO error occursprotected void wakeup()
wakeup
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
protected Iterator<org.apache.mina.transport.socket.apr.AprSession> allSessions()
allSessions
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
protected Iterator<org.apache.mina.transport.socket.apr.AprSession> selectedSessions()
selectedSessions
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
protected void init(org.apache.mina.transport.socket.apr.AprSession session) throws Exception
init
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
Exception
protected void destroy(org.apache.mina.transport.socket.apr.AprSession session) throws Exception
destroy
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
Exception
protected AbstractPollingIoProcessor.SessionState state(org.apache.mina.transport.socket.apr.AprSession session)
state
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
protected boolean isReadable(org.apache.mina.transport.socket.apr.AprSession session)
AbstractPollingIoProcessor
isReadable
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
session
- the session queried
protected boolean isWritable(org.apache.mina.transport.socket.apr.AprSession session)
AbstractPollingIoProcessor
isWritable
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
session
- the session queried
protected boolean isInterestedInRead(org.apache.mina.transport.socket.apr.AprSession session)
AbstractPollingIoProcessor
isInterestedInRead
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
session
- the session queried
protected boolean isInterestedInWrite(org.apache.mina.transport.socket.apr.AprSession session)
AbstractPollingIoProcessor
isInterestedInWrite
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
session
- the session queried
protected void setInterestedInRead(org.apache.mina.transport.socket.apr.AprSession session, boolean value) throws Exception
AbstractPollingIoProcessor
setInterestedInRead
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
session
- the session registeredvalue
- true for registering, false for removing
Exception
protected void setInterestedInWrite(org.apache.mina.transport.socket.apr.AprSession session, boolean value) throws Exception
AbstractPollingIoProcessor
setInterestedInWrite
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
session
- the session registeredvalue
- true for registering, false for removing
Exception
protected int read(org.apache.mina.transport.socket.apr.AprSession session, IoBuffer buffer) throws Exception
read
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
Exception
protected int write(org.apache.mina.transport.socket.apr.AprSession session, IoBuffer buf, int length) throws Exception
write
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
Exception
protected int transferFile(org.apache.mina.transport.socket.apr.AprSession session, FileRegion region, int length) throws Exception
transferFile
in class AbstractPollingIoProcessor<org.apache.mina.transport.socket.apr.AprSession>
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |