water

Class H2ONode.H2OSmallMessage

java.lang.Object

water.H2ONode.H2OSmallMessage

All Implemented Interfaces:

java.lang.Comparable<H2ONode.H2OSmallMessage>

Enclosing class:

H2ONode

public static class H2ONode.H2OSmallMessage
extends java.lang.Object
implements java.lang.Comparable<H2ONode.H2OSmallMessage>

Wrapper around raw bytes representing a small message and its priority.

Constructor Summary

Constructors

Constructor and Description
H2ONode.H2OSmallMessage(byte[] data, int priority)

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(H2ONode.H2OSmallMessage o)
void	increasePriority()
static H2ONode.H2OSmallMessage	make(java.nio.ByteBuffer bb, int priority) Make new H2OSmall message from this byte buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

H2ONode.H2OSmallMessage

public H2ONode.H2OSmallMessage(byte[] data,
                       int priority)

Method Detail

compareTo

public int compareTo(H2ONode.H2OSmallMessage o)

Specified by:

compareTo in interface java.lang.Comparable<H2ONode.H2OSmallMessage>

increasePriority

public void increasePriority()

make

public static H2ONode.H2OSmallMessage make(java.nio.ByteBuffer bb,
                           int priority)

Make new H2OSmall message from this byte buffer. Extracts bytes between position and limit, adds 2B size in the beginning and 1B EOM marker at the end.* Currently size must be <= max small message size (Autobuffer.BBP_SML.size()).

Parameters:

bb -

priority -

Returns: