com.liferay.portal.fabric.netty.fileserver.handlers

Class FileUploadChannelHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

com.liferay.portal.fabric.netty.fileserver.handlers.FileUploadChannelHandler

All Implemented Interfaces:

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

public class FileUploadChannelHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

Author:

Shuyang Zhou

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected com.liferay.petra.concurrent.AsyncBroker<java.nio.file.Path,FileResponse>	asyncBroker
protected io.netty.util.concurrent.EventExecutor	eventExecutor
protected java.nio.channels.FileChannel	fileChannel
protected FileResponse	fileResponse
protected java.nio.file.Path	tempFilePath

Constructor Summary

Constructors

Constructor and Description
FileUploadChannelHandler(com.liferay.petra.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker, FileResponse fileResponse, io.netty.util.concurrent.EventExecutor eventExecutor)

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext channelHandlerContext, java.lang.Object object)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext, java.lang.Throwable throwable)
protected void	finish()
protected boolean	receive(io.netty.buffer.ByteBuf byteBuf)

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

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

Field Detail

asyncBroker

protected final com.liferay.petra.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker

eventExecutor

protected final io.netty.util.concurrent.EventExecutor eventExecutor

fileChannel

protected final java.nio.channels.FileChannel fileChannel

fileResponse

protected final FileResponse fileResponse

tempFilePath

protected final java.nio.file.Path tempFilePath

Constructor Detail

FileUploadChannelHandler

public FileUploadChannelHandler(com.liferay.petra.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker,
                                FileResponse fileResponse,
                                io.netty.util.concurrent.EventExecutor eventExecutor)
                         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext channelHandlerContext,
                        java.lang.Object object)
                 throws java.io.IOException

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

java.io.IOException

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
                            java.lang.Throwable throwable)
                     throws java.io.IOException

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

Throws:

java.io.IOException

finish

protected void finish()
               throws java.io.IOException

Throws:

java.io.IOException

receive

protected boolean receive(io.netty.buffer.ByteBuf byteBuf)
                   throws java.io.IOException

Throws:

java.io.IOException