org.apache.mina.core.polling

Class AbstractPollingIoAcceptor.Acceptor

java.lang.Object

org.apache.mina.core.polling.AbstractPollingIoAcceptor.Acceptor

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

AbstractPollingIoAcceptor<S extends AbstractIoSession,H>

private class AbstractPollingIoAcceptor.Acceptor
extends java.lang.Object
implements java.lang.Runnable

This class is called by the startupAcceptor() method and is placed into a NamePreservingRunnable class. It's a thread accepting incoming connections from clients. The loop is stopped when all the bound handlers are unbound.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Acceptor()

Method Summary

Modifier and Type	Method and Description
private void	processHandles(java.util.Iterator<H> handles) This method will process new sessions for the Worker class.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Acceptor

private Acceptor()

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

processHandles

private void processHandles(java.util.Iterator<H> handles)
                     throws java.lang.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.

Session objects are created by making new instances of SocketSessionImpl and passing the session object to the SocketIoProcessor class.

Throws:

java.lang.Exception