Class DatagramChannelEndPoint

java.lang.Object

org.eclipse.jetty.io.IdleTimeout

org.eclipse.jetty.io.AbstractEndPoint

org.eclipse.jetty.io.SelectableChannelEndPoint

org.eclipse.jetty.io.DatagramChannelEndPoint

All Implemented Interfaces:

Closeable, AutoCloseable, EndPoint, ManagedSelector.Selectable

public class DatagramChannelEndPoint
extends SelectableChannelEndPoint

An EndPoint implementation based on DatagramChannel.

Nested Class Summary

Nested classes/interfaces inherited from interface EndPoint

EndPoint.Pipe, EndPoint.SslSessionData, EndPoint.Wrapper

Field Summary

Fields inherited from interface EndPoint

EOF

Constructor Summary

Constructors

Constructor	Description
DatagramChannelEndPoint(DatagramChannel channel, ManagedSelector selector, SelectionKey key, Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
DatagramChannel	getChannel()
SocketAddress	getRemoteSocketAddress()
SocketAddress	receive(ByteBuffer buffer)	Receives data into the given buffer from the returned address.
boolean	send(SocketAddress address, ByteBuffer... buffers)	Sends to the given address the data in the given buffers.
void	write(Callback callback, SocketAddress address, ByteBuffer... buffers)	Writes to the given address the data contained in the given buffers, and invokes the given callback when either all the data has been sent, or a failure occurs.

Methods inherited from class SelectableChannelEndPoint

doClose, getLocalSocketAddress, getTransport, isOpen, needsFillInterest, onClose, onIncompleteFlush, onSelected, replaceKey, toEndPointString, updateKey

Methods inherited from class AbstractEndPoint

close, close, doShutdownInput, doShutdownOutput, fillInterested, getConnection, getCreatedTimeStamp, getFillInterest, getLocalAddress, getRemoteAddress, getWriteFlusher, isFillInterested, isInputShutdown, isOutputShutdown, onClose, onIdleExpired, onOpen, reset, setConnection, shutdownInput, shutdownOutput, toConnectionString, toString, tryFillInterested, upgrade, write

Methods inherited from class IdleTimeout

checkIdleTimeout, getIdleFor, getIdleTimeout, getScheduler, notIdle, setIdleTimeout

Methods inherited from class Object

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

Methods inherited from interface EndPoint

fill, flush, getIdleTimeout, getSslSessionData, isSecure, setIdleTimeout

Constructor Details

DatagramChannelEndPoint

public DatagramChannelEndPoint(DatagramChannel channel,
 ManagedSelector selector,
 SelectionKey key,
 Scheduler scheduler)

Method Details

getChannel

public DatagramChannel getChannel()

Overrides:

getChannel in class SelectableChannelEndPoint

getRemoteSocketAddress

public SocketAddress getRemoteSocketAddress()

Specified by:

getRemoteSocketAddress in interface EndPoint

Specified by:

getRemoteSocketAddress in class AbstractEndPoint

Returns:

The remote SocketAddress to which this EndPoint is connected, or null if this EndPoint is not connected to a Socket address.

receive

public SocketAddress receive(ByteBuffer buffer)
                      throws IOException

Description copied from interface: EndPoint

Receives data into the given buffer from the returned address.

This method should be used to receive UDP data.

Parameters:

buffer - the buffer to fill with data

Returns:

the peer address that sent the data, or EndPoint.EOF

Throws:

IOException - if the receive fails

send

public boolean send(SocketAddress address,
 ByteBuffer... buffers)
             throws IOException

Description copied from interface: EndPoint

Sends to the given address the data in the given buffers.

This methods should be used to send UDP data.

Parameters:

address - the peer address to send data to

buffers - the buffers containing the data to send

Returns:

true if all the buffers have been consumed

Throws:

IOException - if the send fails

See Also:

• EndPoint.write(Callback, SocketAddress, ByteBuffer...)

write

public void write(Callback callback,
 SocketAddress address,
 ByteBuffer... buffers)
           throws WritePendingException

Description copied from interface: EndPoint

Writes to the given address the data contained in the given buffers, and invokes the given callback when either all the data has been sent, or a failure occurs.

Parameters:

callback - the callback to notify of the success or failure of the write operation

address - the peer address to send data to

buffers - the buffers containing the data to send

Throws:

WritePendingException - if a previous write was initiated but was not yet completed

See Also:

• EndPoint.send(SocketAddress, ByteBuffer...)