version 2.0.4
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:
if (session == null) {
break;
}
break? continue?
2012-02-10
maojk
