Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
2.0.4
Description
class : org.apache.mina.core.polling.AbstractPollingIoAcceptor
Method:private void processHandles(Iterator<H> handles) throws Exception
/**
- This method will process new sessions for the Worker class. All
- keys that have had their status updates as per the Selector.selectedKeys()
- method will be processed here. Only keys that are ready to accept
- connections are handled here.
- <p/>
- Session objects are created by making new instances of SocketSessionImpl
- and passing the session object to the SocketIoProcessor class.
*/
@SuppressWarnings("unchecked")
private void processHandles(Iterator<H> handles) throws Exception {
while (handles.hasNext()) {
H handle = handles.next();
handles.remove();
// Associates a new created connection to a processor,
// and get back a session
S session = accept(processor, handle);
if (session == null)
{ break; } initSession(session, null, null);
// add the session to the SocketIoProcessor
session.getProcessor().add(session);
}
}
Question: break? continue?