org.corfudb.infrastructure

Class NettyServerRouter

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.corfudb.infrastructure.NettyServerRouter

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, IServerRouter

@ChannelHandler.Sharable
public class NettyServerRouter
extends io.netty.channel.ChannelInboundHandlerAdapter
implements IServerRouter

The netty server router routes incoming messages to registered roles using the Created by mwei on 12/1/15.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
NettyServerRouter(List<AbstractServer> servers) Construct a new NettyServerRouter.

Method Summary

Modifier and Type	Method and Description
void	addServer(AbstractServer server) Deprecated. This operation is no longer supported. The router will only route messages for servers provided at construction time.
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) Handle an incoming message read on the channel.
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
List<AbstractServer>	getServers() Get a list of registered servers.
void	sendResponse(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg inMsg, CorfuMsg outMsg) Send a netty message through this router, setting the fields in the outgoing message.
boolean	validateEpoch(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx) Validate the epoch of a CorfuMsg, and send a WRONG_EPOCH response if the server is in the wrong epoch.

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.corfudb.infrastructure.IServerRouter

getServerEpoch, setServerEpoch

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

NettyServerRouter

public NettyServerRouter(List<AbstractServer> servers)

Construct a new NettyServerRouter.

Parameters:

servers - A list of AbstractServers this router will route messages for.

Method Detail

addServer

@Deprecated
public void addServer(AbstractServer server)

Deprecated. This operation is no longer supported. The router will only route messages for servers provided at construction time.

Register a server to route messages to.

Specified by:

addServer in interface IServerRouter

Parameters:

server - The server to route messages to

getServers

public List<AbstractServer> getServers()

Get a list of registered servers.

Specified by:

getServers in interface IServerRouter

sendResponse

public void sendResponse(io.netty.channel.ChannelHandlerContext ctx,
                         CorfuMsg inMsg,
                         CorfuMsg outMsg)

Send a netty message through this router, setting the fields in the outgoing message.

Specified by:

sendResponse in interface IServerRouter

Parameters:

ctx - Channel handler context to use.

inMsg - Incoming message to respond to.

outMsg - Outgoing message.

validateEpoch

public boolean validateEpoch(CorfuMsg msg,
                             io.netty.channel.ChannelHandlerContext ctx)

Validate the epoch of a CorfuMsg, and send a WRONG_EPOCH response if the server is in the wrong epoch. Ignored if the message type is reset (which is valid in any epoch).

Parameters:

msg - The incoming message to validate.

ctx - The context of the channel handler.

Returns:

True, if the epoch is correct, but false otherwise.

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)

Handle an incoming message read on the channel.

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Parameters:

ctx - Channel handler context

msg - The incoming message on that channel.

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter