net.named_data.jndn.transport

Class UdpTransport

java.lang.Object

net.named_data.jndn.transport.Transport

net.named_data.jndn.transport.UdpTransport

public class UdpTransport
extends Transport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UdpTransport.ConnectionInfo A UdpTransport.ConnectionInfo extends Transport.ConnectionInfo to hold the host and port info for the UDP connection.

Constructor Summary

Constructors

Constructor and Description
UdpTransport()

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the connection.
void	connect(Transport.ConnectionInfo connectionInfo, ElementListener elementListener, Runnable onConnected) Connect according to the info in ConnectionInfo, and use elementListener.
boolean	getIsConnected() Check if the transport is connected.
boolean	isAsync() Override to return false since connect does not need to use the onConnected callback.
boolean	isLocal(Transport.ConnectionInfo connectionInfo) Determine whether this transport connecting according to connectionInfo is to a node on the current machine.
void	processEvents() Process any data to receive.
void	send(ByteBuffer data) Send data to the host

Methods inherited from class java.lang.Object

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

Constructor Detail

UdpTransport

public UdpTransport()

Method Detail

isLocal

public boolean isLocal(Transport.ConnectionInfo connectionInfo)

Determine whether this transport connecting according to connectionInfo is to a node on the current machine. According to http://redmine.named-data.net/issues/2532#note-8, UDP transports are always non-local.

Specified by:

isLocal in class Transport

Parameters:

connectionInfo - This is ignored.

Returns:

False because UDP transports are always non-local.

isAsync

public boolean isAsync()

Override to return false since connect does not need to use the onConnected callback.

Specified by:

isAsync in class Transport

Returns:

False.

connect

public void connect(Transport.ConnectionInfo connectionInfo,
           ElementListener elementListener,
           Runnable onConnected)
             throws IOException

Connect according to the info in ConnectionInfo, and use elementListener.

Overrides:

connect in class Transport

Parameters:

connectionInfo - A UdpTransport.ConnectionInfo.

elementListener - The ElementListener must remain valid during the life of this object.

onConnected - If not null, this calls onConnected.run() when the connection is established.

Throws:

IOException - For I/O error.

send

public void send(ByteBuffer data)
          throws IOException

Send data to the host

Overrides:

send in class Transport

Parameters:

data - The buffer of data to send. This reads from position() to limit(), but does not change the position.

Throws:

IOException - For I/O error.

processEvents

public void processEvents()
                   throws IOException,
                          EncodingException

Process any data to receive. For each element received, call elementListener.onReceivedElement. This is non-blocking and will return immediately if there is no data to receive. You should normally not call this directly since it is called by Face.processEvents. If you call this from an main event loop, you may want to catch and log/disregard all exceptions.

Specified by:

processEvents in class Transport

Throws:

IOException - For I/O error.

EncodingException - For invalid encoding.

getIsConnected

public boolean getIsConnected()
                       throws IOException

Check if the transport is connected.

Overrides:

getIsConnected in class Transport

Returns:

True if connected.

Throws:

IOException

close

public void close()
           throws IOException

Close the connection. If not connected, this does nothing.

Overrides:

close in class Transport

Throws:

IOException - For I/O error.