public class BaseServer extends AbstractServer
AbstractServer.ServerState
Constructor and Description |
---|
BaseServer(ServerContext context) |
Modifier and Type | Method and Description |
---|---|
ExecutorService |
getExecutor() |
void |
handleMessageSetEpoch(CorfuPayloadMsg<Long> msg,
io.netty.channel.ChannelHandlerContext ctx,
IServerRouter r)
Respond to a epoch change message.
|
boolean |
isServerReadyToHandleMsg(CorfuMsg msg) |
getHandler, getState, handleMessage, sealServerWithEpoch, setState, shutdown
public BaseServer(@Nonnull ServerContext context)
public boolean isServerReadyToHandleMsg(CorfuMsg msg)
isServerReadyToHandleMsg
in class AbstractServer
public ExecutorService getExecutor()
getExecutor
in class AbstractServer
public void handleMessageSetEpoch(@NonNull CorfuPayloadMsg<Long> msg, io.netty.channel.ChannelHandlerContext ctx, @NonNull IServerRouter r)
msg
- The incoming messagectx
- The channel contextr
- The server router.Copyright © 2019 CorfuDB. All rights reserved.