public class GridOsVersionProcessor extends GridProcessorAdapter implements GridVersionProcessor
GridVersionProcessor.ctx, log| Constructor and Description |
|---|
GridOsVersionProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
addConvertersToAttributes(Map<String,Object> attrs)
Adds all registered local converters to node attributes.
|
void |
onNodeJoined(GridNode node)
Handles node joined event.
|
void |
onNodeLeft(GridNode node)
Handles node left event.
|
void |
onStart(Collection<GridNode> remoteNodes)
Handles node start.
|
boolean |
readDelta(UUID nodeId,
Class<?> msgCls,
ByteBuffer buf)
Reads delta for provided node and message type.
|
void |
registerLocal(Class<?> cls,
Class<? extends GridVersionConverter> converterCls,
GridProductVersion fromVer)
Locally registers converter for a class.
|
boolean |
writeDelta(UUID nodeId,
Class<?> msgCls,
ByteBuffer buf)
Writes delta for provided node and message type.
|
addAttributes, assertParameter, collectDiscoveryData, onDiscoveryDataReceived, onKernalStart, onKernalStop, printMemoryStats, start, stop, toString, validateNodeclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddAttributescollectDiscoveryData, onDiscoveryDataReceived, onKernalStart, onKernalStop, printMemoryStats, start, stop, validateNodepublic GridOsVersionProcessor(GridKernalContext ctx)
ctx - Kernal context.public void onStart(Collection<GridNode> remoteNodes)
onStart in interface GridVersionProcessorremoteNodes - Remote grid nodes.public void onNodeJoined(GridNode node)
onNodeJoined in interface GridVersionProcessornode - Joined node.public void onNodeLeft(GridNode node)
onNodeLeft in interface GridVersionProcessornode - Left node.public boolean writeDelta(UUID nodeId, Class<?> msgCls, ByteBuffer buf)
writeDelta in interface GridVersionProcessornodeId - Node ID.msgCls - Message type.buf - Buffer to write to.public boolean readDelta(UUID nodeId, Class<?> msgCls, ByteBuffer buf)
readDelta in interface GridVersionProcessornodeId - Node ID.msgCls - Message type.buf - Buffer to read from.public void registerLocal(Class<?> cls, Class<? extends GridVersionConverter> converterCls, GridProductVersion fromVer) throws GridException
registerLocal in interface GridVersionProcessorcls - Class.converterCls - Converter class.fromVer - Version to convert from.GridException - In case of error.public void addConvertersToAttributes(Map<String,Object> attrs)
addConvertersToAttributes in interface GridVersionProcessorattrs - Node attributes.Copyright © 2014. All rights reserved.