org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory クラス

org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory の継承関係図

org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory 連携図

クラス
class	ViewChangeListener

公開メンバ関数
ClusterProvider	create (KeycloakSession session)
void	init (Config.Scope config)
void	postInit (KeycloakSessionFactory factory)
void	close ()
String	getId ()
default int	order ()

静的公開変数類
static final String	PROVIDER_ID = "infinispan"

限定公開メンバ関数
int	initClusterStartupTime (KeycloakSession session)

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

関数
static< V extends Serializable > V	putIfAbsentWithRetries (CrossDCAwareCacheFactory crossDCAwareCacheFactory, String key, V value, int taskTimeoutInSeconds)

非公開メンバ関数
void	lazyInit (KeycloakSession session)

非公開変数類
volatile Cache< String, Serializable >	workCache
CrossDCAwareCacheFactory	crossDCAwareCacheFactory
int	clusterStartupTime
InfinispanNotificationsManager	notificationsManager
ExecutorService	localExecutor = Executors.newCachedThreadPool()

詳解

This impl is aware of Cross-Data-Center scenario too

著者

Marek Posolda

関数詳解

close()

void org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.close ( )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                        {

    }

create()

ClusterProvider org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.create ( KeycloakSession  session )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                                           {
        lazyInit(session);
        String myAddress = InfinispanUtil.getTopologyInfo(session).getMyNodeName();
        return new InfinispanClusterProvider(clusterStartupTime, myAddress, crossDCAwareCacheFactory, notificationsManager, localExecutor);
    }

getId()

String org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.getId ( )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                          {
        return PROVIDER_ID;
    }

init()

void org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.init ( Config.Scope  config )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                          {
    }

initClusterStartupTime()

int org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.initClusterStartupTime ( KeycloakSession  session )

inlineprotected

                                                                  {
        Integer existingClusterStartTime = (Integer) crossDCAwareCacheFactory.getCache().get(InfinispanClusterProvider.CLUSTER_STARTUP_TIME_KEY);
        if (existingClusterStartTime != null) {
            logger.debugf("Loaded cluster startup time: %s", Time.toDate(existingClusterStartTime).toString());
            return existingClusterStartTime;
        } else {
            // clusterStartTime not yet initialized. Let's try to put our startupTime
            int serverStartTime = (int) (session.getKeycloakSessionFactory().getServerStartupTimestamp() / 1000);

            existingClusterStartTime = putIfAbsentWithRetries(crossDCAwareCacheFactory, InfinispanClusterProvider.CLUSTER_STARTUP_TIME_KEY, serverStartTime, -1);
            if (existingClusterStartTime == null) {
                logger.debugf("Initialized cluster startup time to %s", Time.toDate(serverStartTime).toString());
                return serverStartTime;
            } else {
                logger.debugf("Loaded cluster startup time: %s", Time.toDate(existingClusterStartTime).toString());
                return existingClusterStartTime;
            }
        }
    }

lazyInit()

void org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.lazyInit ( KeycloakSession  session )

inlineprivate

                                                   {
        if (workCache == null) {
            synchronized (this) {
                if (workCache == null) {
                    InfinispanConnectionProvider ispnConnections = session.getProvider(InfinispanConnectionProvider.class);
                    workCache = ispnConnections.getCache(InfinispanConnectionProvider.WORK_CACHE_NAME);

                    workCache.getCacheManager().addListener(new ViewChangeListener());

                    // See if we have RemoteStore (external JDG) configured for cross-Data-Center scenario
                    Set<RemoteStore> remoteStores = InfinispanUtil.getRemoteStores(workCache);
                    crossDCAwareCacheFactory = CrossDCAwareCacheFactory.getFactory(workCache, remoteStores);

                    clusterStartupTime = initClusterStartupTime(session);

                    TopologyInfo topologyInfo = InfinispanUtil.getTopologyInfo(session);
                    String myAddress = topologyInfo.getMyNodeName();
                    String mySite = topologyInfo.getMySiteName();

                    notificationsManager = InfinispanNotificationsManager.create(session, workCache, myAddress, mySite, remoteStores);
                }
            }
        }
    }

order()

default int org.keycloak.provider.ProviderFactory< T extends Provider >.order ( )

inlineinherited

org.keycloak.protocol.docker.DockerAuthV2ProtocolFactory, org.keycloak.urls.HostnameProviderFactory, org.keycloak.protocol.oidc.ext.OIDCExtProviderFactoryで実装されています。

                        {
        return 0;
    }

postInit()

void org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.postInit ( KeycloakSessionFactory  factory )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                                         {
    }

putIfAbsentWithRetries()

static<V extends Serializable> V org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.putIfAbsentWithRetries ( CrossDCAwareCacheFactory  crossDCAwareCacheFactory, String  key, V  value, int  taskTimeoutInSeconds  )

inlinepackage

                                                                                                                                                               {
        AtomicReference<V> resultRef = new AtomicReference<>();

        Retry.executeWithBackoff((int iteration) -> {

            try {
                V result;
                if (taskTimeoutInSeconds > 0) {
                    result = (V) crossDCAwareCacheFactory.getCache().putIfAbsent(key, value);
                } else {
                    result = (V) crossDCAwareCacheFactory.getCache().putIfAbsent(key, value, taskTimeoutInSeconds, TimeUnit.SECONDS);
                }
                resultRef.set(result);

            } catch (HotRodClientException re) {
                logger.warnf(re, "Failed to write key '%s' and value '%s' in iteration '%d' . Retrying", key, value, iteration);

                // Rethrow the exception. Retry will take care of handle the exception and eventually retry the operation.
                throw re;
            }

        }, 10, 10);

        return resultRef.get();
    }

メンバ詳解

clusterStartupTime

int org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.clusterStartupTime

private

crossDCAwareCacheFactory

CrossDCAwareCacheFactory org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.crossDCAwareCacheFactory

private

localExecutor

ExecutorService org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.localExecutor = Executors.newCachedThreadPool()

private

logger

final Logger org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.logger = Logger.getLogger(InfinispanClusterProviderFactory.class)

staticprotected

notificationsManager

InfinispanNotificationsManager org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.notificationsManager

private

PROVIDER_ID

final String org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.PROVIDER_ID = "infinispan"

static

workCache

volatile Cache<String, Serializable> org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.workCache

private

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/cluster/infinispan/InfinispanClusterProviderFactory.java