ds.funnel.data.channel.tcp

Class TCPChannelAddr

java.lang.Object

ds.funnel.data.channel.ChannelAddress

ds.funnel.data.channel.tcp.TCPChannelAddr

All Implemented Interfaces:

FormatMarshaller

public class TCPChannelAddr
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

Constructor Summary

Constructors

Constructor and Description
TCPChannelAddr(FormatReader mFormat)
TCPChannelAddr(java.lang.String inHostPort) Constructs a new address with the given host:port.
TCPChannelAddr(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

Constructor Detail

TCPChannelAddr

public TCPChannelAddr(java.lang.String inHostPort)

Constructs a new address with the given host:port.

Parameters:

inHostPost - - The host:port of a node.

TCPChannelAddr

public TCPChannelAddr(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.

TCPChannelAddr

public TCPChannelAddr(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