org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider クラス

org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider の継承関係図

org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider 連携図

クラス
class	WrapperCallable

公開メンバ関数
	InfinispanPublicKeyStorageProvider (KeycloakSession session, Cache< String, PublicKeysEntry > keys, Map< String, FutureTask< PublicKeysEntry >> tasksInProgress, int minTimeBetweenRequests)
void	clearCache ()
PublicKey	getPublicKey (String modelKey, String kid, PublicKeyLoader loader)
void	close ()

限定公開メンバ関数
KeycloakTransaction	getAfterTransaction ()
void	runInvalidations ()

関数
void	addInvalidation (String cacheKey)

非公開メンバ関数
PublicKey	getPublicKey (Map< String, PublicKey > publicKeys, String kid)

非公開変数類
final KeycloakSession	session
final Cache< String, PublicKeysEntry >	keys
final Map< String, FutureTask< PublicKeysEntry > >	tasksInProgress
final int	minTimeBetweenRequests
Set< String >	invalidations = new HashSet<>()
boolean	transactionEnlisted = false

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

詳解

著者

Marek Posolda

構築子と解体子

InfinispanPublicKeyStorageProvider()

org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.InfinispanPublicKeyStorageProvider ( KeycloakSession  session, Cache< String, PublicKeysEntry >  keys, Map< String, FutureTask< PublicKeysEntry >>  tasksInProgress, int  minTimeBetweenRequests  )

inline

                                                                                                                                                                                                  {
        this.session = session;
        this.keys = keys;
        this.tasksInProgress = tasksInProgress;
        this.minTimeBetweenRequests = minTimeBetweenRequests;
    }

関数詳解

addInvalidation()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.addInvalidation ( String  cacheKey )

inlinepackage

                                          {
        if (!transactionEnlisted) {
            session.getTransactionManager().enlistAfterCompletion(getAfterTransaction());
            transactionEnlisted = true;
        }

        this.invalidations.add(cacheKey);
    }

clearCache()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.clearCache ( )

inline

org.keycloak.keys.PublicKeyStorageProviderを実装しています。

                             {
        keys.clear();
        ClusterProvider cluster = session.getProvider(ClusterProvider.class);
        cluster.notify(InfinispanPublicKeyStorageProviderFactory.KEYS_CLEAR_CACHE_EVENTS, new ClearCacheEvent(), true, ClusterProvider.DCNotify.ALL_DCS);
    }

close()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.close ( )

inline

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

                        {

    }

getAfterTransaction()

KeycloakTransaction org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.getAfterTransaction ( )

inlineprotected

                                                        {
        return new KeycloakTransaction() {

            @Override
            public void begin() {
            }

            @Override
            public void commit() {
                runInvalidations();
            }

            @Override
            public void rollback() {
                runInvalidations();
            }

            @Override
            public void setRollbackOnly() {
            }

            @Override
            public boolean getRollbackOnly() {
                return false;
            }

            @Override
            public boolean isActive() {
                return true;
            }
        };
    }

getPublicKey() [1/2]

PublicKey org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.getPublicKey ( String  modelKey, String  kid, PublicKeyLoader  loader  )

inline

org.keycloak.keys.PublicKeyStorageProviderを実装しています。

                                                                                       {
        // Check if key is in cache
        PublicKeysEntry entry = keys.get(modelKey);
        if (entry != null) {
            PublicKey publicKey = getPublicKey(entry.getCurrentKeys(), kid);
            if (publicKey != null) {
                return publicKey;
            }
        }

        int lastRequestTime = entry==null ? 0 : entry.getLastRequestTime();
        int currentTime = Time.currentTime();

        // Check if we are allowed to send request
        if (currentTime > lastRequestTime + minTimeBetweenRequests) {

            WrapperCallable wrapperCallable = new WrapperCallable(modelKey, loader);
            FutureTask<PublicKeysEntry> task = new FutureTask<>(wrapperCallable);
            FutureTask<PublicKeysEntry> existing = tasksInProgress.putIfAbsent(modelKey, task);

            if (existing == null) {
                task.run();
            } else {
                task = existing;
            }

            try {
                entry = task.get();

                // Computation finished. Let's see if key is available
                PublicKey publicKey = getPublicKey(entry.getCurrentKeys(), kid);
                if (publicKey != null) {
                    return publicKey;
                }

            } catch (ExecutionException ee) {
                throw new RuntimeException("Error when loading public keys", ee);
            } catch (InterruptedException ie) {
                throw new RuntimeException("Error. Interrupted when loading public keys", ie);
            } finally {
                // Our thread inserted the task. Let's clean
                if (existing == null) {
                    tasksInProgress.remove(modelKey);
                }
            }
        } else {
            log.warnf("Won't load the keys for model '%s' . Last request time was %d", modelKey, lastRequestTime);
        }

        Set<String> availableKids = entry==null ? Collections.emptySet() : entry.getCurrentKeys().keySet();
        log.warnf("PublicKey wasn't found in the storage. Requested kid: '%s' . Available kids: '%s'", kid, availableKids);

        return null;
    }

getPublicKey() [2/2]

PublicKey org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.getPublicKey ( Map< String, PublicKey >  publicKeys, String  kid  )

inlineprivate

                                                                                  {
        // Backwards compatibility
        if (kid == null && !publicKeys.isEmpty()) {
            return publicKeys.values().iterator().next();
        } else {
            return publicKeys.get(kid);
        }
    }

runInvalidations()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.runInvalidations ( )

inlineprotected

                                      {
        ClusterProvider cluster = session.getProvider(ClusterProvider.class);

        for (String cacheKey : invalidations) {
            keys.remove(cacheKey);
            cluster.notify(InfinispanPublicKeyStorageProviderFactory.PUBLIC_KEY_STORAGE_INVALIDATION_EVENT, PublicKeyStorageInvalidationEvent.create(cacheKey), true, ClusterProvider.DCNotify.ALL_DCS);
        }
    }

メンバ詳解

invalidations

Set<String> org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.invalidations = new HashSet<>()

private

keys

final Cache<String, PublicKeysEntry> org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.keys

private

log

final Logger org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.log = Logger.getLogger(InfinispanPublicKeyStorageProvider.class)

staticprivate

minTimeBetweenRequests

final int org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.minTimeBetweenRequests

private

session

final KeycloakSession org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.session

private

tasksInProgress

final Map<String, FutureTask<PublicKeysEntry> > org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.tasksInProgress

private

transactionEnlisted

boolean org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProvider.transactionEnlisted = false

private

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/keys/infinispan/InfinispanPublicKeyStorageProvider.java