tachyon.worker

Class WorkerClient

java.lang.Object

tachyon.worker.WorkerClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class WorkerClient
extends Object
implements Closeable

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(MasterClient masterClient, ExecutorService executorService) Create a WorkerClient, with a given MasterClient.

Method Summary

Methods

Modifier and Type	Method and Description
void	accessBlock(long blockId) Update the latest block access time on the worker.
void	addCheckpoint(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 blockId) Notify the worker the block is cached.
void	cancelBlock(long blockId) Notify worker that the block has been cancelled
void	close() Close the connection to worker.
InetSocketAddress	getAddress()
String	getUserUfsTempFolder() Get the user temporary folder in the under file system of the specified user.
boolean	isConnected()
boolean	isLocal()
String	lockBlock(long blockId) Lock the block, therefore, the worker will not evict the block from the memory until it is unlocked.
void	mustConnect() Connect to the worker.
boolean	promoteBlock(long blockId) Promote block back to the top StorageTier
String	requestBlockLocation(long blockId, long initialBytes) Get temporary path for the block from the worker
boolean	requestSpace(long blockId, long requestBytes) Request space for some block from worker
boolean	unlockBlock(long blockId) 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(MasterClient masterClient,
            ExecutorService executorService)
             throws IOException

Create a WorkerClient, with a given MasterClient.

Parameters:

masterClient -

executorService -

Throws:

IOException

Method Detail

accessBlock

public void accessBlock(long blockId)
                 throws IOException

Update the latest block access time on the worker.

Parameters:

blockId - The id of the block

Throws:

IOException

addCheckpoint

public void addCheckpoint(int fileId)
                   throws IOException

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

Parameters:

fileId - The id of the checkpointed file

Throws:

IOException

asyncCheckpoint

public boolean asyncCheckpoint(int fid)
                        throws IOException

Notify the worker to checkpoint the file asynchronously.

Parameters:

fid - The id of the file

Returns:

true if success, false otherwise

Throws:

IOException

cacheBlock

public void cacheBlock(long blockId)
                throws IOException

Notify the worker the block is cached.

Parameters:

blockId - The id of the block

Throws:

IOException

cancelBlock

public void cancelBlock(long blockId)
                 throws IOException

Notify worker that the block has been cancelled

Parameters:

blockId - The Id of the block to be cancelled

Throws:

IOException

close

public void close()

Close the connection to worker. Shutdown the heartbeat thread.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getAddress

public InetSocketAddress getAddress()

Returns:

the address of the worker.

getUserUfsTempFolder

public String getUserUfsTempFolder()
                            throws IOException

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

Returns:

The user temporary folder in the under file system

Throws:

IOException

isConnected

public boolean isConnected()

Returns:

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

isLocal

public boolean isLocal()

Returns:

true if the worker is local, false otherwise.

lockBlock

public String lockBlock(long blockId)
                 throws IOException

Lock the block, therefore, the worker will not evict the block from the memory until it is unlocked.

Parameters:

blockId - The id of the block

Returns:

the path of the block file locked

Throws:

IOException

mustConnect

public void mustConnect()
                 throws IOException

Connect to the worker.

Throws:

IOException

promoteBlock

public boolean promoteBlock(long blockId)
                     throws IOException

Promote block back to the top StorageTier

Parameters:

blockId - The id of the block that will be promoted

Returns:

true if succeed, false otherwise

Throws:

IOException

requestBlockLocation

public String requestBlockLocation(long blockId,
                          long initialBytes)
                            throws IOException

Get temporary path for the block from the worker

Parameters:

blockId - The id of the block

initialBytes - The initial size bytes allocated for the block

Returns:

the temporary path of the block

Throws:

IOException

requestSpace

public boolean requestSpace(long blockId,
                   long requestBytes)
                     throws IOException

Request space for some block from worker

Parameters:

blockId - The id of the block

requestBytes - The requested space size, in bytes

Returns:

true if success, false otherwise

Throws:

IOException

unlockBlock

public boolean unlockBlock(long blockId)
                    throws IOException

Unlock the block

Parameters:

blockId - The id of the block

Returns:

true if success, false otherwise

Throws:

IOException

userHeartbeat

public void userHeartbeat(long userId)
                   throws IOException

Users' heartbeat to the Worker.

Parameters:

userId - The id of the user

Throws:

IOException