tachyon.worker

Class WorkerServiceHandler

java.lang.Object

tachyon.worker.WorkerServiceHandler

All Implemented Interfaces:

WorkerService.Iface

public class WorkerServiceHandler
extends Object
implements WorkerService.Iface

WorkerServiceHandler handles all the RPC calls to the worker.

Constructor Summary

Constructors

Constructor and Description
WorkerServiceHandler(WorkerStorage workerStorage)

Method Summary

Methods

Modifier and Type	Method and Description
void	accessBlock(long blockId)
void	addCheckpoint(long userId, int fileId)
boolean	asyncCheckpoint(int fileId)
void	cacheBlock(long userId, long blockId) Used to cache a block into Tachyon space, worker will move the temporary block file from user folder to data folder, and update the space usage information related.
void	cancelBlock(long userId, long blockId) Used to cancel a block which is being written.
String	getUserUfsTempFolder(long userId) Used to get user's temporary folder on under file system, and the path of the user's temporary folder will be returned.
String	lockBlock(long blockId, long userId) Lock the file in Tachyon's space while the user is reading it, and the path of the block file locked will be returned, if the block file is not found, FileDoesNotExistException will be thrown.
boolean	promoteBlock(long blockId) Used to promote block on under storage layer to top storage layer when there are more than one storage layers in Tachyon's space.
String	requestBlockLocation(long userId, long blockId, long initialBytes) Used to allocate location and space for a new coming block, worker will choose the appropriate storage directory which fits the initial block size by some allocation strategy, and the temporary file path of the block file will be returned.
boolean	requestSpace(long userId, long blockId, long requestBytes) Used to request space for some block file.
boolean	unlockBlock(long blockId, long userId) Used to unlock a block after the block is accessed, if the block is to be removed, delete the block file.
void	userHeartbeat(long userId) Local user send heartbeat to local worker to keep its temporary folder.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerServiceHandler

public WorkerServiceHandler(WorkerStorage workerStorage)

Method Detail

accessBlock

public void accessBlock(long blockId)
                 throws org.apache.thrift.TException

Specified by:

accessBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

addCheckpoint

public void addCheckpoint(long userId,
                 int fileId)
                   throws FileDoesNotExistException,
                          SuspectedFileSizeException,
                          FailedToCheckpointException,
                          BlockInfoException,
                          org.apache.thrift.TException

Specified by:

addCheckpoint in interface WorkerService.Iface

Throws:

FileDoesNotExistException

SuspectedFileSizeException

FailedToCheckpointException

BlockInfoException

org.apache.thrift.TException

asyncCheckpoint

public boolean asyncCheckpoint(int fileId)
                        throws TachyonException,
                               org.apache.thrift.TException

Specified by:

asyncCheckpoint in interface WorkerService.Iface

Throws:

TachyonException

org.apache.thrift.TException

cacheBlock

public void cacheBlock(long userId,
              long blockId)
                throws FileDoesNotExistException,
                       SuspectedFileSizeException,
                       BlockInfoException,
                       org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to cache a block into Tachyon space, worker will move the temporary block file from user folder to data folder, and update the space usage information related. then update the block information to master.

Specified by:

cacheBlock in interface WorkerService.Iface

Throws:

FileDoesNotExistException

SuspectedFileSizeException

BlockInfoException

org.apache.thrift.TException

cancelBlock

public void cancelBlock(long userId,
               long blockId)
                 throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to cancel a block which is being written. worker will delete the temporary block file and the location and space information related, then reclaim space allocated to the block.

Specified by:

cancelBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

getUserUfsTempFolder

public String getUserUfsTempFolder(long userId)
                            throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to get user's temporary folder on under file system, and the path of the user's temporary folder will be returned.

Specified by:

getUserUfsTempFolder in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

lockBlock

public String lockBlock(long blockId,
               long userId)
                 throws FileDoesNotExistException,
                        org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Lock the file in Tachyon's space while the user is reading it, and the path of the block file locked will be returned, if the block file is not found, FileDoesNotExistException will be thrown.

Specified by:

lockBlock in interface WorkerService.Iface

Throws:

FileDoesNotExistException

org.apache.thrift.TException

promoteBlock

public boolean promoteBlock(long blockId)
                     throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to promote block on under storage layer to top storage layer when there are more than one storage layers in Tachyon's space. return true if the block is successfully promoted, false otherwise.

Specified by:

promoteBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

requestBlockLocation

public String requestBlockLocation(long userId,
                          long blockId,
                          long initialBytes)
                            throws OutOfSpaceException,
                                   FileAlreadyExistException,
                                   org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to allocate location and space for a new coming block, worker will choose the appropriate storage directory which fits the initial block size by some allocation strategy, and the temporary file path of the block file will be returned. if there is no enough space on Tachyon storage OutOfSpaceException will be thrown, if the file is already being written by the user, FileAlreadyExistException will be thrown.

Specified by:

requestBlockLocation in interface WorkerService.Iface

Throws:

OutOfSpaceException

FileAlreadyExistException

org.apache.thrift.TException

requestSpace

public boolean requestSpace(long userId,
                   long blockId,
                   long requestBytes)
                     throws FileDoesNotExistException,
                            org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to request space for some block file. return true if the worker successfully allocates space for the block on block’s location, false if there is no enough space, if there is no information of the block on worker, FileDoesNotExistException will be thrown.

Specified by:

requestSpace in interface WorkerService.Iface

Throws:

FileDoesNotExistException

org.apache.thrift.TException

unlockBlock

public boolean unlockBlock(long blockId,
                  long userId)
                    throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to unlock a block after the block is accessed, if the block is to be removed, delete the block file. return true if successfully unlock the block, return false if the block is not found or failed to delete the block.

Specified by:

unlockBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

userHeartbeat

public void userHeartbeat(long userId)
                   throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Local user send heartbeat to local worker to keep its temporary folder.

Specified by:

userHeartbeat in interface WorkerService.Iface

Throws:

org.apache.thrift.TException