alluxio.worker.grpc

Class ReadRequestContext<T extends alluxio.worker.grpc.ReadRequest>

java.lang.Object

alluxio.worker.grpc.ReadRequestContext<T>

Type Parameters:

T - type of read request

Direct Known Subclasses:

BlockReadRequestContext

@ThreadSafe
public class ReadRequestContext<T extends alluxio.worker.grpc.ReadRequest>
extends Object

Represents the context of a read request received from gRPC stream. This class serves the shared states of the request and can be accessed concurrently by the gRPC event 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.grpc.Error	getError()
com.codahale.metrics.Meter	getMeter()
long	getPosReceived()
long	getPosToQueue()
T	getRequest()
boolean	isCancel()
boolean	isDataReaderActive()
boolean	isDoneUnsafe()
boolean	isEof()
void	setCancel(boolean cancel)
void	setCounter(com.codahale.metrics.Counter counter)
void	setDataReaderActive(boolean packetReaderActive)
void	setDoneUnsafe(boolean done)
void	setEof(boolean eof)
void	setError(alluxio.worker.grpc.Error error)
void	setMeter(com.codahale.metrics.Meter meter)
void	setPosReceived(long posReceived)
void	setPosToQueue(long posToQueue)

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

isDataReaderActive

public boolean isDataReaderActive()

Returns:

whether the data reader is active

getPosToQueue

public long getPosToQueue()

Returns:

the next position to queue to the read buffer

getPosReceived

public long getPosReceived()

Returns:

the position before which data are received by the client

isEof

public boolean isEof()

Returns:

true when the data 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.grpc.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

getMeter

@Nullable
public com.codahale.metrics.Meter getMeter()

Returns:

metrics meter associated with this request

setDataReaderActive

public void setDataReaderActive(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

setPosReceived

public void setPosReceived(long posReceived)

Parameters:

posReceived - the position before which data are received by the client

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.grpc.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

setMeter

public void setMeter(com.codahale.metrics.Meter meter)

Parameters:

meter - meter to set