Package org.apache.mina.transport.socket.nio

Class NioDatagramAcceptor

java.lang.Object

org.apache.mina.core.service.AbstractIoService

org.apache.mina.core.service.AbstractIoAcceptor

org.apache.mina.transport.socket.nio.NioDatagramAcceptor

All Implemented Interfaces:

IoAcceptor, IoProcessor<NioSession>, IoService, DatagramAcceptor

public final class NioDatagramAcceptor
extends AbstractIoAcceptor
implements DatagramAcceptor, IoProcessor<NioSession>

IoAcceptor for datagram transport (UDP/IP).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	NioDatagramAcceptor.Acceptor	This private class is used to accept incoming connection from clients.

Nested classes/interfaces inherited from class org.apache.mina.core.service.AbstractIoAcceptor

AbstractIoAcceptor.AcceptorOperationFuture

Nested classes/interfaces inherited from class org.apache.mina.core.service.AbstractIoService

AbstractIoService.ServiceOperationFuture

Field Summary

Fields

Modifier and Type	Field	Description
private NioDatagramAcceptor.Acceptor	acceptor	The thread responsible of accepting incoming requests
private java.util.Map<java.net.SocketAddress,java.nio.channels.DatagramChannel>	boundHandles
private java.util.Queue<AbstractIoAcceptor.AcceptorOperationFuture>	cancelQueue
private static IoSessionRecycler	DEFAULT_RECYCLER	A session recycler that is used to retrieve an existing session, unless it's too old.
private AbstractIoService.ServiceOperationFuture	disposalFuture
private java.util.Queue<NioSession>	flushingSessions
private long	lastIdleCheckTime
private java.util.concurrent.Semaphore	lock	A lock used to protect the selector to be waked up before it's created
private java.util.Queue<AbstractIoAcceptor.AcceptorOperationFuture>	registerQueue	A queue used to store the list of pending Binds
private static long	SELECT_TIMEOUT	A timeout used for the select, as we need to get out to deal with idle sessions
private boolean	selectable
private java.nio.channels.Selector	selector	The Selector used by this acceptor
private IoSessionRecycler	sessionRecycler

Fields inherited from class org.apache.mina.core.service.AbstractIoAcceptor

bindLock

Fields inherited from class org.apache.mina.core.service.AbstractIoService

disposalLock, LOGGER, sessionConfig

Constructor Summary

Constructors

Modifier	Constructor	Description
	NioDatagramAcceptor()	Creates a new instance.
	NioDatagramAcceptor(java.util.concurrent.Executor executor)	Creates a new instance.
private	NioDatagramAcceptor(IoSessionConfig sessionConfig, java.util.concurrent.Executor executor)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
void	add(NioSession session)	Adds the specified session to the I/O processor so that the I/O processor starts to perform any I/O operations related with the session.
protected java.util.Set<java.net.SocketAddress>	bindInternal(java.util.List<? extends java.net.SocketAddress> localAddresses)	Starts the acceptor, and register the given addresses
protected void	close(java.nio.channels.DatagramChannel handle)
protected void	destroy()
protected void	dispose0()	Implement this method to release any acquired resources.
void	flush(NioSession session)	Flushes the internal write request queue of the specified session.
private boolean	flush(NioSession session, long currentTime)
private void	flushSessions(long currentTime)
java.net.InetSocketAddress	getDefaultLocalAddress()	Returns the default local address to bind when no argument is specified in IoAcceptor.bind() method.
java.net.InetSocketAddress	getLocalAddress()	Returns the local address which is bound currently.
DatagramSessionConfig	getSessionConfig()
IoSessionRecycler	getSessionRecycler()
TransportMetadata	getTransportMetadata()
protected void	init()
protected boolean	isReadable(java.nio.channels.DatagramChannel handle)
protected boolean	isWritable(java.nio.channels.DatagramChannel handle)
protected java.net.SocketAddress	localAddress(java.nio.channels.DatagramChannel handle)
IoSession	newSession(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)	(Optional) Returns an IoSession that is bound to the specified localAddress and the specified remoteAddress which reuses the local address that is already bound by this service.
protected NioSession	newSession(IoProcessor<NioSession> processor, java.nio.channels.DatagramChannel handle, java.net.SocketAddress remoteAddress)
private IoSession	newSessionWithoutLock(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
private void	notifyIdleSessions(long currentTime)
protected java.nio.channels.DatagramChannel	open(java.net.SocketAddress localAddress)
private void	processReadySessions(java.util.Set<java.nio.channels.SelectionKey> handles)
private void	readHandle(java.nio.channels.DatagramChannel handle)
protected java.net.SocketAddress	receive(java.nio.channels.DatagramChannel handle, IoBuffer buffer)
private int	registerHandles()
void	remove(NioSession session)	Removes and closes the specified session from the I/O processor so that the I/O processor closes the connection associated with the session and releases any other related resources.
private boolean	scheduleFlush(NioSession session)
protected int	select()
protected int	select(long timeout)
protected java.util.Set<java.nio.channels.SelectionKey>	selectedHandles()
protected int	send(NioSession session, IoBuffer buffer, java.net.SocketAddress remoteAddress)
void	setDefaultLocalAddress(java.net.InetSocketAddress localAddress)	Sets the default local InetSocketAddress to bind when no argument is specified in IoAcceptor.bind() method.
protected void	setInterestedInWrite(NioSession session, boolean isInterested)
void	setSessionRecycler(IoSessionRecycler sessionRecycler)	Sets the IoSessionRecycler for this service.
private void	startupAcceptor()	Starts the inner Acceptor thread.
protected void	unbind0(java.util.List<? extends java.net.SocketAddress> localAddresses)	Implement this method to perform the actual unbind operation.
private int	unregisterHandles()
void	updateTrafficControl(NioSession session)	Controls the traffic of the specified session depending of the IoSession.isReadSuspended() and IoSession.isWriteSuspended() flags
protected void	wakeup()
void	write(NioSession session, WriteRequest writeRequest)	Writes the WriteRequest for the specified session.

Methods inherited from class org.apache.mina.core.service.AbstractIoAcceptor

bind, bind, bind, bind, bind, getDefaultLocalAddresses, getLocalAddresses, isCloseOnDeactivation, setCloseOnDeactivation, setDefaultLocalAddress, setDefaultLocalAddresses, setDefaultLocalAddresses, setDefaultLocalAddresses, toString, unbind, unbind, unbind, unbind

Methods inherited from class org.apache.mina.core.service.AbstractIoService

addListener, broadcast, dispose, dispose, executeWorker, executeWorker, finishSessionInitialization0, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getListeners, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, initSession, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.mina.core.service.IoAcceptor

bind, bind, bind, bind, bind, getDefaultLocalAddresses, getLocalAddresses, isCloseOnDeactivation, setCloseOnDeactivation, setDefaultLocalAddress, setDefaultLocalAddresses, setDefaultLocalAddresses, setDefaultLocalAddresses, unbind, unbind, unbind, unbind

Methods inherited from interface org.apache.mina.core.service.IoProcessor

dispose, isDisposed, isDisposing

Methods inherited from interface org.apache.mina.core.service.IoService

addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

Field Detail

DEFAULT_RECYCLER

private static final IoSessionRecycler DEFAULT_RECYCLER

A session recycler that is used to retrieve an existing session, unless it's too old.

SELECT_TIMEOUT

private static final long SELECT_TIMEOUT

A timeout used for the select, as we need to get out to deal with idle sessions

See Also:

Constant Field Values

lock

private final java.util.concurrent.Semaphore lock

A lock used to protect the selector to be waked up before it's created

registerQueue

private final java.util.Queue<AbstractIoAcceptor.AcceptorOperationFuture> registerQueue

A queue used to store the list of pending Binds

cancelQueue

private final java.util.Queue<AbstractIoAcceptor.AcceptorOperationFuture> cancelQueue

flushingSessions

private final java.util.Queue<NioSession> flushingSessions

boundHandles

private final java.util.Map<java.net.SocketAddress,java.nio.channels.DatagramChannel> boundHandles

sessionRecycler

private IoSessionRecycler sessionRecycler

disposalFuture

private final AbstractIoService.ServiceOperationFuture disposalFuture

selectable

private volatile boolean selectable

acceptor

private NioDatagramAcceptor.Acceptor acceptor

The thread responsible of accepting incoming requests

lastIdleCheckTime

private long lastIdleCheckTime

selector

private volatile java.nio.channels.Selector selector

The Selector used by this acceptor

Constructor Detail

NioDatagramAcceptor

public NioDatagramAcceptor()

Creates a new instance.

NioDatagramAcceptor

public NioDatagramAcceptor(java.util.concurrent.Executor executor)

Creates a new instance.

Parameters:

executor - The executor to use

NioDatagramAcceptor

private NioDatagramAcceptor(IoSessionConfig sessionConfig,
                            java.util.concurrent.Executor executor)

Creates a new instance.

Method Detail

registerHandles

private int registerHandles()

processReadySessions

private void processReadySessions(java.util.Set<java.nio.channels.SelectionKey> handles)

scheduleFlush

private boolean scheduleFlush(NioSession session)

readHandle

private void readHandle(java.nio.channels.DatagramChannel handle)
                 throws java.lang.Exception

Throws:

java.lang.Exception

newSessionWithoutLock

private IoSession newSessionWithoutLock(java.net.SocketAddress remoteAddress,
                                        java.net.SocketAddress localAddress)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

flushSessions

private void flushSessions(long currentTime)

flush

private boolean flush(NioSession session,
                      long currentTime)
               throws java.lang.Exception

Throws:

java.lang.Exception

unregisterHandles

private int unregisterHandles()

notifyIdleSessions

private void notifyIdleSessions(long currentTime)

startupAcceptor

private void startupAcceptor()
                      throws java.lang.InterruptedException

Starts the inner Acceptor thread.

Throws:

java.lang.InterruptedException

init

protected void init()
             throws java.lang.Exception

Throws:

java.lang.Exception

add

public void add(NioSession session)

Adds the specified session to the I/O processor so that the I/O processor starts to perform any I/O operations related with the session.

Specified by:

add in interface IoProcessor<NioSession>

Parameters:

session - The added session

bindInternal

protected final java.util.Set<java.net.SocketAddress> bindInternal(java.util.List<? extends java.net.SocketAddress> localAddresses)
                                                            throws java.lang.Exception

Starts the acceptor, and register the given addresses

Specified by:

bindInternal in class AbstractIoAcceptor

Parameters:

localAddresses - The address to bind to

Returns:

the Set of the local addresses which is bound actually

Throws:

java.lang.Exception - If the bind failed

close

protected void close(java.nio.channels.DatagramChannel handle)
              throws java.lang.Exception

Throws:

java.lang.Exception

destroy

protected void destroy()
                throws java.lang.Exception

Throws:

java.lang.Exception

dispose0

protected void dispose0()
                 throws java.lang.Exception

Implement this method to release any acquired resources. This method is invoked only once by AbstractIoService.dispose().

Specified by:

dispose0 in class AbstractIoService

Throws:

java.lang.Exception - If the dispose failed

flush

public void flush(NioSession session)

Flushes the internal write request queue of the specified session.

Specified by:

flush in interface IoProcessor<NioSession>

Parameters:

session - The session we want the message to be written

getDefaultLocalAddress

public java.net.InetSocketAddress getDefaultLocalAddress()

Description copied from class: AbstractIoAcceptor

Returns the default local address to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local address is specified. If more than one address are set, only one of them will be returned, but it's not necessarily the firstly specified address in IoAcceptor.setDefaultLocalAddresses(List).

Specified by:

getDefaultLocalAddress in interface DatagramAcceptor

Specified by:

getDefaultLocalAddress in interface IoAcceptor

Overrides:

getDefaultLocalAddress in class AbstractIoAcceptor

Returns:

The default bound LocalAddress

getLocalAddress

public java.net.InetSocketAddress getLocalAddress()

Description copied from class: AbstractIoAcceptor

Returns the local address which is bound currently. If more than one address are bound, only one of them will be returned, but it's not necessarily the firstly bound address.

Specified by:

getLocalAddress in interface DatagramAcceptor

Specified by:

getLocalAddress in interface IoAcceptor

Overrides:

getLocalAddress in class AbstractIoAcceptor

Returns:

The bound LocalAddress

getSessionConfig

public DatagramSessionConfig getSessionConfig()

Specified by:

getSessionConfig in interface DatagramAcceptor

Specified by:

getSessionConfig in interface IoService

Returns:

the default Datagram configuration of the new IoSessions created by this service.

getSessionRecycler

public final IoSessionRecycler getSessionRecycler()

Specified by:

getSessionRecycler in interface DatagramAcceptor

Returns:

the IoSessionRecycler for this service.

getTransportMetadata

public TransportMetadata getTransportMetadata()

Specified by:

getTransportMetadata in interface IoService

Returns:

the TransportMetadata that this service runs on.

isReadable

protected boolean isReadable(java.nio.channels.DatagramChannel handle)

isWritable

protected boolean isWritable(java.nio.channels.DatagramChannel handle)

localAddress

protected java.net.SocketAddress localAddress(java.nio.channels.DatagramChannel handle)
                                       throws java.lang.Exception

Throws:

java.lang.Exception

newSession

protected NioSession newSession(IoProcessor<NioSession> processor,
                                java.nio.channels.DatagramChannel handle,
                                java.net.SocketAddress remoteAddress)

newSession

public final IoSession newSession(java.net.SocketAddress remoteAddress,
                                  java.net.SocketAddress localAddress)

(Optional) Returns an IoSession that is bound to the specified localAddress and the specified remoteAddress which reuses the local address that is already bound by this service.

This operation is optional. Please throw UnsupportedOperationException if the transport type doesn't support this operation. This operation is usually implemented for connectionless transport types.

Specified by:

newSession in interface IoAcceptor

Parameters:

remoteAddress - The remote address bound to the service

localAddress - The local address the session will be bound to

Returns:

The session bound to the the given localAddress and remote address

open

protected java.nio.channels.DatagramChannel open(java.net.SocketAddress localAddress)
                                          throws java.lang.Exception

Throws:

java.lang.Exception

receive

protected java.net.SocketAddress receive(java.nio.channels.DatagramChannel handle,
                                         IoBuffer buffer)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

remove

public void remove(NioSession session)

Removes and closes the specified session from the I/O processor so that the I/O processor closes the connection associated with the session and releases any other related resources.

Specified by:

remove in interface IoProcessor<NioSession>

Parameters:

session - The session to be removed

select

protected int select()
              throws java.lang.Exception

Throws:

java.lang.Exception

select

protected int select(long timeout)
              throws java.lang.Exception

Throws:

java.lang.Exception

selectedHandles

protected java.util.Set<java.nio.channels.SelectionKey> selectedHandles()

send

protected int send(NioSession session,
                   IoBuffer buffer,
                   java.net.SocketAddress remoteAddress)
            throws java.lang.Exception

Throws:

java.lang.Exception

setDefaultLocalAddress

public void setDefaultLocalAddress(java.net.InetSocketAddress localAddress)

Description copied from interface: DatagramAcceptor

Sets the default local InetSocketAddress to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local InetSocketAddress is specified. This method overrides the IoAcceptor.setDefaultLocalAddress(java.net.SocketAddress) method.

Specified by:

setDefaultLocalAddress in interface DatagramAcceptor

Parameters:

localAddress - The local address

setInterestedInWrite

protected void setInterestedInWrite(NioSession session,
                                    boolean isInterested)
                             throws java.lang.Exception

Throws:

java.lang.Exception

setSessionRecycler

public final void setSessionRecycler(IoSessionRecycler sessionRecycler)

Description copied from interface: DatagramAcceptor

Sets the IoSessionRecycler for this service.

Specified by:

setSessionRecycler in interface DatagramAcceptor

Parameters:

sessionRecycler - null to use the default recycler

unbind0

protected final void unbind0(java.util.List<? extends java.net.SocketAddress> localAddresses)
                      throws java.lang.Exception

Implement this method to perform the actual unbind operation.

Specified by:

unbind0 in class AbstractIoAcceptor

Parameters:

localAddresses - The address to unbind from

Throws:

java.lang.Exception - If the unbind failed

updateTrafficControl

public void updateTrafficControl(NioSession session)

Controls the traffic of the specified session depending of the IoSession.isReadSuspended() and IoSession.isWriteSuspended() flags

Specified by:

updateTrafficControl in interface IoProcessor<NioSession>

Parameters:

session - The session to be updated

wakeup

protected void wakeup()

write

public void write(NioSession session,
                  WriteRequest writeRequest)

Writes the WriteRequest for the specified session.

Specified by:

write in interface IoProcessor<NioSession>

Parameters:

session - The session we want the message to be written

writeRequest - the WriteRequest to write