Package net.rubyeye.xmemcached.auth
Class AuthTask
- java.lang.Object
-
- java.lang.Thread
-
- net.rubyeye.xmemcached.auth.AuthTask
-
- All Implemented Interfaces:
java.lang.Runnable
public class AuthTask extends java.lang.Thread
Authentication task
-
-
Field Summary
Fields Modifier and Type Field Description private AuthInfo
authInfo
private CommandFactory
commandFactory
static byte[]
EMPTY_BYTES
(package private) static org.slf4j.Logger
log
private MemcachedTCPSession
memcachedTCPSession
private javax.security.sasl.SaslClient
saslClient
-
Constructor Summary
Constructors Constructor Description AuthTask(AuthInfo authInfo, CommandFactory commandFactory, MemcachedTCPSession memcachedTCPSession)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
destroySaslClient()
private void
doAuth()
void
run()
private Command
startAuth()
private void
waitCommand(Command cmd, java.util.concurrent.atomic.AtomicBoolean done)
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
authInfo
private final AuthInfo authInfo
-
commandFactory
private final CommandFactory commandFactory
-
memcachedTCPSession
private MemcachedTCPSession memcachedTCPSession
-
EMPTY_BYTES
public static final byte[] EMPTY_BYTES
-
log
static final org.slf4j.Logger log
-
saslClient
private javax.security.sasl.SaslClient saslClient
-
-
Constructor Detail
-
AuthTask
public AuthTask(AuthInfo authInfo, CommandFactory commandFactory, MemcachedTCPSession memcachedTCPSession)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
doAuth
private void doAuth()
-
destroySaslClient
private void destroySaslClient()
-
startAuth
private Command startAuth() throws javax.security.sasl.SaslException
- Throws:
javax.security.sasl.SaslException
-
waitCommand
private void waitCommand(Command cmd, java.util.concurrent.atomic.AtomicBoolean done)
-
-