tachyon.worker

Class WorkerClient

java.lang.Object

tachyon.worker.WorkerClient

public class WorkerClient
extends Object

The client talks to a worker server. It keeps sending keep alive message to the worker server. Since WorkerService.Client is not thread safe, this class has to guarantee thread safe.

Constructor Summary

Constructors

Constructor and Description
WorkerClient(InetSocketAddress address, long userId)

Method Summary

Modifier and Type	Method and Description
void	accessBlock(long blockId) Update the latest block access time on the worker.
void	addCheckpoint(long userId, int fileId) Notify the worker that the checkpoint file of the file has been added.
boolean	asyncCheckpoint(int fid) Notify the worker to checkpoint the file asynchronously.
void	cacheBlock(long userId, long blockId) Notify the worker the block is cached.
void	close() Close the connection to worker.
String	getDataFolder()
String	getUserTempFolder(long userId) Get the local user temporary folder of the specified user.
String	getUserUnderfsTempFolder(long userId) Get the user temporary folder in the under file system of the specified user.
boolean	isConnected()
void	lockBlock(long blockId, long userId) Lock the block, therefore, the worker will lock evict the block from the memory untill it is unlocked.
boolean	open() Open the connection to the worker.
boolean	requestSpace(long userId, long requestBytes) Request space from the worker's memory
void	returnSpace(long userId, long returnSpaceBytes) Return the space which has been requested
void	unlockBlock(long blockId, long userId) Unlock the block
void	userHeartbeat(long userId) Users' heartbeat to the Worker.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerClient

public WorkerClient(InetSocketAddress address,
                    long userId)

Parameters:

address - The address of the worker the client trying to contect to.

userId - The user id of the client

Method Detail

accessBlock

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

Update the latest block access time on the worker.

Parameters:

blockId - The id of the block

Throws:

org.apache.thrift.TException

addCheckpoint

public void addCheckpoint(long userId,
                          int fileId)
                   throws IOException,
                          org.apache.thrift.TException

Notify the worker that the checkpoint file of the file has been added.

Parameters:

userId - The user id of the client who send the notification

fileId - The id of the checkpointed file

Throws:

IOException

org.apache.thrift.TException

asyncCheckpoint

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

Notify the worker to checkpoint the file asynchronously.

Parameters:

fid - The id of the file

Returns:

true if succeed, false otherwise

Throws:

TachyonException

org.apache.thrift.TException

cacheBlock

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

Notify the worker the block is cached.

Parameters:

userId - The user id of the client who send the notification

blockId - The id of the block

Throws:

IOException

org.apache.thrift.TException

close

public void close()

Close the connection to worker. Shutdown the heartbeat thread.

getDataFolder

public String getDataFolder()
                     throws org.apache.thrift.TException

Returns:

The root local data folder of the worker

Throws:

org.apache.thrift.TException

getUserTempFolder

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

Get the local user temporary folder of the specified user.

Parameters:

userId - The id of the user

Returns:

The local user temporary folder of the specified user

Throws:

org.apache.thrift.TException

getUserUnderfsTempFolder

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

Get the user temporary folder in the under file system of the specified user.

Parameters:

userId - The id of the user

Returns:

The user temporary folder in the under file system

Throws:

org.apache.thrift.TException

isConnected

public boolean isConnected()

Returns:

true if it's connected to the worker, false otherwise

lockBlock

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

Lock the block, therefore, the worker will lock evict the block from the memory untill it is unlocked.

Parameters:

blockId - The id of the block

userId - The id of the user who wants to lock the block

Throws:

org.apache.thrift.TException

open

public boolean open()

Open the connection to the worker. And start the heartbeat thread.

Returns:

true if succeed, false otherwise

requestSpace

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

Request space from the worker's memory

Parameters:

userId - The id of the user who send the request

requestBytes - The requested space size, in bytes

Returns:

true if succeed, false otherwise

Throws:

org.apache.thrift.TException

returnSpace

public void returnSpace(long userId,
                        long returnSpaceBytes)
                 throws org.apache.thrift.TException

Return the space which has been requested

Parameters:

userId - The id of the user who wants to return the space

returnSpaceBytes - The returned space size, in bytes

Throws:

org.apache.thrift.TException

unlockBlock

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

Unlock the block

Parameters:

blockId - The id of the block

userId - The id of the user who wants to unlock the block

Throws:

org.apache.thrift.TException

userHeartbeat

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

Users' heartbeat to the Worker.

Parameters:

userId - The id of the user

Throws:

org.apache.thrift.TException