Class AuthThreadMonitor


  • public class AuthThreadMonitor
    extends SpyObject
    This will ensure no more than one AuthThread will exist for a given MemcachedNode.
    • Field Detail

      • nodeMap

        private final java.util.Map<java.lang.Object,​AuthThread> nodeMap
    • Constructor Detail

      • AuthThreadMonitor

        public AuthThreadMonitor()
    • Method Detail

      • authConnection

        public void authConnection​(MemcachedConnection conn,
                                   OperationFactory opFact,
                                   AuthDescriptor authDescriptor,
                                   MemcachedNode node)
        Authenticate a new connection. This is typically used by a MemcachedNode in order to authenticate a connection right after it has been established. If an old, but not yet completed authentication exists this will stop it in order to create a new authentication attempt.
        Parameters:
        conn -
        opFact -
        authDescriptor -
        node -
      • interruptAllPendingAuth

        public void interruptAllPendingAuth()
        Interrupt all pending AuthThreads. While shutting down a connection, if there are any AuthThreads running, terminate them so that the java process can exit gracefully ( otherwise it will wait infinitely).
      • interruptOldAuth

        private void interruptOldAuth​(MemcachedNode nodeToStop)
      • getNodeMap

        protected java.util.Map<java.lang.Object,​AuthThread> getNodeMap()
        Returns Map of AuthThread for testing authentication mechanisms for different server versions. It should not be accessed from anywhere else.
        Returns: