Package com.jme3.network.kernel.udp

Class UdpKernel

java.lang.Object

com.jme3.network.kernel.AbstractKernel

com.jme3.network.kernel.udp.UdpKernel

All Implemented Interfaces:

Kernel

public class UdpKernel
extends AbstractKernel

A Kernel implementation using UDP packets.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	UdpKernel.HostThread
protected class	UdpKernel.MessageWriter

Field Summary

Fields inherited from interface com.jme3.network.kernel.Kernel

EVENTS_PENDING

Constructor Summary

Constructors

Constructor	Description
UdpKernel(int port)
UdpKernel(InetAddress host, int port)
UdpKernel(InetSocketAddress address)

Method Summary

Modifier and Type	Method	Description
void	broadcast(Filter<? super Endpoint> filter, 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, DatagramPacket packet)
protected Endpoint	getEndpoint(SocketAddress address, boolean create)
void	initialize()	Initializes the kernel and starts any internal processing.
protected void	newData(DatagramPacket packet)
void	terminate()	Gracefully terminates the kernel and stops any internal daemon processing.

Methods inherited from class com.jme3.network.kernel.AbstractKernel

addEnvelope, addEvent, hasEnvelopes, nextEndpointId, nextEvent, read, reportError, wakeupReader

Methods inherited from class java.lang.Object

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

Constructor Details

UdpKernel

public UdpKernel(InetAddress host,
 int port)

UdpKernel

public UdpKernel(int port)
          throws IOException

Throws:

IOException

UdpKernel

public UdpKernel(InetSocketAddress address)

Method Details

createHostThread

protected UdpKernel.HostThread createHostThread()

initialize

public void initialize()

Description copied from interface: Kernel

Initializes the kernel and starts any internal processing.

terminate

public void terminate()
               throws InterruptedException

Description copied from interface: Kernel

Gracefully terminates the kernel and stops any internal daemon processing. This method will not return until all internal threads have been shut down.

Throws:

InterruptedException

broadcast

public void broadcast(Filter<? super Endpoint> filter,
 ByteBuffer data,
 boolean reliable,
 boolean copy)

Dispatches the data to all endpoints managed by the kernel. 'routing' is currently ignored.

getEndpoint

protected Endpoint getEndpoint(SocketAddress address,
 boolean create)

closeEndpoint

protected void closeEndpoint(UdpEndpoint p)
                      throws IOException

Called by the endpoints when they need to be closed.

Throws:

IOException

newData

protected void newData(DatagramPacket packet)

enqueueWrite

protected void enqueueWrite(Endpoint endpoint,
 DatagramPacket packet)