alluxio.worker.netty

Class FileWriteHandler.BlockPacketWriter

java.lang.Object

alluxio.worker.netty.FileWriteHandler.BlockPacketWriter

All Implemented Interfaces:

Runnable

Enclosing class:

FileWriteHandler

public class FileWriteHandler.BlockPacketWriter
extends Object

The packet writer that writes to a local block worker.

Constructor Summary

Constructors

Constructor and Description
BlockPacketWriter(BlockWriteRequestContext context, io.netty.channel.Channel channel, DoraWorker worker)

Method Summary

Modifier and Type	Method and Description
protected void	cancelRequest(BlockWriteRequestContext context) Cancels this write.
protected void	cleanupRequest(BlockWriteRequestContext context) Cleans up this write.
protected void	completeRequest(BlockWriteRequestContext context, io.netty.channel.Channel channel) Completes this write.
protected void	writeBuf(BlockWriteRequestContext context, io.netty.channel.Channel channel, io.netty.buffer.ByteBuf buf, long pos) Writes the buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockPacketWriter

public BlockPacketWriter(BlockWriteRequestContext context,
                         io.netty.channel.Channel channel,
                         DoraWorker worker)

Parameters:

context - context of this packet writer

channel - netty channel

worker - local block worker

Method Detail

completeRequest

protected void completeRequest(BlockWriteRequestContext context,
                               io.netty.channel.Channel channel)
                        throws Exception

Completes this write. This is called when the write completes.

Parameters:

context - context of the request to complete

channel - netty channel

Throws:

Exception

cancelRequest

protected void cancelRequest(BlockWriteRequestContext context)
                      throws Exception

Cancels this write. This is called when the client issues a cancel request.

Parameters:

context - context of the request to complete

Throws:

Exception

cleanupRequest

protected void cleanupRequest(BlockWriteRequestContext context)
                       throws Exception

Cleans up this write. This is called when the write request is aborted due to any exception or session timeout.

Parameters:

context - context of the request to complete

Throws:

Exception

writeBuf

protected void writeBuf(BlockWriteRequestContext context,
                        io.netty.channel.Channel channel,
                        io.netty.buffer.ByteBuf buf,
                        long pos)
                 throws Exception

Writes the buffer.

Parameters:

context - context of the request to complete

channel - the netty channel

buf - the buffer

pos - the pos

Throws:

Exception