water
Class TimeLine

java.lang.Object
  water.UDP
      water.TimeLine

public class TimeLine
extends UDP

Maintain a VERY efficient list of events in the system. This must be VERY cheap to call, as it will get called alot. On demand, we can snapshot this list gather all other lists from all other (responsive) Nodes, and build a whole-Cloud timeline for dumping.

Nested Class Summary

Nested classes/interfaces inherited from class water.UDP

UDP.udp

Field Summary

static H2O	CLOUD
static int	MAX_EVENTS

Constructor Summary

TimeLine()

Method Summary

AutoBuffer	call(AutoBuffer ab)
static int	dropped(long[] tl, int idx)
static java.net.InetAddress	inet(long[] tl, int idx)
static boolean	isEmpty(long[] tl, int idx)
static long	l0(long[] tl, int idx)
static long	l8(long[] tl, int idx)
static int	length()
static long	ms(long[] tl, int idx)
static long	ns(long[] tl, int idx)
java.lang.String	print16(AutoBuffer ab)
static void	printMyTimeLine() Only for debugging.
static void	record_IOclose(AutoBuffer b, int flavor)
static void	record_IOclose(long start_ns, long start_io_ms, int r_w, long size, int flavor)
static void	record_recv(AutoBuffer b, boolean tcp, int drop)
static void	record_send(AutoBuffer b, boolean tcp)
static int	send_recv(long[] tl, int idx)
static long[]	snapshot()
static long[][]	system_snapshot()

Methods inherited from class water.UDP

get2, get4, get4f, get8, get8d, printx16, set2, set4, set4f, set8, set8d

Methods inherited from class java.lang.Object

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

Field Detail

MAX_EVENTS

public static final int MAX_EVENTS

See Also:

Constant Field Values

CLOUD

public static H2O CLOUD

Constructor Detail

TimeLine

public TimeLine()

Method Detail

snapshot

public static long[] snapshot()

record_send

public static void record_send(AutoBuffer b,
                               boolean tcp)

record_recv

public static void record_recv(AutoBuffer b,
                               boolean tcp,
                               int drop)

record_IOclose

public static void record_IOclose(AutoBuffer b,
                                  int flavor)

record_IOclose

public static void record_IOclose(long start_ns,
                                  long start_io_ms,
                                  int r_w,
                                  long size,
                                  int flavor)

length

public static int length()

ms

public static long ms(long[] tl,
                      int idx)

inet

public static java.net.InetAddress inet(long[] tl,
                                        int idx)

ns

public static long ns(long[] tl,
                      int idx)

send_recv

public static int send_recv(long[] tl,
                            int idx)

dropped

public static int dropped(long[] tl,
                          int idx)

l0

public static long l0(long[] tl,
                      int idx)

l8

public static long l8(long[] tl,
                      int idx)

isEmpty

public static boolean isEmpty(long[] tl,
                              int idx)

system_snapshot

public static long[][] system_snapshot()

call

public AutoBuffer call(AutoBuffer ab)

print16

public java.lang.String print16(AutoBuffer ab)

Overrides:

print16 in class UDP

printMyTimeLine

public static void printMyTimeLine()

Only for debugging. Prints local timeline to stdout. To be used in case of an error when global timeline can not be relied upon as we might not be able to talk to other nodes.