Package org.keycloak.models.sessions.infinispan.remotestore

Class RemoteCacheSessionsLoader

java.lang.Object

org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionsLoader

All Implemented Interfaces:

SessionLoader<RemoteCacheSessionsLoaderContext,SessionLoader.WorkerContext,SessionLoader.WorkerResult>

public class RemoteCacheSessionsLoader
extends Object
implements SessionLoader<RemoteCacheSessionsLoaderContext,SessionLoader.WorkerContext,SessionLoader.WorkerResult>

Author:

Marek Posolda

Nested Class Summary

Nested classes/interfaces inherited from interface org.keycloak.models.sessions.infinispan.initializer.SessionLoader

SessionLoader.LoaderContext, SessionLoader.WorkerContext, SessionLoader.WorkerResult

Constructor Summary

Constructors

Constructor	Description
RemoteCacheSessionsLoader(String cacheName, int sessionsPerSegment)

Method Summary

Modifier and Type	Method	Description
void	afterAllSessionsLoaded()	Callback triggered on cluster coordinator once it recognize that all sessions were successfully loaded
RemoteCacheSessionsLoaderContext	computeLoaderContext()	Will be triggered just once on cluster coordinator node to count the number of segments and other context data specific to whole computation.
SessionLoader.WorkerContext	computeWorkerContext(int segment)	Compute the worker context for current iteration
protected org.infinispan.Cache	getCache(KeycloakSession session)
protected org.infinispan.client.hotrod.RemoteCache	getRemoteCache(KeycloakSession session)
SessionLoader.WorkerResult	loadSessions(KeycloakSession session, RemoteCacheSessionsLoaderContext loaderContext, SessionLoader.WorkerContext ctx)	Will be called on all cluster nodes to load the specified page.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

RemoteCacheSessionsLoader

public RemoteCacheSessionsLoader(String cacheName,
 int sessionsPerSegment)

Method Details

computeLoaderContext

public RemoteCacheSessionsLoaderContext computeLoaderContext()

Description copied from interface: SessionLoader

Will be triggered just once on cluster coordinator node to count the number of segments and other context data specific to whole computation. Each segment will be then later computed in one "worker" task This method could be expensive to call, so the "computed" loaderContext object is passed among workers/loaders and needs to be serializable

Specified by:

computeLoaderContext in interface SessionLoader<RemoteCacheSessionsLoaderContext,SessionLoader.WorkerContext,SessionLoader.WorkerResult>

Returns:

computeWorkerContext

public SessionLoader.WorkerContext computeWorkerContext(int segment)

Description copied from interface: SessionLoader

Compute the worker context for current iteration

Specified by:

computeWorkerContext in interface SessionLoader<RemoteCacheSessionsLoaderContext,SessionLoader.WorkerContext,SessionLoader.WorkerResult>

Parameters:

segment - the current segment (page) to compute

Returns:

loadSessions

public SessionLoader.WorkerResult loadSessions(KeycloakSession session,
 RemoteCacheSessionsLoaderContext loaderContext,
 SessionLoader.WorkerContext ctx)

Description copied from interface: SessionLoader

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

Specified by:

loadSessions in interface SessionLoader<RemoteCacheSessionsLoaderContext,SessionLoader.WorkerContext,SessionLoader.WorkerResult>

loaderContext - global loaderContext object, which was already computed before

ctx - for current iteration

Returns:

afterAllSessionsLoaded

public void afterAllSessionsLoaded()

Description copied from interface: SessionLoader

Callback triggered on cluster coordinator once it recognize that all sessions were successfully loaded

Specified by:

afterAllSessionsLoaded in interface SessionLoader<RemoteCacheSessionsLoaderContext,SessionLoader.WorkerContext,SessionLoader.WorkerResult>

getCache

protected org.infinispan.Cache getCache(KeycloakSession session)

getRemoteCache

protected org.infinispan.client.hotrod.RemoteCache getRemoteCache(KeycloakSession session)

toString

public String toString()

Overrides:

toString in class Object