org.gridgain.grid.kernal.processors.clock

Class GridClockSyncProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.clock.GridClockSyncProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridClockSyncProcessor
extends GridProcessorAdapter

Time synchronization processor.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridClockSyncProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
long	adjustedTime(long topVer) Gets time adjusted with time coordinator on given topology version.
void	onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	onMessageReceived(GridClockMessage msg, InetAddress addr, int port) Callback from server for message receiving.
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
NavigableMap<GridClockDeltaVersion,GridClockDeltaSnapshot>	timeSyncHistory()

Methods inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

assertParameter, collectDiscoveryData, onDiscoveryDataReceived, printMemoryStats, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridClockSyncProcessor

public GridClockSyncProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws GridException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

GridException - Throws in case of any errors.

addAttributes

public void addAttributes(Map<String,Object> attrs)
                   throws GridException

Adds attributes from this component to map of all node attributes.

Specified by:

addAttributes in interface GridProcessor

Overrides:

addAttributes in class GridProcessorAdapter

Parameters:

attrs - Map of all attributes.

Throws:

GridException - If failed.

onKernalStart

public void onKernalStart()
                   throws GridException

Callback that notifies that kernal has successfully started, including all managers and processors.

Specified by:

onKernalStart in interface GridComponent

Overrides:

onKernalStart in class GridProcessorAdapter

Throws:

GridException - Thrown in case of any errors.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

stop

public void stop(boolean cancel)
          throws GridException

Stops grid component.

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

GridException - Thrown in case of any errors.

timeSyncHistory

public NavigableMap<GridClockDeltaVersion,GridClockDeltaSnapshot> timeSyncHistory()

Returns:

Time sync history.

onMessageReceived

public void onMessageReceived(GridClockMessage msg,
                     InetAddress addr,
                     int port)

Callback from server for message receiving.

Parameters:

msg - Received message.

addr - Remote node address.

port - Remote node port.

adjustedTime

public long adjustedTime(long topVer)

Gets time adjusted with time coordinator on given topology version.

Parameters:

topVer - Topology version.

Returns:

Adjusted time.