alluxio.worker.dora

Class DoraOpenFileHandleContainer

java.lang.Object

java.lang.Thread

alluxio.worker.dora.DoraOpenFileHandleContainer

All Implemented Interfaces:

Runnable

public class DoraOpenFileHandleContainer
extends Thread

A collection of open file handles in a dora worker. It is also a thread, and will run periodic checking of stale open handles.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method and Description
boolean	add(String key, OpenFileHandle handle) Add a open file handle into this collection.
OpenFileHandle	find(String key) Find an open file handle by its key.
OpenFileHandle	findAndVerify(String key, String uuid) Find an open file handle by its key, and verify against its uuid.
void	remove(String key) Remove a specified key.
void	run()
void	shutdown() Wakeup the current thread and ask it to stop.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

add

public boolean add(String key,
                   OpenFileHandle handle)

Add a open file handle into this collection.

Parameters:

key -

handle -

Returns:

true if succeeded, otherwise false is returned

find

@Nullable
public OpenFileHandle find(String key)

Find an open file handle by its key.

Parameters:

key -

Returns:

a valid open file handle if succeeded, null if not found

findAndVerify

@Nullable
public OpenFileHandle findAndVerify(String key,
                                              String uuid)

Find an open file handle by its key, and verify against its uuid. If the file handle exists but the uuid verification fails, null will be returned.

Parameters:

key -

uuid - the uuid of open file from client side

Returns:

a valid open file handle if succeeded, null if not found or verification failed

remove

public void remove(String key)

Remove a specified key.

Parameters:

key - the key to remove

shutdown

public void shutdown()

Wakeup the current thread and ask it to stop.