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, wakeupReaderpublic UdpKernel(java.net.InetAddress host,
                 int port)
public UdpKernel(int port)
          throws java.io.IOException
java.io.IOExceptionpublic UdpKernel(java.net.InetSocketAddress address)
protected UdpKernel.HostThread createHostThread()
public void initialize()
Kernelpublic void terminate()
               throws java.lang.InterruptedException
Kerneljava.lang.InterruptedExceptionpublic 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.IOExceptionprotected void newData(java.net.DatagramPacket packet)
protected void enqueueWrite(Endpoint endpoint, java.net.DatagramPacket packet)