alluxio.worker

Class SessionCleaner

java.lang.Object

alluxio.worker.SessionCleaner

All Implemented Interfaces:

Runnable

@NotThreadSafe
public final class SessionCleaner
extends Object
implements Runnable

SessionCleaner periodically checks if any session have become zombies, removes the zombie session and associated data when necessary. The syncing parameters (intervals) adopt directly from worker-to-master heartbeat configurations.

Constructor Summary

Constructors

Constructor and Description
SessionCleaner(Sessions sessions, SessionCleanable... sessionCleanable) Creates a new instance of SessionCleaner.

Method Summary

Modifier and Type	Method and Description
void	run() Main loop for the cleanup, continuously looks for zombie sessions.
void	stop() Stops the checking, once this method is called, the object should be discarded.

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionCleaner

public SessionCleaner(Sessions sessions,
                      SessionCleanable... sessionCleanable)

Creates a new instance of SessionCleaner.

Parameters:

sessions - the worker's sessions will be clean up by callback if which has been timeout

sessionCleanable - who wants to cleanup the session

Method Detail

run

public void run()

Main loop for the cleanup, continuously looks for zombie sessions.

Specified by:

run in interface Runnable

stop

public void stop()

Stops the checking, once this method is called, the object should be discarded.