alluxio.worker.s3

Class S3NettyBaseTask

java.lang.Object

alluxio.worker.s3.S3NettyBaseTask

Direct Known Subclasses:

S3NettyBucketTask, S3NettyObjectTask

public abstract class S3NettyBaseTask
extends Object

S3 Abstract Base task for handling S3 API logic in netty server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	S3NettyBaseTask.OpTag Enum for tagging the http request to target for different threadpools for handling.
static class	S3NettyBaseTask.OpType Enum indicating name of S3 API handling per http request.

Field Summary

Fields

Modifier and Type	Field and Description
protected S3NettyHandler	mHandler
protected S3NettyBaseTask.OpType	mOPType

Constructor Summary

Constructors

Constructor and Description
S3NettyBaseTask(S3NettyHandler handler, S3NettyBaseTask.OpType OPType) Creates an instance of S3NettyBaseTask.

Method Summary

Modifier and Type	Method and Description
abstract io.netty.handler.codec.http.HttpResponse	continueTask() Run core S3 API logic from different S3 task.
S3NettyBaseTask.OpType	getOPType() Return the OpType (S3 API enum).
io.netty.handler.codec.http.HttpResponse	handleContent(io.netty.handler.codec.http.HttpContent content) Run core S3 API logic with HttpContent in different S3 task.
void	handleTaskAsync() Run S3 API logic in a customized async way, e.g.
boolean	needContent() Return if the S3 API needs to process the content.

Methods inherited from class java.lang.Object

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

Field Detail

mHandler

protected final S3NettyHandler mHandler

mOPType

protected final S3NettyBaseTask.OpType mOPType

Constructor Detail

S3NettyBaseTask

public S3NettyBaseTask(S3NettyHandler handler,
                       S3NettyBaseTask.OpType OPType)

Creates an instance of S3NettyBaseTask.

Parameters:

handler - S3NettyHandler

OPType - op type

Method Detail

getOPType

public S3NettyBaseTask.OpType getOPType()

Return the OpType (S3 API enum).

Returns:

OpType (S3 API enum)

continueTask

public abstract io.netty.handler.codec.http.HttpResponse continueTask()

Run core S3 API logic from different S3 task.

Returns:

HttpResponse (S3 Http response)

handleContent

public io.netty.handler.codec.http.HttpResponse handleContent(io.netty.handler.codec.http.HttpContent content)

Run core S3 API logic with HttpContent in different S3 task.

Parameters:

content - HttpContent

Returns:

HttpResponse (S3 Http response)

needContent

public boolean needContent()

Return if the S3 API needs to process the content.

Returns:

if true, the S3 API needs to process the content

handleTaskAsync

public void handleTaskAsync()

Run S3 API logic in a customized async way, e.g. delegate the core API logic to another thread and do something while waiting.