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

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

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

公開メンバ関数
	BaseCacheInitializer (KeycloakSessionFactory sessionFactory, Cache< String, Serializable > workCache, SessionLoader sessionLoader, String stateKeySuffix, int sessionsPerSegment)
Cache< String, Serializable >	getWorkCache ()
void	initCache ()
void	loadSessions ()

限定公開メンバ関数
boolean	isFinished ()
boolean	isCoordinator ()
InitializerState	getStateFromCache ()
void	saveStateToCache (final InitializerState state)
abstract void	startLoading ()

限定公開変数類
final KeycloakSessionFactory	sessionFactory
final Cache< String, Serializable >	workCache
final SessionLoader	sessionLoader
final int	sessionsPerSegment
final String	stateKey

非公開メンバ関数
void	retry (int retry, Runnable runnable)

静的非公開変数類
static final String	STATE_KEY_PREFIX = "distributed::"
static final Logger	log = Logger.getLogger(BaseCacheInitializer.class)

詳解

著者

Marek Posolda

構築子と解体子

BaseCacheInitializer()

org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.BaseCacheInitializer ( KeycloakSessionFactory  sessionFactory, Cache< String, Serializable >  workCache, SessionLoader  sessionLoader, String  stateKeySuffix, int  sessionsPerSegment  )

inline

                                                                                                                                                                                          {
        this.sessionFactory = sessionFactory;
        this.workCache = workCache;
        this.sessionLoader = sessionLoader;
        this.sessionsPerSegment = sessionsPerSegment;
        this.stateKey = STATE_KEY_PREFIX + stateKeySuffix;
    }

関数詳解

getStateFromCache()

InitializerState org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.getStateFromCache ( )

inlineprotected

                                                   {
        // We ignore cacheStore for now, so that in Cross-DC scenario (with RemoteStore enabled) is the remoteStore ignored.
        return (InitializerState) workCache.getAdvancedCache()
                .withFlags(Flag.SKIP_CACHE_STORE, Flag.SKIP_CACHE_LOAD)
                .get(stateKey);
    }

getWorkCache()

Cache<String, Serializable> org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.getWorkCache ( )

inline

                                                      {
        return workCache;
    }

initCache()

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

inlineinherited

                            {
    }

isCoordinator()

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

inlineprotected

                                      {
        Transport transport = workCache.getCacheManager().getTransport();
        return transport == null || transport.isCoordinator();
    }

isFinished()

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

inlineprotected

                                   {
        // Check if we should skipLoadingSessions. This can happen if someone else already did the task (For example in cross-dc environment, it was done by different DC)
        boolean isFinishedAlready = this.sessionLoader.isFinished(this);
        if (isFinishedAlready) {
            return true;
        }

        InitializerState state = getStateFromCache();
        return state != null && state.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();
            }
        }
    }

retry()

void org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.retry ( int  retry, Runnable  runnable  )

inlineprivate

                                                     {
        while (true) {
            try {
                runnable.run();
                return;
            } catch (RuntimeException e) {
                ComponentStatus status = workCache.getStatus();
                if (status.isStopping() || status.isTerminated()) {
                    log.warn("Failed to put initializerState to the cache. Cache is already terminating");
                    log.debug(e.getMessage(), e);
                    return;
                }
                retry--;
                if (retry == 0) {
                    throw e;
                }
            }
        }
    }

saveStateToCache()

void org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.saveStateToCache ( final InitializerState  state )

inlineprotected

                                                                  {

        // 3 attempts to send the message (it may fail if some node fails in the meantime)
        retry(3, new Runnable() {

            @Override
            public void run() {

                // Save this synchronously to ensure all nodes read correct state
                // We ignore cacheStore for now, so that in Cross-DC scenario (with RemoteStore enabled) is the remoteStore ignored.
                BaseCacheInitializer.this.workCache.getAdvancedCache().
                        withFlags(Flag.IGNORE_RETURN_VALUES, Flag.FORCE_SYNCHRONOUS, Flag.SKIP_CACHE_STORE, Flag.SKIP_CACHE_LOAD)
                        .put(stateKey, state);
            }

        });
    }

startLoading()

abstract void org.keycloak.models.sessions.infinispan.initializer.CacheInitializer.startLoading ( )

abstractprotectedinherited

Just coordinator will run this

メンバ詳解

log

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

staticprivate

sessionFactory

final KeycloakSessionFactory org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.sessionFactory

protected

sessionLoader

final SessionLoader org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.sessionLoader

protected

sessionsPerSegment

final int org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.sessionsPerSegment

protected

STATE_KEY_PREFIX

final String org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.STATE_KEY_PREFIX = "distributed::"

staticprivate

stateKey

final String org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.stateKey

protected

workCache

final Cache<String, Serializable> org.keycloak.models.sessions.infinispan.initializer.BaseCacheInitializer.workCache

protected

---

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

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