alluxio.worker.netty

Class UfsFileWriteHandler.UfsFilePacketWriter

java.lang.Object

alluxio.worker.netty.UfsFileWriteHandler.UfsFilePacketWriter

All Implemented Interfaces:

Runnable

Enclosing class:

UfsFileWriteHandler

public class UfsFileWriteHandler.UfsFilePacketWriter
extends Object

The packet writer that writes to UFS.

Constructor Summary

Constructors

Constructor and Description
UfsFilePacketWriter(UfsFileWriteRequestContext context, io.netty.channel.Channel channel, UfsManager ufsManager)

Method Summary

Modifier and Type	Method and Description
protected void	cancelRequest(UfsFileWriteRequestContext context) Cancels this write.
protected void	cleanupRequest(UfsFileWriteRequestContext context) Cleans up this write.
protected void	completeRequest(UfsFileWriteRequestContext context, io.netty.channel.Channel channel) Completes this write.
protected void	writeBuf(UfsFileWriteRequestContext 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

UfsFilePacketWriter

public UfsFilePacketWriter(UfsFileWriteRequestContext context,
                           io.netty.channel.Channel channel,
                           UfsManager ufsManager)

Parameters:

context - context of this packet writer

channel - netty channel

ufsManager - UFS manager

Method Detail

completeRequest

protected void completeRequest(UfsFileWriteRequestContext 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(UfsFileWriteRequestContext 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(UfsFileWriteRequestContext 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(UfsFileWriteRequestContext 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