water

Class H2ONode

java.lang.Object

water.Iced<H2ONode>

water.H2ONode

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, java.lang.Cloneable, java.lang.Comparable, Freezable<H2ONode>

public final class H2ONode
extends Iced<H2ONode>
implements java.lang.Comparable

A Node in an H2O Cloud. Basically a worker-bee with CPUs, Memory and Disk. One of this is the self-Node, but the rest are remote Nodes.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
HeartBeat	_heartbeat
water.H2ONode.H2Okey	_key
long	_last_heard_from
boolean	_removed_from_cloud
int	_tcp_readers

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(java.lang.Object o)
boolean	equals(java.lang.Object o)
java.lang.String	getIpPortString()
H2OSecurityManager	getSecurityManager()
SocketChannelFactory	getSocketFactory()
int	hashCode()
int	index()
static H2ONode	intern(byte[] bs, int off)
static H2ONode	intern(java.net.InetAddress ip, int port)
int	ip4()
boolean	isHealthy()
boolean	isHealthy(long now)
static java.nio.channels.ByteChannel	openChan(byte tcpType, SocketChannelFactory socketFactory, java.net.InetAddress originAddr, int originPort) Returns a new connection of type tcpType, the type can be either TCPReceiverThread.TCP_SMALL, TCPReceiverThread.TCP_BIG or TCPReceiverThread.TCP_EXTERNAL.
static java.nio.channels.ByteChannel	openChan(byte tcpType, SocketChannelFactory socketFactory, java.lang.String originAddr, int originPort)
H2ONode	read_impl(AutoBuffer ab)
H2ONode	readJSON_impl(AutoBuffer ab)
static H2ONode	self(java.net.InetAddress local)
void	sendMessage(java.nio.ByteBuffer bb, byte msg_priority)
void	stopSendThread()
java.lang.String	toString()
AutoBuffer	write_impl(AutoBuffer ab)
AutoBuffer	writeJSON_impl(AutoBuffer ab)

Methods inherited from class water.Iced

asBytes, clone, copyOver, frozenType, read, readExternal, readJSON, reloadFromBytes, toJsonString, write, writeExternal, writeJSON

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

_last_heard_from

public transient long _last_heard_from

_heartbeat

public transient volatile HeartBeat _heartbeat

_tcp_readers

public transient int _tcp_readers

_removed_from_cloud

public boolean _removed_from_cloud

_key

public final water.H2ONode.H2Okey _key

Method Detail

stopSendThread

public void stopSendThread()

getIpPortString

public java.lang.String getIpPortString()

ip4

public final int ip4()

isHealthy

public boolean isHealthy()

isHealthy

public boolean isHealthy(long now)

intern

public static H2ONode intern(java.net.InetAddress ip,
             int port)

intern

public static H2ONode intern(byte[] bs,
             int off)

self

public static H2ONode self(java.net.InetAddress local)

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 o)

Overrides:

equals in class java.lang.Object

compareTo

public int compareTo(java.lang.Object o)

Specified by:

compareTo in interface java.lang.Comparable

index

public int index()

sendMessage

public void sendMessage(java.nio.ByteBuffer bb,
               byte msg_priority)

openChan

public static java.nio.channels.ByteChannel openChan(byte tcpType,
                                     SocketChannelFactory socketFactory,
                                     java.net.InetAddress originAddr,
                                     int originPort)
                                              throws java.io.IOException

Returns a new connection of type tcpType, the type can be either TCPReceiverThread.TCP_SMALL, TCPReceiverThread.TCP_BIG or TCPReceiverThread.TCP_EXTERNAL. If socket channel factory is set, the communication will considered to be secured - this depends on the configuration of the SocketChannelFactory. In case of the factory is null, the communication won't be secured.

Returns:

new socket channel

Throws:

java.io.IOException

openChan

public static java.nio.channels.ByteChannel openChan(byte tcpType,
                                     SocketChannelFactory socketFactory,
                                     java.lang.String originAddr,
                                     int originPort)
                                              throws java.io.IOException

Throws:

java.io.IOException

write_impl

public final AutoBuffer write_impl(AutoBuffer ab)

read_impl

public final H2ONode read_impl(AutoBuffer ab)

writeJSON_impl

public final AutoBuffer writeJSON_impl(AutoBuffer ab)

readJSON_impl

public final H2ONode readJSON_impl(AutoBuffer ab)

getSocketFactory

public SocketChannelFactory getSocketFactory()

getSecurityManager

public H2OSecurityManager getSecurityManager()