org.apache.giraph.comm.netty.handler

Class MasterRequestServerHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.apache.giraph.comm.netty.handler.RequestServerHandler<MasterRequest>

org.apache.giraph.comm.netty.handler.MasterRequestServerHandler

All Implemented Interfaces:

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

public class MasterRequestServerHandler
extends RequestServerHandler<MasterRequest>

Handler for requests on master

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MasterRequestServerHandler.Factory Factory for MasterRequestServerHandler

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class org.apache.giraph.comm.netty.handler.RequestServerHandler

flowControl, RESPONSE_BYTES

Constructor Summary

Constructors

Constructor and Description
MasterRequestServerHandler(WorkerRequestReservedMap workerRequestReservedMap, ImmutableClassesGiraphConfiguration conf, TaskInfo myTaskInfo, MasterGlobalCommHandler commHandler, Thread.UncaughtExceptionHandler exceptionHandler, FlowControl flowControl) Constructor

Method Summary

Modifier and Type	Method and Description
void	processRequest(MasterRequest request) Process request

Methods inherited from class org.apache.giraph.comm.netty.handler.RequestServerHandler

channelActive, channelInactive, channelRead, exceptionCaught

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

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

Constructor Detail

MasterRequestServerHandler

public MasterRequestServerHandler(WorkerRequestReservedMap workerRequestReservedMap,
                                  ImmutableClassesGiraphConfiguration conf,
                                  TaskInfo myTaskInfo,
                                  MasterGlobalCommHandler commHandler,
                                  Thread.UncaughtExceptionHandler exceptionHandler,
                                  FlowControl flowControl)

Constructor

Parameters:

workerRequestReservedMap - Worker request reservation map

conf - Configuration

myTaskInfo - Current task info

commHandler - Master communication handler

exceptionHandler - Handles uncaught exceptions

flowControl - Reference to the flow control used

Method Detail

processRequest

public void processRequest(MasterRequest request)

Description copied from class: RequestServerHandler

Process request

Specified by:

processRequest in class RequestServerHandler<MasterRequest>

Parameters:

request - Request to process