org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker クラス

org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker 連携図

公開メンバ関数
	LastSessionRefreshChecker (LastSessionRefreshStore store, LastSessionRefreshStore offlineStore)
SessionUpdateTask.CrossDCMessageStatus	shouldSaveUserSessionToRemoteCache (KeycloakSession kcSession, RealmModel realm, SessionEntityWrapper< UserSessionEntity > sessionWrapper, boolean offline, int newLastSessionRefresh)
SessionUpdateTask.CrossDCMessageStatus	shouldSaveClientSessionToRemoteCache (KeycloakSession kcSession, RealmModel realm, SessionEntityWrapper< AuthenticatedClientSessionEntity > sessionWrapper, UserSessionModel userSession, boolean offline, int newTimestamp)

静的公開変数類
static final Logger	logger = Logger.getLogger(LastSessionRefreshChecker.class)

非公開メンバ関数
SessionUpdateTask.CrossDCMessageStatus	baseChecks (KeycloakSession kcSession, RealmModel realm, boolean offline)

非公開変数類
final LastSessionRefreshStore	store
final LastSessionRefreshStore	offlineStore

詳解

著者

Marek Posolda

構築子と解体子

LastSessionRefreshChecker()

org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker.LastSessionRefreshChecker ( LastSessionRefreshStore  store, LastSessionRefreshStore  offlineStore  )

inline

                                                                                                          {
        this.store = store;
        this.offlineStore = offlineStore;
    }

関数詳解

baseChecks()

SessionUpdateTask.CrossDCMessageStatus org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker.baseChecks ( KeycloakSession  kcSession, RealmModel  realm, boolean  offline  )

inlineprivate

                                                                                                                            {
        // revokeRefreshToken always writes everything to remoteCache immediately
        if (realm.isRevokeRefreshToken()) {
            return SessionUpdateTask.CrossDCMessageStatus.SYNC;
        }

        // We're likely not in cross-dc environment. Doesn't matter what we return
        LastSessionRefreshStore storeToUse = offline ? offlineStore : store;
        if (storeToUse == null) {
            return SessionUpdateTask.CrossDCMessageStatus.SYNC;
        }

        // Received the message from the other DC that we should update the lastSessionRefresh in local cluster
        Boolean ignoreRemoteCacheUpdate = (Boolean) kcSession.getAttribute(LastSessionRefreshListener.IGNORE_REMOTE_CACHE_UPDATE);
        if (ignoreRemoteCacheUpdate != null && ignoreRemoteCacheUpdate) {
            return SessionUpdateTask.CrossDCMessageStatus.NOT_NEEDED;
        }

        return null;
    }

shouldSaveClientSessionToRemoteCache()

SessionUpdateTask.CrossDCMessageStatus org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker.shouldSaveClientSessionToRemoteCache ( KeycloakSession  kcSession, RealmModel  realm, SessionEntityWrapper< AuthenticatedClientSessionEntity >  sessionWrapper, UserSessionModel  userSession, boolean  offline, int  newTimestamp  )

inline

                                                                                                                                                                                                 {

        SessionUpdateTask.CrossDCMessageStatus baseChecks = baseChecks(kcSession, realm ,offline);
        if (baseChecks != null) {
            return baseChecks;
        }

        UUID clientSessionId = sessionWrapper.getEntity().getId();

        if (offline) {
            Integer lsrr = sessionWrapper.getLocalMetadataNoteInt(AuthenticatedClientSessionEntity.LAST_TIMESTAMP_REMOTE);
            if (lsrr == null) {
                lsrr = userSession.getStarted();
            }

            if (lsrr + (realm.getOfflineSessionIdleTimeout() / 2) <= newTimestamp) {
                    logger.debugf("We are going to write remotely for clientSession %s. Remote timestamp: %d, New timestamp: %d",
                            clientSessionId, lsrr, newTimestamp);
                return SessionUpdateTask.CrossDCMessageStatus.SYNC;
            }
        }

        if (logger.isDebugEnabled()) {
            logger.debugf("Skip writing timestamp to the remoteCache. ClientSession %s timestamp %d", clientSessionId, newTimestamp);
        }

        return SessionUpdateTask.CrossDCMessageStatus.NOT_NEEDED;
    }

shouldSaveUserSessionToRemoteCache()

SessionUpdateTask.CrossDCMessageStatus org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker.shouldSaveUserSessionToRemoteCache ( KeycloakSession  kcSession, RealmModel  realm, SessionEntityWrapper< UserSessionEntity >  sessionWrapper, boolean  offline, int  newLastSessionRefresh  )

inline

                                                                                                                                                             {

        SessionUpdateTask.CrossDCMessageStatus baseChecks = baseChecks(kcSession, realm ,offline);
        if (baseChecks != null) {
            return baseChecks;
        }

        String userSessionId = sessionWrapper.getEntity().getId();

        if (offline) {
            Integer lsrr = sessionWrapper.getLocalMetadataNoteInt(UserSessionEntity.LAST_SESSION_REFRESH_REMOTE);
            if (lsrr == null) {
                lsrr = sessionWrapper.getEntity().getStarted();
            }

            if (lsrr + (realm.getOfflineSessionIdleTimeout() / 2) <= newLastSessionRefresh) {
                logger.debugf("We are going to write remotely userSession %s. Remote last session refresh: %d, New last session refresh: %d",
                        userSessionId, lsrr, newLastSessionRefresh);
                return SessionUpdateTask.CrossDCMessageStatus.SYNC;
            }
        }

        if (logger.isDebugEnabled()) {
            logger.debugf("Skip writing last session refresh to the remoteCache. Session %s newLastSessionRefresh %d", userSessionId, newLastSessionRefresh);
        }

        LastSessionRefreshStore storeToUse = offline ? offlineStore : store;
        storeToUse.putLastSessionRefresh(kcSession, userSessionId, realm.getId(), newLastSessionRefresh);

        return SessionUpdateTask.CrossDCMessageStatus.NOT_NEEDED;
    }

メンバ詳解

logger

final Logger org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker.logger = Logger.getLogger(LastSessionRefreshChecker.class)

static

offlineStore

final LastSessionRefreshStore org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker.offlineStore

private

store

final LastSessionRefreshStore org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshChecker.store

private

---

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

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