@InterfaceAudience.Private public class DelegationTokenRenewer extends Thread
Modifier and Type | Class and Description |
---|---|
static interface |
DelegationTokenRenewer.Renewable
The renewable interface used by the renewer.
|
static class |
DelegationTokenRenewer.RenewAction<T extends FileSystem & DelegationTokenRenewer.Renewable>
An action that will renew and replace the file system's delegation
tokens automatically.
|
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
static long |
renewCycle |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Modifier and Type | Method and Description |
---|---|
<T extends FileSystem & DelegationTokenRenewer.Renewable> |
addRenewAction(T fs)
Add a renew action to the queue.
|
static DelegationTokenRenewer |
getInstance() |
protected int |
getRenewQueueLength()
For testing purposes
|
<T extends FileSystem & DelegationTokenRenewer.Renewable> |
removeRenewAction(T fs)
Remove the associated renew action from the queue
|
void |
run() |
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
@InterfaceAudience.Private public static long renewCycle
protected int getRenewQueueLength()
public static DelegationTokenRenewer getInstance()
public <T extends FileSystem & DelegationTokenRenewer.Renewable> DelegationTokenRenewer.RenewAction<T> addRenewAction(T fs)
public <T extends FileSystem & DelegationTokenRenewer.Renewable> void removeRenewAction(T fs) throws IOException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.