alluxio.worker.netty

Class ReadRequestContext<T extends ReadRequest>

java.lang.Object

alluxio.worker.netty.ReadRequestContext<T>

Type Parameters:

T - type of read request

Direct Known Subclasses:

BlockReadRequestContext

@ThreadSafe
public class ReadRequestContext<T extends ReadRequest>
extends Object

Represents the context of a read request received from netty channel. This class serves the shared states of the request and can be accessed concurrently by the netty thread and I/O thread.

Constructor Summary

Constructors

Constructor and Description
ReadRequestContext(T request)

Method Summary

Modifier and Type	Method and Description
com.codahale.metrics.Counter	getCounter()
alluxio.worker.netty.Error	getError()
long	getPosToQueue()
long	getPosToWrite()
T	getRequest()
boolean	isCancel()
boolean	isDoneUnsafe()
boolean	isEof()
boolean	isPacketReaderActive()
void	setCancel(boolean cancel)
void	setCounter(com.codahale.metrics.Counter counter)
void	setDoneUnsafe(boolean done)
void	setEof(boolean eof)
void	setError(alluxio.worker.netty.Error error)
void	setPacketReaderActive(boolean packetReaderActive)
void	setPosToQueue(long posToQueue)
void	setPosToWrite(long posToWrite)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadRequestContext

public ReadRequestContext(T request)

Parameters:

request - the read request

Method Detail

getRequest

public T getRequest()

Returns:

request received from channel

isPacketReaderActive

public boolean isPacketReaderActive()

Returns:

whether the packet reader is active

getPosToQueue

public long getPosToQueue()

Returns:

the next position to queue to the netty buffer

getPosToWrite

public long getPosToWrite()

Returns:

the next position to write to the channel

isEof

public boolean isEof()

Returns:

true when the packet reader replies a SUCCESS response, false otherwise

isCancel

public boolean isCancel()

Returns:

true when a CANCEL request is received by the client, false otherwise

getError

@Nullable
public alluxio.worker.netty.Error getError()

Returns:

the error during this read request

isDoneUnsafe

public boolean isDoneUnsafe()

Returns:

true when the SUCCESS or CANCEL response is sent, false otherwise

getCounter

@Nullable
public com.codahale.metrics.Counter getCounter()

Returns:

metrics counter associated with this request

setPacketReaderActive

public void setPacketReaderActive(boolean packetReaderActive)

Parameters:

packetReaderActive - packet reader state to set

setPosToQueue

public void setPosToQueue(long posToQueue)

Parameters:

posToQueue - the next position to queue to the netty buffer to set

setPosToWrite

public void setPosToWrite(long posToWrite)

Parameters:

posToWrite - the next pos to write to the channel to set

setEof

public void setEof(boolean eof)

Parameters:

eof - whether SUCCESS response is replied

setCancel

public void setCancel(boolean cancel)

Parameters:

cancel - whether the CANCEL request is received

setError

public void setError(alluxio.worker.netty.Error error)

Parameters:

error - the error

setDoneUnsafe

public void setDoneUnsafe(boolean done)

Parameters:

done - whether the SUCCESS or CANCEL response is sent

setCounter

public void setCounter(com.codahale.metrics.Counter counter)

Parameters:

counter - counter to set