water

Class H2ONode

java.lang.Object

water.Iced

water.H2ONode

All Implemented Interfaces:

java.lang.Cloneable, java.lang.Comparable, Freezable

public class H2ONode
extends Iced
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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	H2ONode.AckAckTimeOutThread
static class	H2ONode.H2Okey

Field Summary

Fields

Modifier and Type	Field and Description
boolean	_announcedLostContact
HeartBeat	_heartbeat
H2ONode.H2Okey	_key
long	_last_heard_from
boolean	_node_healthy
int	_tcp_readers
int	_unique_idx
static H2ONode[]	IDX
static java.util.concurrent.atomic.AtomicInteger	TCPS

Constructor Summary

Constructors

Constructor and Description
H2ONode()

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(java.lang.Object o)
boolean	equals(java.lang.Object o)
void	freeTCPSocket(java.nio.channels.SocketChannel sock)
long	get_max_mem()
java.nio.channels.SocketChannel	getTCPSocket()
int	hashCode()
int	index()
static H2ONode	intern(H2ONode.H2Okey key)
static H2ONode	intern(java.net.InetAddress ip, int port)
static H2ONode	intern(int ip, int port)
int	ip4()
int	nextTaskNum()
H2ONode	read(AutoBuffer ab) Deserialize from the AutoBuffer into a pre-existing 'this' object.
long	runtime() Returns run time for this node based on last heartbeat.
RPC	taskGet(int tnum)
void	taskPut(int tnum, RPC rpc)
void	taskRemove(int tnum)
java.util.Collection<RPC>	tasks()
int	taskSize()
java.lang.String	toString()
AutoBuffer	write(AutoBuffer ab) Serialize the 'this' object into the AutoBuffer, returning the AutoBuffer.

Methods inherited from class water.Iced

clone, frozenType, init, newInstance, toDocField, writeJSON, writeJSONFields

Methods inherited from class java.lang.Object

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

Field Detail

_unique_idx

public int _unique_idx

_last_heard_from

public long _last_heard_from

_announcedLostContact

public boolean _announcedLostContact

_heartbeat

public volatile HeartBeat _heartbeat

_tcp_readers

public int _tcp_readers

_node_healthy

public boolean _node_healthy

_key

public H2ONode.H2Okey _key

IDX

public static H2ONode[] IDX

TCPS

public static final java.util.concurrent.atomic.AtomicInteger TCPS

Constructor Detail

H2ONode

public H2ONode()

Method Detail

ip4

public final int ip4()

intern

public static final H2ONode intern(H2ONode.H2Okey key)

intern

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

intern

public static final H2ONode intern(int ip,
             int port)

write

public AutoBuffer write(AutoBuffer ab)

Description copied from interface: Freezable

Serialize the 'this' object into the AutoBuffer, returning the AutoBuffer.

Specified by:

write in interface Freezable

Overrides:

write in class Iced

read

public H2ONode read(AutoBuffer ab)

Description copied from interface: Freezable

Deserialize from the AutoBuffer into a pre-existing 'this' object.

Specified by:

read in interface Freezable

Overrides:

read in class Iced

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

get_max_mem

public long get_max_mem()

getTCPSocket

public java.nio.channels.SocketChannel getTCPSocket()
                                             throws java.io.IOException

Throws:

java.io.IOException

freeTCPSocket

public void freeTCPSocket(java.nio.channels.SocketChannel sock)

taskPut

public void taskPut(int tnum,
           RPC rpc)

taskGet

public RPC taskGet(int tnum)

taskRemove

public void taskRemove(int tnum)

tasks

public java.util.Collection<RPC> tasks()

taskSize

public int taskSize()

nextTaskNum

public int nextTaskNum()

runtime

public long runtime()

Returns run time for this node based on last heartbeat.