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 AbstractIoAcceptor

AbstractIoAcceptor.AcceptorOperationFuture

Nested classes/interfaces inherited from class AbstractIoService

AbstractIoService.ServiceOperationFuture

Field Summary

Fields

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

Fields inherited from class AbstractIoAcceptor

bindLock

Fields inherited from class AbstractIoService

disposalLock, LOGGER, sessionConfig

Constructor Summary

Constructors

Modifier	Constructor	Description
	NioDatagramAcceptor()	Creates a new instance.
	NioDatagramAcceptor(Executor executor)	Creates a new instance.
private	NioDatagramAcceptor(IoSessionConfig sessionConfig, 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 final Set<SocketAddress>	bindInternal(List<? extends SocketAddress> localAddresses)	Starts the acceptor, and register the given addresses
protected void	close(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)
InetSocketAddress	getDefaultLocalAddress()	Returns the default local address to bind when no argument is specified in IoAcceptor.bind() method.
InetSocketAddress	getLocalAddress()	Returns the local address which is bound currently.
DatagramSessionConfig	getSessionConfig()
final IoSessionRecycler	getSessionRecycler()
TransportMetadata	getTransportMetadata()
protected void	init()
protected boolean	isReadable(DatagramChannel handle)
protected boolean	isWritable(DatagramChannel handle)
protected SocketAddress	localAddress(DatagramChannel handle)
final IoSession	newSession(SocketAddress remoteAddress, 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, DatagramChannel handle, SocketAddress remoteAddress)
private IoSession	newSessionWithoutLock(SocketAddress remoteAddress, SocketAddress localAddress)
private void	notifyIdleSessions(long currentTime)
protected DatagramChannel	open(SocketAddress localAddress)
private void	processReadySessions(Set<SelectionKey> handles)
private void	readHandle(DatagramChannel handle)
protected SocketAddress	receive(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 Set<SelectionKey>	selectedHandles()
protected int	send(NioSession session, IoBuffer buffer, SocketAddress remoteAddress)
void	setDefaultLocalAddress(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)
final void	setSessionRecycler(IoSessionRecycler sessionRecycler)	Sets the IoSessionRecycler for this service.
private void	startupAcceptor()	Starts the inner Acceptor thread.
protected final void	unbind0(List<? extends 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 AbstractIoAcceptor

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

Methods inherited from class 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 Object

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

Methods inherited from interface IoAcceptor

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

Methods inherited from interface IoProcessor

dispose, isDisposed, isDisposing

Methods inherited from interface IoService

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

Field Details

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 Semaphore lock

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

registerQueue

private final Queue<AbstractIoAcceptor.AcceptorOperationFuture> registerQueue

A queue used to store the list of pending Binds

cancelQueue

private final Queue<AbstractIoAcceptor.AcceptorOperationFuture> cancelQueue

flushingSessions

private final Queue<NioSession> flushingSessions

boundHandles

private final Map<SocketAddress, 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 Selector selector

The Selector used by this acceptor

Constructor Details

NioDatagramAcceptor

public NioDatagramAcceptor()

Creates a new instance.

NioDatagramAcceptor

public NioDatagramAcceptor(Executor executor)

Creates a new instance.

Parameters:

executor - The executor to use

NioDatagramAcceptor

private NioDatagramAcceptor(IoSessionConfig sessionConfig,
 Executor executor)

Creates a new instance.

Method Details

registerHandles

private int registerHandles()

processReadySessions

private void processReadySessions(Set<SelectionKey> handles)

scheduleFlush

private boolean scheduleFlush(NioSession session)

readHandle

private void readHandle(DatagramChannel handle)
                 throws Exception

Throws:

Exception

newSessionWithoutLock

private IoSession newSessionWithoutLock(SocketAddress remoteAddress,
 SocketAddress localAddress)
                                 throws Exception

Throws:

Exception

flushSessions

private void flushSessions(long currentTime)

flush

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

Throws:

Exception

unregisterHandles

private int unregisterHandles()

notifyIdleSessions

private void notifyIdleSessions(long currentTime)

startupAcceptor

private void startupAcceptor()
                      throws InterruptedException

Starts the inner Acceptor thread.

Throws:

InterruptedException

init

protected void init()
             throws Exception

Throws:

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 Set<SocketAddress> bindInternal(List<? extends SocketAddress> localAddresses)
                                         throws 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:

Exception - If the bind failed

close

protected void close(DatagramChannel handle)
              throws Exception

Throws:

Exception

destroy

protected void destroy()
                throws Exception

Throws:

Exception

dispose0

protected void dispose0()
                 throws 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:

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 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 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 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(DatagramChannel handle)

isWritable

protected boolean isWritable(DatagramChannel handle)

localAddress

protected SocketAddress localAddress(DatagramChannel handle)
                              throws Exception

Throws:

Exception

newSession

protected NioSession newSession(IoProcessor<NioSession> processor,
 DatagramChannel handle,
 SocketAddress remoteAddress)

newSession

public final IoSession newSession(SocketAddress remoteAddress,
 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 DatagramChannel open(SocketAddress localAddress)
                        throws Exception

Throws:

Exception

receive

protected SocketAddress receive(DatagramChannel handle,
 IoBuffer buffer)
                         throws Exception

Throws:

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 Exception

Throws:

Exception

select

protected int select(long timeout)
              throws Exception

Throws:

Exception

selectedHandles

protected Set<SelectionKey> selectedHandles()

send

protected int send(NioSession session,
 IoBuffer buffer,
 SocketAddress remoteAddress)
            throws Exception

Throws:

Exception

setDefaultLocalAddress

public void setDefaultLocalAddress(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 Exception

Throws:

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(List<? extends SocketAddress> localAddresses)
                      throws Exception

Implement this method to perform the actual unbind operation.

Specified by:

unbind0 in class AbstractIoAcceptor

Parameters:

localAddresses - The address to unbind from

Throws:

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