alluxio.worker.netty

Class WriteRequestContext<T extends alluxio.worker.netty.WriteRequest>

java.lang.Object

alluxio.worker.netty.WriteRequestContext<T>

Type Parameters:

T - type of the write request

Direct Known Subclasses:

BlockWriteRequestContext, UfsFileWriteRequestContext

@ThreadSafe
public class WriteRequestContext<T extends alluxio.worker.netty.WriteRequest>
extends Object

Represents the context of a write 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.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	mPosToWrite The next pos to write to the block worker.

Constructor Summary

Constructors

Constructor and Description
WriteRequestContext(T request)

Method Summary

Modifier and Type	Method and Description
com.codahale.metrics.Counter	getCounter()
alluxio.worker.netty.Error	getError()
Queue<io.netty.buffer.ByteBuf>	getPackets()
long	getPosToQueue()
long	getPosToWrite()
T	getRequest()
boolean	isDoneUnsafe()
boolean	isPacketWriterActive()
void	setCounter(com.codahale.metrics.Counter counter)
void	setDoneUnsafe(boolean done)
void	setError(alluxio.worker.netty.Error error)
void	setPacketWriterActive(boolean packetWriterActive)
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

Field Detail

mPosToWrite

protected volatile long mPosToWrite

The next pos to write to the block worker. This is only updated by the packet writer thread. The netty I/O reads this only for sanity check during initialization. Using "volatile" because we want any value change of this variable to be visible across both netty and I/O threads, meanwhile only one updater means atomicity of operations is unnecessary;

Constructor Detail

WriteRequestContext

public WriteRequestContext(T request)

Parameters:

request - the write request

Method Detail

getRequest

public T getRequest()

Returns:

the write request

getPackets

public Queue<io.netty.buffer.ByteBuf> getPackets()

Returns:

the buffer for packets read from the channel

isPacketWriterActive

public boolean isPacketWriterActive()

Returns:

whether this packet writer is still active

getError

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

Returns:

the error

getPosToQueue

public long getPosToQueue()

Returns:

the next position to queue to the buffer

getPosToWrite

public long getPosToWrite()

Returns:

the next position to write to the block worker

getCounter

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

Returns:

metrics counter associated with this request

isDoneUnsafe

public boolean isDoneUnsafe()

Returns:

true when the EOF or CANCEL is received, false otherwise

setPacketWriterActive

public void setPacketWriterActive(boolean packetWriterActive)

Parameters:

packetWriterActive - whether the packet writer is active

setError

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

Parameters:

error - the error

setPosToQueue

public void setPosToQueue(long posToQueue)

Parameters:

posToQueue - the next position to queue to the buffer

setPosToWrite

public void setPosToWrite(long posToWrite)

Parameters:

posToWrite - the next position to write to the block worker

setDoneUnsafe

public void setDoneUnsafe(boolean done)

Parameters:

done - whether the EOF or CANCEL is received

setCounter

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

Parameters:

counter - counter to set