org.corfudb.infrastructure

Class ManagementServer

java.lang.Object

org.corfudb.infrastructure.AbstractServer

org.corfudb.infrastructure.ManagementServer

public class ManagementServer
extends AbstractServer

Handles reconfiguration and workflow requests to the Management Server. Spawns the following services: - Management Agent. - Orchestrator.

Created by zlokhandwala on 9/28/16.

Nested Class Summary

Nested classes/interfaces inherited from class org.corfudb.infrastructure.AbstractServer

AbstractServer.ServerState

Constructor Summary

Constructors

Constructor and Description
ManagementServer(ServerContext serverContext) Returns new ManagementServer.

Method Summary

Modifier and Type	Method and Description
ExecutorService	getExecutor()
void	handleFailureDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Triggers the failure handler.
void	handleFailureDetectorMetricsRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r)
void	handleHealingDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Triggers the healing handler.
void	handleLayoutRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Handles the Management layout request.
void	handleManagementBootstrap(CorfuPayloadMsg<Layout> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Bootstraps the management server.
void	handleNodeStateRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Returns current NodeState provided by failure detector.
void	handleOrchestratorMsg(CorfuPayloadMsg<OrchestratorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Forward an orchestrator request to the orchestrator service.
boolean	isServerReadyToHandleMsg(CorfuMsg msg)
void	shutdown() Management Server shutdown: Shuts down the fault detector service.

Methods inherited from class org.corfudb.infrastructure.AbstractServer

getHandler, getState, handleMessage, sealServerWithEpoch, setState

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagementServer

public ManagementServer(ServerContext serverContext)

Returns new ManagementServer.

Parameters:

serverContext - context object providing parameters and objects

Method Detail

isServerReadyToHandleMsg

public boolean isServerReadyToHandleMsg(CorfuMsg msg)

Specified by:

isServerReadyToHandleMsg in class AbstractServer

getExecutor

public ExecutorService getExecutor()

Specified by:

getExecutor in class AbstractServer

handleOrchestratorMsg

public void handleOrchestratorMsg(@Nonnull
                                  CorfuPayloadMsg<OrchestratorMsg> msg,
                                  @Nonnull
                                  io.netty.channel.ChannelHandlerContext ctx,
                                  @Nonnull
                                  IServerRouter r)

Forward an orchestrator request to the orchestrator service.

Parameters:

msg - corfu message containing ORCHESTRATOR_REQUEST

ctx - netty ChannelHandlerContext

r - server router

handleManagementBootstrap

public void handleManagementBootstrap(CorfuPayloadMsg<Layout> msg,
                                      io.netty.channel.ChannelHandlerContext ctx,
                                      IServerRouter r)

Bootstraps the management server. The msg contains the layout to be bootstrapped.

Parameters:

msg - corfu message containing MANAGEMENT_BOOTSTRAP_REQUEST

ctx - netty ChannelHandlerContext

r - server router

handleFailureDetectedMsg

public void handleFailureDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg,
                                     io.netty.channel.ChannelHandlerContext ctx,
                                     IServerRouter r)

Triggers the failure handler. The msg contains the failed/defected nodes.

Parameters:

msg - corfu message containing MANAGEMENT_FAILURE_DETECTED

ctx - netty ChannelHandlerContext

r - server router

handleHealingDetectedMsg

public void handleHealingDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg,
                                     io.netty.channel.ChannelHandlerContext ctx,
                                     IServerRouter r)

Triggers the healing handler. The msg contains the healed nodes.

Parameters:

msg - corfu message containing MANAGEMENT_HEALING_DETECTED

ctx - netty ChannelHandlerContext

r - server router

handleNodeStateRequest

public void handleNodeStateRequest(CorfuMsg msg,
                                   io.netty.channel.ChannelHandlerContext ctx,
                                   IServerRouter r)

Returns current NodeState provided by failure detector. The detector periodically collects current cluster state and saves it in ClusterStateContext. Servers periodically inspect cluster and ask each other of the connectivity/node state (connection status between current node and all the others). The node provides its current node state. Default NodeState has been providing unless the node is not bootstrapped. Failure detector updates ClusterNodeState by current state then current NodeState can be provided to other nodes.

Parameters:

msg - corfu message containing NODE_STATE_REQUEST

ctx - netty ChannelHandlerContext

r - server router

handleFailureDetectorMetricsRequest

public void handleFailureDetectorMetricsRequest(CorfuMsg msg,
                                                io.netty.channel.ChannelHandlerContext ctx,
                                                IServerRouter r)

handleLayoutRequest

public void handleLayoutRequest(CorfuMsg msg,
                                io.netty.channel.ChannelHandlerContext ctx,
                                IServerRouter r)

Handles the Management layout request.

Parameters:

msg - corfu message containing MANAGEMENT_LAYOUT_REQUEST

ctx - netty ChannelHandlerContext

r - server router

shutdown

public void shutdown()

Management Server shutdown: Shuts down the fault detector service.

Overrides:

shutdown in class AbstractServer