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.ThreadAuthentication task
-
-
Field Summary
Fields Modifier and Type Field Description private AuthInfoauthInfoprivate CommandFactorycommandFactorystatic byte[]EMPTY_BYTES(package private) static org.slf4j.Loggerlogprivate MemcachedTCPSessionmemcachedTCPSessionprivate javax.security.sasl.SaslClientsaslClient
-
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 voiddestroySaslClient()private voiddoAuth()voidrun()private CommandstartAuth()private voidwaitCommand(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:
runin interfacejava.lang.Runnable- Overrides:
runin 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)
-
-