org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader クラス

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

org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader 連携図

公開メンバ関数
	RemoteCacheSessionsLoader (String cacheName, int sessionsPerSegment)
void	init (KeycloakSession session)
RemoteCacheSessionsLoaderContext	computeLoaderContext (KeycloakSession session)
boolean	loadSessions (KeycloakSession session, RemoteCacheSessionsLoaderContext context, int segment)
boolean	isFinished (BaseCacheInitializer initializer)
void	afterAllSessionsLoaded (BaseCacheInitializer initializer)
String	toString ()
boolean	loadSessions (KeycloakSession session, LOADER_CONTEXT loaderContext, int segment)

限定公開メンバ関数
int	getIspnSegmentsCount (RemoteCache remoteCache)
Set< Integer >	getMyIspnSegments (int segment, RemoteCacheSessionsLoaderContext ctx)
Cache	getCache (KeycloakSession session)
RemoteCache	getRemoteCache (KeycloakSession session)

非公開変数類
final String	cacheName
final int	sessionsPerSegment

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

詳解

著者

Marek Posolda

構築子と解体子

RemoteCacheSessionsLoader()

org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.RemoteCacheSessionsLoader ( String  cacheName, int  sessionsPerSegment  )

inline

                                                                               {
        this.cacheName = cacheName;
        this.sessionsPerSegment = sessionsPerSegment;
    }

関数詳解

afterAllSessionsLoaded()

void org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.afterAllSessionsLoaded ( BaseCacheInitializer  initializer )

inline

org.keycloak.models.sessions.infinispan.initializer.SessionLoader< LOADER_CONTEXT extends SessionLoader.LoaderContext >を実装しています。

                                                                         {
    }

computeLoaderContext()

RemoteCacheSessionsLoaderContext org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.computeLoaderContext ( KeycloakSession  session )

inline

org.keycloak.models.sessions.infinispan.initializer.SessionLoader< LOADER_CONTEXT extends SessionLoader.LoaderContext >を実装しています。

                                                                                          {
        RemoteCache remoteCache = getRemoteCache(session);
        int sessionsTotal = remoteCache.size();
        int ispnSegments = getIspnSegmentsCount(remoteCache);

        return new RemoteCacheSessionsLoaderContext(ispnSegments, sessionsPerSegment, sessionsTotal);

    }

getCache()

Cache org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.getCache ( KeycloakSession  session )

inlineprotected

                                                      {
        InfinispanConnectionProvider ispn = session.getProvider(InfinispanConnectionProvider.class);
        return ispn.getCache(cacheName);
    }

getIspnSegmentsCount()

int org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.getIspnSegmentsCount ( RemoteCache  remoteCache )

inlineprotected

                                                                {
        OperationsFactory operationsFactory = ((RemoteCacheImpl) remoteCache).getOperationsFactory();

        // Same like RemoteCloseableIterator.startInternal
        IterationStartOperation iterationStartOperation = operationsFactory.newIterationStartOperation(null, null, null, sessionsPerSegment, false);
        IterationStartResponse startResponse = await(iterationStartOperation.execute());

        try {
            // Could happen for non-clustered caches
            if (startResponse.getSegmentConsistentHash() == null) {
                return -1;
            } else {
                return startResponse.getSegmentConsistentHash().getNumSegments();
            }
        } finally {
            startResponse.getChannel().close();
        }
    }

getMyIspnSegments()

Set<Integer> org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.getMyIspnSegments ( int  segment, RemoteCacheSessionsLoaderContext  ctx  )

inlineprotected

                                                                                                {
        // Remote cache is non-clustered
        if (ctx.getIspnSegmentsCount() < 0) {
            return null;
        }

        if (ctx.getIspnSegmentsCount() % ctx.getSegmentsCount() > 0) {
            throw new IllegalStateException("Illegal state. IspnSegmentsCount: " + ctx.getIspnSegmentsCount() + ", segmentsCount: " + ctx.getSegmentsCount());
        }

        int countPerSegment = ctx.getIspnSegmentsCount() / ctx.getSegmentsCount();
        int first = segment * countPerSegment;
        int last = first + countPerSegment - 1;

        Set<Integer> myIspnSegments = new HashSet<>();
        for (int i=first ; i<=last ; i++) {
            myIspnSegments.add(i);
        }
        return myIspnSegments;

    }

getRemoteCache()

RemoteCache org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.getRemoteCache ( KeycloakSession  session )

inlineprotected

                                                                  {
        InfinispanConnectionProvider ispn = session.getProvider(InfinispanConnectionProvider.class);
        return ispn.getRemoteCache(cacheName);
    }

init()

void org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.init ( KeycloakSession  session )

inline

org.keycloak.models.sessions.infinispan.initializer.SessionLoader< LOADER_CONTEXT extends SessionLoader.LoaderContext >を実装しています。

                                              {
    }

isFinished()

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

inline

org.keycloak.models.sessions.infinispan.initializer.SessionLoader< LOADER_CONTEXT extends SessionLoader.LoaderContext >を実装しています。

                                                                {
        Cache<String, Serializable> workCache = initializer.getWorkCache();

        // Check if persistent sessions were already loaded in this DC. This is possible just for offline sessions ATM
        Boolean sessionsLoaded = (Boolean) workCache
                .getAdvancedCache().withFlags(Flag.SKIP_CACHE_LOAD, Flag.SKIP_CACHE_STORE)
                .get(OfflinePersistentUserSessionLoader.PERSISTENT_SESSIONS_LOADED_IN_CURRENT_DC);

        if ((cacheName.equals(InfinispanConnectionProvider.OFFLINE_USER_SESSION_CACHE_NAME) || (cacheName.equals(InfinispanConnectionProvider.OFFLINE_CLIENT_SESSION_CACHE_NAME)))
                && sessionsLoaded != null && sessionsLoaded) {
            log.debugf("Sessions already loaded in current DC. Skip sessions loading from remote cache '%s'", cacheName);
            return true;
        } else {
            log.debugf("Sessions maybe not yet loaded in current DC. Will load them from remote cache '%s'", cacheName);
            return false;
        }
    }

loadSessions() [1/2]

boolean org.keycloak.models.sessions.infinispan.initializer.SessionLoader< LOADER_CONTEXT extends SessionLoader.LoaderContext >.loadSessions ( KeycloakSession  session, LOADER_CONTEXT  loaderContext, int  segment  )

inherited

Will be called on all cluster nodes to load the specified page.

引数

session
loaderContext	loaderContext object, which was already computed before
segment	to be computed

戻り値

loadSessions() [2/2]

boolean org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.loadSessions ( KeycloakSession  session, RemoteCacheSessionsLoaderContext  context, int  segment  )

inline

                                                                                                                {
        Cache cache = getCache(session);
        Cache decoratedCache = cache.getAdvancedCache().withFlags(Flag.SKIP_CACHE_LOAD, Flag.SKIP_CACHE_STORE, Flag.IGNORE_RETURN_VALUES);
        RemoteCache remoteCache = getRemoteCache(session);

        Set<Integer> myIspnSegments = getMyIspnSegments(segment, context);

        log.debugf("Will do bulk load of sessions from remote cache '%s' . Segment: %d", cache.getName(), segment);

        CloseableIterator<Map.Entry> iterator = null;
        int countLoaded = 0;
        try {
            iterator = remoteCache.retrieveEntries(null, myIspnSegments, context.getSessionsPerSegment());
            while (iterator.hasNext()) {
                countLoaded++;
                Map.Entry entry = iterator.next();
                decoratedCache.putAsync(entry.getKey(), entry.getValue());
            }
        } catch (RuntimeException e) {
            log.warnf(e, "Error loading sessions from remote cache '%s' for segment '%d'", remoteCache.getName(), segment);
            throw e;
        } finally {
            if (iterator != null) {
                iterator.close();
            }
        }

        log.debugf("Successfully finished loading sessions from cache '%s' . Segment: %d, Count of sessions loaded: %d", cache.getName(), segment, countLoaded);

        return true;
    }

toString()

String org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.toString ( )

inline

                             {
        return new StringBuilder("RemoteCacheSessionsLoader [ ")
                .append("cacheName: ").append(cacheName)
                .append(", sessionsPerSegment: ").append(sessionsPerSegment)
                .append(" ]")
                .toString();
    }

メンバ詳解

cacheName

final String org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.cacheName

private

log

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

staticprivate

sessionsPerSegment

final int org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader.sessionsPerSegment

private

---

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

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