public class UdpKernel extends AbstractKernel
Modifier and Type | Class and Description |
---|---|
protected class |
UdpKernel.HostThread |
protected class |
UdpKernel.MessageWriter |
EVENTS_PENDING
Constructor and Description |
---|
UdpKernel(java.net.InetAddress host,
int port) |
UdpKernel(java.net.InetSocketAddress address) |
UdpKernel(int port) |
Modifier and Type | Method and Description |
---|---|
void |
broadcast(Filter<? super Endpoint> filter,
java.nio.ByteBuffer data,
boolean reliable,
boolean copy)
Dispatches the data to all endpoints managed by the
kernel.
|
protected void |
closeEndpoint(UdpEndpoint p)
Called by the endpoints when they need to be closed.
|
protected UdpKernel.HostThread |
createHostThread() |
protected void |
enqueueWrite(Endpoint endpoint,
java.net.DatagramPacket packet) |
protected Endpoint |
getEndpoint(java.net.SocketAddress address,
boolean create) |
void |
initialize()
Initializes the kernel and starts any internal processing.
|
protected void |
newData(java.net.DatagramPacket packet) |
void |
terminate()
Gracefully terminates the kernel and stops any internal
daemon processing.
|
addEnvelope, addEvent, hasEnvelopes, nextEndpointId, nextEvent, read, reportError, wakeupReader
public UdpKernel(java.net.InetAddress host, int port)
public UdpKernel(int port) throws java.io.IOException
java.io.IOException
public UdpKernel(java.net.InetSocketAddress address)
protected UdpKernel.HostThread createHostThread()
public void initialize()
Kernel
public void terminate() throws java.lang.InterruptedException
Kernel
java.lang.InterruptedException
public void broadcast(Filter<? super Endpoint> filter, java.nio.ByteBuffer data, boolean reliable, boolean copy)
protected Endpoint getEndpoint(java.net.SocketAddress address, boolean create)
protected void closeEndpoint(UdpEndpoint p) throws java.io.IOException
java.io.IOException
protected void newData(java.net.DatagramPacket packet)
protected void enqueueWrite(Endpoint endpoint, java.net.DatagramPacket packet)