ds.funnel.data.channel.udp

Class UDPChannelAddr

java.lang.Object

ds.funnel.data.channel.ChannelAddress

ds.funnel.data.channel.udp.UDPChannelAddr

All Implemented Interfaces:

FormatMarshaller

public class UDPChannelAddr
extends ChannelAddress

A socket implementation of NodeAddress.

Version:

x.x.x, 2/11/2014

Author:

Ryan Stern at Colorado State University

Nested Class Summary

Nested classes/interfaces inherited from class ds.funnel.data.channel.ChannelAddress

ChannelAddress.ChannelAddressType

Field Summary

Fields

Modifier and Type	Field and Description
static int	RECV_BUFFER_BYTES
static int	SEND_BUFFER_BYTES

Constructor Summary

Constructors

Constructor and Description
UDPChannelAddr(FormatReader mFormat)
UDPChannelAddr(java.lang.String inHostPort) Constructs a new address with the given host:port.
UDPChannelAddr(java.lang.String inHost, int inPort) Constructs a new address with the given host and port.

Method Summary

Modifier and Type	Method and Description
ChannelManager	connect(java.nio.channels.ByteChannel inChannel, ChannelProtocol inProtocol) Completes a connection made to the node.
ChannelManager	connect(ChannelProtocol inProtocol) Opens a new connection to the node.
boolean	equals(java.lang.Object obj)
java.lang.String	getHost() Get the host address of the node.
java.lang.String	getHostPort() Get the combined host and port as host:port.
int	getPort() Get the port number of the node.
int	hashCode()
ChannelListener	listen(ChannelProtocolFactory inProtocolFactory) Starts a listener on this address.
void	marshall(FormatWriter mFormat)
java.lang.String	toString()

Methods inherited from class ds.funnel.data.channel.ChannelAddress

marshall

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Detail

SEND_BUFFER_BYTES

public static final int SEND_BUFFER_BYTES

See Also:

Constant Field Values

RECV_BUFFER_BYTES

public static final int RECV_BUFFER_BYTES

See Also:

Constant Field Values

Constructor Detail

UDPChannelAddr

public UDPChannelAddr(java.lang.String inHostPort)

Constructs a new address with the given host:port.

Parameters:

inHostPost - - The host:port of a node.

UDPChannelAddr

public UDPChannelAddr(java.lang.String inHost,
                      int inPort)

Constructs a new address with the given host and port.

Parameters:

inHost - - The host of this node.

inPort - - The port of this node.

UDPChannelAddr

public UDPChannelAddr(FormatReader mFormat)
               throws FormatException

Throws:

FormatException

Method Detail

getHost

public java.lang.String getHost()

Get the host address of the node.

Returns:

The host address of the node.

getHostPort

public java.lang.String getHostPort()

Get the combined host and port as host:port.

Returns:

The combined host and port.

getPort

public int getPort()

Get the port number of the node.

Returns:

The port number of the peer.

listen

public ChannelListener listen(ChannelProtocolFactory inProtocolFactory)
                       throws ConnectException

Description copied from class: ChannelAddress

Starts a listener on this address.

Specified by:

listen in class ChannelAddress

Returns:

The ChannelAccepter listening to this address.

Throws:

ConnectException

connect

public ChannelManager connect(ChannelProtocol inProtocol)
                       throws ConnectException

Description copied from class: ChannelAddress

Opens a new connection to the node.

Specified by:

connect in class ChannelAddress

Returns:

The byte channel for the connection.

Throws:

ConnectException

connect

public ChannelManager connect(java.nio.channels.ByteChannel inChannel,
                              ChannelProtocol inProtocol)
                       throws ConnectException

Description copied from class: ChannelAddress

Completes a connection made to the node.

Specified by:

connect in class ChannelAddress

Returns:

The byte channel for the connection.

Throws:

ConnectException

marshall

public void marshall(FormatWriter mFormat)
              throws FormatException

Parameters:

mFormat - - The format writer to write to

Throws:

FormatException - If there was a problem while writing

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object