org.corfudb.infrastructure

Class AbstractServer

java.lang.Object

org.corfudb.infrastructure.AbstractServer

Direct Known Subclasses:

BaseServer, LayoutServer, LogUnitServer, ManagementServer, SequencerServer

public abstract class AbstractServer
extends Object

Created by mwei on 12/4/15.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractServer.ServerState The server state.

Constructor Summary

Constructors

Constructor and Description
AbstractServer()

Method Summary

Modifier and Type	Method and Description
abstract ExecutorService	getExecutor()
abstract CorfuMsgHandler	getHandler() Get the message handler for this instance.
AbstractServer.ServerState	getState()
void	handleMessage(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Handle a incoming Netty message.
abstract boolean	isServerReadyToHandleMsg(CorfuMsg msg)
void	sealServerWithEpoch(long epoch) Seal the server with the epoch.
protected void	setState(AbstractServer.ServerState newState)
void	shutdown() Shutdown the server.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractServer

public AbstractServer()

Method Detail

getHandler

public abstract CorfuMsgHandler getHandler()

Get the message handler for this instance.

Returns:

A message handler.

sealServerWithEpoch

public void sealServerWithEpoch(long epoch)

Seal the server with the epoch.

Parameters:

epoch - Epoch to seal with

isServerReadyToHandleMsg

public abstract boolean isServerReadyToHandleMsg(CorfuMsg msg)

handleMessage

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

Handle a incoming Netty message.

Parameters:

msg - An incoming message.

ctx - The channel handler context.

r - The router that took in the message.

setState

protected void setState(AbstractServer.ServerState newState)

getState

public AbstractServer.ServerState getState()

getExecutor

public abstract ExecutorService getExecutor()

shutdown

public void shutdown()

Shutdown the server.