alluxio.worker.grpc

Class UfsFallbackBlockWriteHandler

java.lang.Object

alluxio.worker.grpc.UfsFallbackBlockWriteHandler

@NotThreadSafe
public final class UfsFallbackBlockWriteHandler
extends Object

This handler handles UFS block write request. Instead of writing a block to tiered storage, this handler writes the block into UFS .

Field Summary

Fields

Modifier and Type	Field and Description
protected AuthenticatedUserInfo	mUserInfo

Method Summary

Modifier and Type	Method and Description
protected void	cancelRequest(BlockWriteRequestContext context) Cancels this write.
protected void	cleanupRequest(BlockWriteRequestContext context) Cleans up this write.
protected void	completeRequest(BlockWriteRequestContext context) Completes this write.
protected BlockWriteRequestContext	createRequestContext(WriteRequest msg) Creates a new request context.
protected void	flushRequest(BlockWriteRequestContext context) Flushes the buffered data.
protected void	handleCommand(WriteRequestCommand command, BlockWriteRequestContext context) Handles a command in the write request.
void	onCancel() Handles request cancellation event.
void	onCompleted() Handles request complete event.
void	onError(Throwable cause) Handles errors from the request.
void	write(WriteRequest writeRequest) Handles write request.
protected void	writeBuf(BlockWriteRequestContext context, io.grpc.stub.StreamObserver<WriteResponse> responseObserver, DataBuffer buf, long pos) Writes the buffer.
void	writeDataMessage(WriteRequest request, DataBuffer buffer) Handles write request with data message.

Methods inherited from class java.lang.Object

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

Field Detail

mUserInfo

protected AuthenticatedUserInfo mUserInfo

Method Detail

createRequestContext

protected BlockWriteRequestContext createRequestContext(WriteRequest msg)
                                                 throws Exception

Creates a new request context.

Parameters:

msg - the block write request

Throws:

Exception

completeRequest

protected void completeRequest(BlockWriteRequestContext context)
                        throws Exception

Completes this write. This is called when the write completes.

Parameters:

context - context of the request to complete

Throws:

Exception

cancelRequest

protected void cancelRequest(BlockWriteRequestContext context)
                      throws Exception

Cancels this write. This is called when the client issues a cancel request.

Parameters:

context - context of the request to complete

Throws:

Exception

cleanupRequest

protected void cleanupRequest(BlockWriteRequestContext context)
                       throws Exception

Cleans up this write. This is called when the write request is aborted due to any exception or session timeout.

Parameters:

context - context of the request to complete

Throws:

Exception

flushRequest

protected void flushRequest(BlockWriteRequestContext context)
                     throws Exception

Flushes the buffered data. Flush only happens after write.

Parameters:

context - context of the request to complete

Throws:

Exception

writeBuf

protected void writeBuf(BlockWriteRequestContext context,
                        io.grpc.stub.StreamObserver<WriteResponse> responseObserver,
                        DataBuffer buf,
                        long pos)
                 throws Exception

Writes the buffer.

Parameters:

context - context of the request to complete

responseObserver - the response observer

buf - the buffer

pos - the pos

Throws:

Exception

handleCommand

protected void handleCommand(WriteRequestCommand command,
                             BlockWriteRequestContext context)
                      throws Exception

Handles a command in the write request.

Parameters:

command - the command to be handled

Throws:

Exception

write

public void write(WriteRequest writeRequest)

Handles write request.

Parameters:

writeRequest - the request from the client

writeDataMessage

public void writeDataMessage(WriteRequest request,
                             DataBuffer buffer)

Handles write request with data message.

Parameters:

request - the request from the client

buffer - the data associated with the request

onCompleted

public void onCompleted()

Handles request complete event.

onCancel

public void onCancel()

Handles request cancellation event.

onError

public void onError(Throwable cause)

Handles errors from the request.

Parameters:

cause - the exception