alluxio.worker.netty

Class UfsFileWriteHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

alluxio.worker.netty.UfsFileWriteHandler

All Implemented Interfaces:

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

@NotThreadSafe
public final class UfsFileWriteHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

This handler handles writes to a file in the under file system. Due to the semantics enforced on under file systems, the client must write all the data of a file through the same stream to the under file system. This prevents us from handling the writes at a block level. For more information about the implementation of read/write buffering, see AbstractWriteHandler. For more information about the implementation of the client side writer, see UnderFileSystemFileOutStream.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	UfsFileWriteHandler.UfsFilePacketWriter The packet writer that writes to UFS.

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
UfsFileWriteHandler(ExecutorService executorService, UfsManager ufsManager) Creates an instance of UfsFileWriteHandler.

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(UfsFileWriteRequestContext context, io.netty.channel.Channel channel) Creates a read writer.
protected UfsFileWriteRequestContext	createRequestContext(Protocol.WriteRequest msg) Creates a new request context.
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected void	initRequestContext(UfsFileWriteRequestContext 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

UfsFileWriteHandler

public UfsFileWriteHandler(ExecutorService executorService,
                           UfsManager ufsManager)

Creates an instance of UfsFileWriteHandler.

Parameters:

executorService - the executor service to run PacketWriters

ufsManager - the file data manager

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

createRequestContext

protected UfsFileWriteRequestContext 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(UfsFileWriteRequestContext context)

Initializes the given request context.

Parameters:

context - the created request context

createPacketWriter

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

Creates a read writer.

Parameters:

context - read request context

channel - channel

Returns:

the packet reader for this handler

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