org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider クラス

org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider の継承関係図

org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider 連携図

公開メンバ関数
	InfinispanAuthenticationSessionProvider (KeycloakSession session, InfinispanKeyGenerator keyGenerator, Cache< String, RootAuthenticationSessionEntity > cache)
RootAuthenticationSessionModel	createRootAuthenticationSession (RealmModel realm)
RootAuthenticationSessionModel	createRootAuthenticationSession (String id, RealmModel realm)
void	removeExpired (RealmModel realm)
void	onRealmRemoved (RealmModel realm)
void	onClientRemoved (RealmModel realm, ClientModel client)
void	updateNonlocalSessionAuthNotes (AuthenticationSessionCompoundId compoundId, Map< String, String > authNotesFragment)
RootAuthenticationSessionModel	getRootAuthenticationSession (RealmModel realm, String authenticationSessionId)
void	removeRootAuthenticationSession (RealmModel realm, RootAuthenticationSessionModel authenticationSession)
void	close ()
Cache< String, RootAuthenticationSessionEntity >	getCache ()

限定公開メンバ関数
void	onRealmRemovedEvent (String realmId)
void	onClientRemovedEvent (String realmId, String clientUuid)
String	generateTabId ()

限定公開変数類
final InfinispanKeycloakTransaction	tx
final SessionEventsSenderTransaction	clusterEventsSenderTx

非公開メンバ関数
RootAuthenticationSessionAdapter	wrap (RealmModel realm, RootAuthenticationSessionEntity entity)
RootAuthenticationSessionEntity	getRootAuthenticationSessionEntity (String authSessionId)

非公開変数類
final KeycloakSession	session
final Cache< String, RootAuthenticationSessionEntity >	cache
final InfinispanKeyGenerator	keyGenerator

静的非公開変数類
static final Logger	log = Logger.getLogger(InfinispanAuthenticationSessionProvider.class)

詳解

著者

Marek Posolda

構築子と解体子

InfinispanAuthenticationSessionProvider()

org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.InfinispanAuthenticationSessionProvider ( KeycloakSession  session, InfinispanKeyGenerator  keyGenerator, Cache< String, RootAuthenticationSessionEntity >  cache  )

inline

                                                                                                                                                                       {
        this.session = session;
        this.cache = cache;
        this.keyGenerator = keyGenerator;

        this.tx = new InfinispanKeycloakTransaction();
        this.clusterEventsSenderTx = new SessionEventsSenderTransaction(session);

        session.getTransactionManager().enlistAfterCompletion(tx);
        session.getTransactionManager().enlistAfterCompletion(clusterEventsSenderTx);
    }

関数詳解

close()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.close ( )

inline

org.keycloak.provider.Providerを実装しています。

                        {

    }

createRootAuthenticationSession() [1/2]

RootAuthenticationSessionModel org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.createRootAuthenticationSession ( RealmModel  realm )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                                                            {
        String id = keyGenerator.generateKeyString(session, cache);
        return createRootAuthenticationSession(id, realm);
    }

createRootAuthenticationSession() [2/2]

RootAuthenticationSessionModel org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.createRootAuthenticationSession ( String  id, RealmModel  realm  )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                                                                       {
        RootAuthenticationSessionEntity entity = new RootAuthenticationSessionEntity();
        entity.setId(id);
        entity.setRealmId(realm.getId());
        entity.setTimestamp(Time.currentTime());

        tx.put(cache, id, entity);

        return wrap(realm, entity);
    }

generateTabId()

String org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.generateTabId ( )

inlineprotected

                                     {
        return Base64Url.encode(KeycloakModelUtils.generateSecret(8));
    }

getCache()

Cache<String, RootAuthenticationSessionEntity> org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.getCache ( )

inline

                                                                     {
        return cache;
    }

getRootAuthenticationSession()

RootAuthenticationSessionModel org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.getRootAuthenticationSession ( RealmModel  realm, String  authenticationSessionId  )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                                                                                         {
        RootAuthenticationSessionEntity entity = getRootAuthenticationSessionEntity(authenticationSessionId);
        return wrap(realm, entity);
    }

getRootAuthenticationSessionEntity()

RootAuthenticationSessionEntity org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.getRootAuthenticationSessionEntity ( String  authSessionId )

inlineprivate

                                                                                                     {
        // Chance created in this transaction
        RootAuthenticationSessionEntity entity = tx.get(cache, authSessionId);

        if (entity == null) {
            entity = cache.get(authSessionId);
        }

        return entity;
    }

onClientRemoved()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.onClientRemoved ( RealmModel  realm, ClientModel  client  )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                                      {
        // No update anything on clientRemove for now. AuthenticationSessions of removed client will be handled at runtime if needed.

//        clusterEventsSenderTx.addEvent(
//                ClientRemovedSessionEvent.create(session, InfinispanAuthenticationSessionProviderFactory.CLIENT_REMOVED_AUTHSESSION_EVENT, realm.getId(), false, client.getId()),
//                ClusterProvider.DCNotify.ALL_DCS);
    }

onClientRemovedEvent()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.onClientRemovedEvent ( String  realmId, String  clientUuid  )

inlineprotected

                                                                           {

    }

onRealmRemoved()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.onRealmRemoved ( RealmModel  realm )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                 {
        // Send message to all DCs. The remoteCache will notify client listeners on all DCs for remove authentication sessions
        clusterEventsSenderTx.addEvent(
                RealmRemovedSessionEvent.createEvent(RealmRemovedSessionEvent.class, InfinispanAuthenticationSessionProviderFactory.REALM_REMOVED_AUTHSESSION_EVENT, session, realm.getId(), false),
                ClusterProvider.DCNotify.ALL_DCS);
    }

onRealmRemovedEvent()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.onRealmRemovedEvent ( String  realmId )

inlineprotected

                                                       {
        Iterator<Map.Entry<String, RootAuthenticationSessionEntity>> itr = CacheDecorators.localCache(cache)
                .entrySet()
                .stream()
                .filter(RootAuthenticationSessionPredicate.create(realmId))
                .iterator();

        while (itr.hasNext()) {
            CacheDecorators.localCache(cache)
                    .remove(itr.next().getKey());
        }
    }

removeExpired()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.removeExpired ( RealmModel  realm )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                {
        log.debugf("Removing expired sessions");

        int expired = Time.currentTime() - RealmInfoUtil.getDettachedClientSessionLifespan(realm);


        // Each cluster node cleanups just local sessions, which are those owned by himself (+ few more taking l1 cache into account)
        Iterator<Map.Entry<String, RootAuthenticationSessionEntity>> itr = CacheDecorators.localCache(cache)
                .entrySet()
                .stream()
                .filter(RootAuthenticationSessionPredicate.create(realm.getId()).expired(expired))
                .iterator();

        int counter = 0;
        while (itr.hasNext()) {
            counter++;
            RootAuthenticationSessionEntity entity = itr.next().getValue();
            tx.remove(cache, entity.getId());
        }

        log.debugf("Removed %d expired authentication sessions for realm '%s'", counter, realm.getName());
    }

removeRootAuthenticationSession()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.removeRootAuthenticationSession ( RealmModel  realm, RootAuthenticationSessionModel  authenticationSession  )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                                                                                        {
        tx.remove(cache, authenticationSession.getId());
    }

updateNonlocalSessionAuthNotes()

void org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.updateNonlocalSessionAuthNotes ( AuthenticationSessionCompoundId  compoundId, Map< String, String >  authNotesFragment  )

inline

org.keycloak.sessions.AuthenticationSessionProviderを実装しています。

                                                                                                                                  {
        if (compoundId == null) {
            return;
        }

        ClusterProvider cluster = session.getProvider(ClusterProvider.class);
        cluster.notify(
          InfinispanAuthenticationSessionProviderFactory.AUTHENTICATION_SESSION_EVENTS,
          AuthenticationSessionAuthNoteUpdateEvent.create(compoundId.getRootSessionId(), compoundId.getTabId(), compoundId.getClientUUID(), authNotesFragment),
          true,
          ClusterProvider.DCNotify.ALL_BUT_LOCAL_DC
        );
    }

wrap()

RootAuthenticationSessionAdapter org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.wrap ( RealmModel  realm, RootAuthenticationSessionEntity  entity  )

inlineprivate

                                                                                                            {
        return entity==null ? null : new RootAuthenticationSessionAdapter(session, this, cache, realm, entity);
    }

メンバ詳解

cache

final Cache<String, RootAuthenticationSessionEntity> org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.cache

private

clusterEventsSenderTx

final SessionEventsSenderTransaction org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.clusterEventsSenderTx

protected

keyGenerator

final InfinispanKeyGenerator org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.keyGenerator

private

log

final Logger org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.log = Logger.getLogger(InfinispanAuthenticationSessionProvider.class)

staticprivate

session

final KeycloakSession org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.session

private

tx

final InfinispanKeycloakTransaction org.keycloak.models.sessions.infinispan.InfinispanAuthenticationSessionProvider.tx

protected

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/models/sessions/infinispan/InfinispanAuthenticationSessionProvider.java