Package com.alibaba.graphscope.parallel.netty.handler

Class NettyServerHandler<OID_T extends org.apache.hadoop.io.WritableComparable,GS_VID_T>

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<WritableRequest>

com.alibaba.graphscope.parallel.netty.handler.NettyServerHandler<OID_T,GS_VID_T>

All Implemented Interfaces:

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

public class NettyServerHandler<OID_T extends org.apache.hadoop.io.WritableComparable,GS_VID_T>
extends io.netty.channel.SimpleChannelInboundHandler<WritableRequest>

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
static int	RESPONSE_BYTES

Constructor Summary

Constructors

Constructor	Description
NettyServerHandler(IFragment<?,GS_VID_T,?,?> fragment, MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)

Method Summary

Modifier and Type	Method	Description
protected void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, WritableRequest msg)	Please keep in mind that this method will be renamed to messageReceived(ChannelHandlerContext, I) in 5.0.
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
long	getNumberBytesReceived()
void	preSuperStep(MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)
void	resetBytesCounter()

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

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 io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Field Detail

RESPONSE_BYTES

public static int RESPONSE_BYTES

Constructor Detail

NettyServerHandler

public NettyServerHandler(IFragment<?,GS_VID_T,?,?> fragment,
                          MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)

Method Detail

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                            WritableRequest msg)
                     throws Exception

Please keep in mind that this method will be renamed to messageReceived(ChannelHandlerContext, I) in 5.0.

Is called for each message of type WritableRequest.

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<WritableRequest>

Parameters:

ctx - the ChannelHandlerContext which this SimpleChannelInboundHandler belongs to

msg - the message to handle

Throws:

Exception - is thrown if an error occurred

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

preSuperStep

public void preSuperStep(MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)

getNumberBytesReceived

public long getNumberBytesReceived()

resetBytesCounter

public void resetBytesCounter()