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

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

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

公開メンバ関数
	InfinispanClusterProvider (int clusterStartupTime, String myAddress, CrossDCAwareCacheFactory crossDCAwareCacheFactory, InfinispanNotificationsManager notificationsManager, ExecutorService localExecutor)
int	getClusterStartupTime ()
void	close ()
Future< Boolean >	executeIfNotExecutedAsync (String taskKey, int taskTimeoutInSeconds, Callable task)
void	registerListener (String taskKey, ClusterListener task)
void	notify (String taskKey, ClusterEvent event, boolean ignoreSender, DCNotify dcNotify)

静的公開変数類
static final String	CLUSTER_STARTUP_TIME_KEY = "cluster-start-time"

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

関数
public< T > ExecutionResult< T >	executeIfNotExecuted (String taskKey, int taskTimeoutInSeconds, Callable< T > task)

非公開メンバ関数
LockEntry	createLockEntry ()
boolean	tryLock (String cacheKey, int taskTimeoutInSeconds)
void	removeFromCache (String cacheKey)

非公開変数類
final int	clusterStartupTime
final String	myAddress
final CrossDCAwareCacheFactory	crossDCAwareCacheFactory
final InfinispanNotificationsManager	notificationsManager
final ExecutorService	localExecutor

静的非公開変数類
static final String	TASK_KEY_PREFIX = "task::"

詳解

著者

Marek Posolda

構築子と解体子

InfinispanClusterProvider()

org.keycloak.cluster.infinispan.InfinispanClusterProvider.InfinispanClusterProvider ( int  clusterStartupTime, String  myAddress, CrossDCAwareCacheFactory  crossDCAwareCacheFactory, InfinispanNotificationsManager  notificationsManager, ExecutorService  localExecutor  )

inline

                                                                                                                                                                                                                      {
        this.myAddress = myAddress;
        this.clusterStartupTime = clusterStartupTime;
        this.crossDCAwareCacheFactory = crossDCAwareCacheFactory;
        this.notificationsManager = notificationsManager;
        this.localExecutor = localExecutor;
    }

関数詳解

close()

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

inline

org.keycloak.provider.Providerを実装しています。

                        {
    }

createLockEntry()

LockEntry org.keycloak.cluster.infinispan.InfinispanClusterProvider.createLockEntry ( )

inlineprivate

                                        {
        LockEntry lock = new LockEntry();
        lock.setNode(myAddress);
        lock.setTimestamp(Time.currentTime());
        return lock;
    }

executeIfNotExecuted()

public<T> ExecutionResult<T> org.keycloak.cluster.infinispan.InfinispanClusterProvider.executeIfNotExecuted ( String  taskKey, int  taskTimeoutInSeconds, Callable< T >  task  )

inlinepackage

org.keycloak.cluster.ClusterProviderを実装しています。

                                                                                                                   {
        String cacheKey = TASK_KEY_PREFIX + taskKey;
        boolean locked = tryLock(cacheKey, taskTimeoutInSeconds);
        if (locked) {
            try {
                try {
                    T result = task.call();
                    return ExecutionResult.executed(result);
                } catch (RuntimeException re) {
                    throw re;
                } catch (Exception e) {
                    throw new RuntimeException("Unexpected exception when executed task " + taskKey, e);
                }
            } finally {
                removeFromCache(cacheKey);
            }
        } else {
            return ExecutionResult.notExecuted();
        }
    }

executeIfNotExecutedAsync()

Future<Boolean> org.keycloak.cluster.infinispan.InfinispanClusterProvider.executeIfNotExecutedAsync ( String  taskKey, int  taskTimeoutInSeconds, Callable  task  )

inline

org.keycloak.cluster.ClusterProviderを実装しています。

                                                                                                              {
        TaskCallback newCallback = new TaskCallback();
        TaskCallback callback = this.notificationsManager.registerTaskCallback(TASK_KEY_PREFIX + taskKey, newCallback);

        // We successfully submitted our task
        if (newCallback == callback) {
            Callable<Boolean> wrappedTask = () -> {
                boolean executed = executeIfNotExecuted(taskKey, taskTimeoutInSeconds, task).isExecuted();

                if (!executed) {
                    logger.infof("Task already in progress on other cluster node. Will wait until it's finished");
                }

                callback.getTaskCompletedLatch().await(taskTimeoutInSeconds, TimeUnit.SECONDS);
                return callback.isSuccess();
            };

            Future<Boolean> future = localExecutor.submit(wrappedTask);
            callback.setFuture(future);
        } else {
            logger.infof("Task already in progress on this cluster node. Will wait until it's finished");
        }

        return callback.getFuture();
    }

getClusterStartupTime()

int org.keycloak.cluster.infinispan.InfinispanClusterProvider.getClusterStartupTime ( )

inline

org.keycloak.cluster.ClusterProviderを実装しています。

                                       {
        return clusterStartupTime;
    }

notify()

void org.keycloak.cluster.infinispan.InfinispanClusterProvider.notify ( String  taskKey, ClusterEvent  event, boolean  ignoreSender, DCNotify  dcNotify  )

inline

org.keycloak.cluster.ClusterProviderを実装しています。

                                                                                                    {
        this.notificationsManager.notify(taskKey, event, ignoreSender, dcNotify);
    }

registerListener()

void org.keycloak.cluster.infinispan.InfinispanClusterProvider.registerListener ( String  taskKey, ClusterListener  task  )

inline

org.keycloak.cluster.ClusterProviderを実装しています。

                                                                       {
        this.notificationsManager.registerListener(taskKey, task);
    }

removeFromCache()

void org.keycloak.cluster.infinispan.InfinispanClusterProvider.removeFromCache ( String  cacheKey )

inlineprivate

                                                  {
        // More attempts to send the message (it may fail if some node fails in the meantime)
        Retry.executeWithBackoff((int iteration) -> {

            crossDCAwareCacheFactory.getCache().remove(cacheKey);
            if (logger.isTraceEnabled()) {
                logger.tracef("Task %s removed from the cache", cacheKey);
            }

        }, 10, 10);
    }

tryLock()

boolean org.keycloak.cluster.infinispan.InfinispanClusterProvider.tryLock ( String  cacheKey, int  taskTimeoutInSeconds  )

inlineprivate

                                                                       {
        LockEntry myLock = createLockEntry();

        LockEntry existingLock = InfinispanClusterProviderFactory.putIfAbsentWithRetries(crossDCAwareCacheFactory, cacheKey, myLock, taskTimeoutInSeconds);
        if (existingLock != null) {
            if (logger.isTraceEnabled()) {
                logger.tracef("Task %s in progress already by node %s. Ignoring task.", cacheKey, existingLock.getNode());
            }
            return false;
        } else {
            if (logger.isTraceEnabled()) {
                logger.tracef("Successfully acquired lock for task %s. Our node is %s", cacheKey, myLock.getNode());
            }
            return true;
        }
    }

メンバ詳解

CLUSTER_STARTUP_TIME_KEY

final String org.keycloak.cluster.infinispan.InfinispanClusterProvider.CLUSTER_STARTUP_TIME_KEY = "cluster-start-time"

static

clusterStartupTime

final int org.keycloak.cluster.infinispan.InfinispanClusterProvider.clusterStartupTime

private

crossDCAwareCacheFactory

final CrossDCAwareCacheFactory org.keycloak.cluster.infinispan.InfinispanClusterProvider.crossDCAwareCacheFactory

private

localExecutor

final ExecutorService org.keycloak.cluster.infinispan.InfinispanClusterProvider.localExecutor

private

logger

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

staticprotected

myAddress

final String org.keycloak.cluster.infinispan.InfinispanClusterProvider.myAddress

private

notificationsManager

final InfinispanNotificationsManager org.keycloak.cluster.infinispan.InfinispanClusterProvider.notificationsManager

private

TASK_KEY_PREFIX

final String org.keycloak.cluster.infinispan.InfinispanClusterProvider.TASK_KEY_PREFIX = "task::"

staticprivate

---

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

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