alluxio.worker.netty

Class FileWriteHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

alluxio.worker.netty.FileWriteHandler

All Implemented Interfaces:

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

@NotThreadSafe
public class FileWriteHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

This handler handles block write request. Check more information in AbstractWriteHandler.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FileWriteHandler.BlockPacketWriter The packet writer that writes to a local block worker.

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FileWriteHandler(ExecutorService executorService, DoraWorker doraWorker) Creates an instance of FileWriteHandler.

Method Summary

Modifier and Type	Method and Description
protected boolean	acceptMessage(Object object) Checks whether this object should be processed by this handler.
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object object)
void	channelUnregistered(io.netty.channel.ChannelHandlerContext ctx)
protected alluxio.worker.netty.AbstractWriteHandler.PacketWriter	createPacketWriter(BlockWriteRequestContext context, io.netty.channel.Channel channel) Creates a read writer.
protected BlockWriteRequestContext	createRequestContext(Protocol.WriteRequest msg) Creates a new request context.
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected DoraWorker	getWorker()
protected void	initRequestContext(BlockWriteRequestContext context) Initializes the given request context.

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, 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

FileWriteHandler

protected FileWriteHandler(ExecutorService executorService,
                           DoraWorker doraWorker)

Creates an instance of FileWriteHandler.

Parameters:

executorService - the executor service to run PacketWriters

doraWorker - the dora worker

Method Detail

acceptMessage

protected boolean acceptMessage(Object object)

Checks whether this object should be processed by this handler.

Parameters:

object - the object

Returns:

true if this object should be processed

createPacketWriter

protected alluxio.worker.netty.AbstractWriteHandler.PacketWriter createPacketWriter(BlockWriteRequestContext context,
                                                                                    io.netty.channel.Channel channel)

Creates a read writer.

Parameters:

context - read request context

channel - channel

Returns:

the packet reader for this handler

createRequestContext

protected BlockWriteRequestContext createRequestContext(Protocol.WriteRequest msg)

Creates a new request context. This method must be exception free.

Parameters:

msg - the block write request

initRequestContext

protected void initRequestContext(BlockWriteRequestContext context)
                           throws Exception

Initializes the given request context.

Parameters:

context - the created request context

Throws:

Exception

getWorker

protected DoraWorker getWorker()

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object object)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

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

channelUnregistered

public void channelUnregistered(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

channelUnregistered in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelUnregistered in class io.netty.channel.ChannelInboundHandlerAdapter