alluxio.worker.s3

Class S3HttpHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

alluxio.worker.s3.S3HttpHandler

All Implemented Interfaces:

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

public class S3HttpHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

Handles S3 HTTP request.

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
S3HttpHandler(FileSystem fileSystem, DoraWorker doraWorker, AsyncUserAccessAuditLogWriter asyncAuditLogWriter, ThreadPoolExecutor lightPool, ThreadPoolExecutor heavyPool) Constructs an instance of S3HttpHandler.

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext context, Object msg)
void	channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, 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

S3HttpHandler

public S3HttpHandler(FileSystem fileSystem,
                     DoraWorker doraWorker,
                     AsyncUserAccessAuditLogWriter asyncAuditLogWriter,
                     ThreadPoolExecutor lightPool,
                     ThreadPoolExecutor heavyPool)

Constructs an instance of S3HttpHandler.

Parameters:

fileSystem -

doraWorker -

asyncAuditLogWriter -

lightPool -

heavyPool -

Method Detail

channelReadComplete

public void channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
                         throws Exception

Specified by:

channelReadComplete in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelReadComplete in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext context,
                        Object msg)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception