org.gridgain.grid.kernal.processors.dr

Class GridDrUtils

java.lang.Object

org.gridgain.grid.kernal.processors.dr.GridDrUtils

public class GridDrUtils
extends Object

DR utility methods.

Field Summary

Fields

Modifier and Type	Field and Description
static Integer	DR_GLOBAL_SYNC Key used to store GridDrPauseInfo in system cache.
static int	MAX_DATA_CENTERS Maximum amount of data centers.
static byte[]	PING_REQ_BYTES Cached external ping request bytes.
static byte[]	PING_RESP_BYTES Cached external ping response bytes.

Method Summary

Methods

Modifier and Type	Method and Description
static GridTuple4<GridUuid,String,Integer,Integer>	batchRequestHeader(byte[] data) Get batch request header.
static byte[]	marshal(GridDrExternalBatchRequest req) Marshal batch request.
static byte[]	marshal(GridDrExternalBatchResponse resp) Marshal batch response.
static byte[]	marshal(GridDrExternalHandshakeRequest req) Marshal handshake request.
static byte[]	marshal(GridDrExternalHandshakeResponse resp) Marshal handshake response.
static <K,V> GridDrRawEntry<K,V>	readDrEntry(DataInput in, byte dataCenterId) Read marshaled DR entry.
static Object	unmarshal(byte[] data) Unmarshal DR message.
static <K,V> void	writeDrEntry(DataOutput out, GridDrRawEntry<K,V> entry) Write marshalled DR entry.

Methods inherited from class java.lang.Object

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

Field Detail

DR_GLOBAL_SYNC

public static final Integer DR_GLOBAL_SYNC

Key used to store GridDrPauseInfo in system cache.

MAX_DATA_CENTERS

public static final int MAX_DATA_CENTERS

Maximum amount of data centers.

See Also:

Constant Field Values

PING_REQ_BYTES

public static final byte[] PING_REQ_BYTES

Cached external ping request bytes.

PING_RESP_BYTES

public static final byte[] PING_RESP_BYTES

Cached external ping response bytes.

Method Detail

readDrEntry

public static <K,V> GridDrRawEntry<K,V> readDrEntry(DataInput in,
                                    byte dataCenterId)
                                       throws IOException

Read marshaled DR entry.

Parameters:

in - Input.

dataCenterId - Data center ID.

Returns:

Marshalled DR entry.

Throws:

IOException - If failed.

writeDrEntry

public static <K,V> void writeDrEntry(DataOutput out,
                      GridDrRawEntry<K,V> entry)
                         throws IOException

Write marshalled DR entry.

Parameters:

out - Output.

entry - Entry.

Throws:

IOException - If failed.

marshal

public static byte[] marshal(GridDrExternalHandshakeRequest req)
                      throws GridException

Marshal handshake request.

Parameters:

req - Handshake request.

Returns:

Bytes.

Throws:

GridException - If failed.

marshal

public static byte[] marshal(GridDrExternalHandshakeResponse resp)
                      throws GridException

Marshal handshake response.

Parameters:

resp - Handshake response.

Returns:

Bytes.

Throws:

GridException - If failed.

marshal

public static byte[] marshal(GridDrExternalBatchRequest req)
                      throws GridException

Marshal batch request.

Parameters:

req - Batch request.

Returns:

Bytes.

Throws:

GridException - If failed.

marshal

public static byte[] marshal(GridDrExternalBatchResponse resp)
                      throws GridException

Marshal batch response.

Parameters:

resp - Batch response.

Returns:

Bytes.

Throws:

GridException - If failed.

unmarshal

public static Object unmarshal(byte[] data)
                        throws GridException

Unmarshal DR message.

Parameters:

data - Data bytes.

Returns:

Message.

Throws:

GridException - If failed.

batchRequestHeader

public static GridTuple4<GridUuid,String,Integer,Integer> batchRequestHeader(byte[] data)
                                                                      throws GridException

Get batch request header.

Parameters:

data - Raw data bytes.

Returns:

Batch request header.

Throws:

GridException - If failed.