org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer クラス

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

org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer 連携図

公開メンバ関数
	DBLockBasedCacheInitializer (KeycloakSession session, CacheInitializer delegate)
void	initCache ()
void	loadSessions ()

限定公開メンバ関数
boolean	isFinished ()
boolean	isCoordinator ()
void	startLoading ()

非公開変数類
final KeycloakSession	session
final CacheInitializer	delegate

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

詳解

Encapsulates preloading of sessions within the DB Lock. This DB-aware lock ensures that "startLoading" is done on single DC and the other DCs need to wait.

著者

Marek Posolda

構築子と解体子

DBLockBasedCacheInitializer()

org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer.DBLockBasedCacheInitializer ( KeycloakSession  session, CacheInitializer  delegate  )

inline

                                                                                           {
        this.session = session;
        this.delegate = delegate;
    }

関数詳解

initCache()

void org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer.initCache ( )

inline

                            {
        delegate.initCache();
    }

isCoordinator()

boolean org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer.isCoordinator ( )

inlineprotected

                                      {
        return delegate.isCoordinator();
    }

isFinished()

boolean org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer.isFinished ( )

inlineprotected

                                   {
        return delegate.isFinished();
    }

loadSessions()

void org.keycloak.models.sessions.infinispan.initializer.CacheInitializer.loadSessions ( )

inlineinherited

                               {
        while (!isFinished()) {
            if (!isCoordinator()) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException ie) {
                    log.error("Interrupted", ie);
                }
            } else {
                startLoading();
            }
        }
    }

startLoading()

void org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer.startLoading ( )

inlineprotected

Just coordinator will run this. And there is DB-lock, so the delegate.startLoading() will be permitted just by the single DC

                                  {
        DBLockManager dbLockManager = new DBLockManager(session);
        dbLockManager.checkForcedUnlock();
        DBLockProvider dbLock = dbLockManager.getDBLock();
        dbLock.waitForLock();
        try {

            if (isFinished()) {
                log.infof("Task already finished when DBLock retrieved");
            } else {
                delegate.startLoading();
            }
        } finally {
            dbLock.releaseLock();
        }
    }

メンバ詳解

delegate

final CacheInitializer org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer.delegate

private

log

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

staticprivate

session

final KeycloakSession org.keycloak.models.sessions.infinispan.initializer.DBLockBasedCacheInitializer.session

private

---

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

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