org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction クラス

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

org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction 連携図

クラス
enum	CacheOperation
interface	CacheTask
class	CacheTaskWithValue

公開メンバ関数
void	begin ()
void	commit ()
void	rollback ()
void	setRollbackOnly ()
boolean	getRollbackOnly ()
boolean	isActive ()

関数
public< K, V > void	put (Cache< K, V > cache, K key, V value)
public< K, V > void	put (Cache< K, V > cache, K key, V value, long lifespan, TimeUnit lifespanUnit)
public< K, V > void	putIfAbsent (Cache< K, V > cache, K key, V value)
public< K, V > void	replace (Cache< K, V > cache, K key, V value)
public< K, V > void	notify (ClusterProvider clusterProvider, String taskKey, ClusterEvent event, boolean ignoreSender)
public< K, V > void	remove (Cache< K, V > cache, K key)
public< K, V > V	get (Cache< K, V > cache, K key)

静的非公開メンバ関数
static< K, V > Object	getTaskKey (Cache< K, V > cache, K key)
static< K, V > Cache< K, V >	decorateCache (Cache< K, V > cache)

非公開変数類
boolean	active
boolean	rollback
final Map< Object, CacheTask >	tasks = new LinkedHashMap<>()

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

詳解

著者

Stian Thorgersen

---

クラス詳解

org::keycloak::models::sessions::infinispan::InfinispanKeycloakTransaction::CacheOperation

enum org::keycloak::models::sessions::infinispan::InfinispanKeycloakTransaction::CacheOperation

org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.CacheOperation 連携図

列挙値
ADD
ADD_IF_ABSENT
ADD_WITH_LIFESPAN
REMOVE
REPLACE

関数詳解

begin()

void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.begin ( )

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                        {
        active = true;
    }

commit()

void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.commit ( )

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                         {
        if (rollback) {
            throw new RuntimeException("Rollback only!");
        }

        tasks.values().forEach(CacheTask::execute);
    }

decorateCache()

static <K, V> Cache<K, V> org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.decorateCache ( Cache< K, V >  cache )

inlinestaticprivate

                                                                       {
        return cache.getAdvancedCache()
                .withFlags(Flag.IGNORE_RETURN_VALUES, Flag.SKIP_REMOTE_LOOKUP);
    }

get()

public<K, V> V org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.get ( Cache< K, V >  cache, K  key  )

inlinepackage

                                                  {
        Object taskKey = getTaskKey(cache, key);
        CacheTask current = tasks.get(taskKey);
        if (current != null) {
            if (current instanceof CacheTaskWithValue) {
                return ((CacheTaskWithValue<V>) current).getValue();
            }
            return null;
        }

        // Should we have per-transaction cache for lookups?
        return cache.get(key);
    }

getRollbackOnly()

boolean org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.getRollbackOnly ( )

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                                     {
        return rollback;
    }

getTaskKey()

static <K, V> Object org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.getTaskKey ( Cache< K, V >  cache, K  key  )

inlinestaticprivate

                                                                      {
        if (key instanceof String) {
            return new StringBuilder(cache.getName())
                    .append("::")
                    .append(key).toString();
        } else {
            return key;
        }
    }

isActive()

boolean org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.isActive ( )

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                              {
        return active;
    }

notify()

public<K, V> void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.notify ( ClusterProvider  clusterProvider, String  taskKey, ClusterEvent  event, boolean  ignoreSender  )

inlinepackage

                                                                                                                         {
        log.tracev("Adding cache operation SEND_EVENT: {0}", event);

        String theTaskKey = taskKey;
        int i = 1;
        while (tasks.containsKey(theTaskKey)) {
            theTaskKey = taskKey + "-" + (i++);
        }

        tasks.put(taskKey, () -> clusterProvider.notify(taskKey, event, ignoreSender, ClusterProvider.DCNotify.ALL_DCS));
    }

put() [1/2]

public<K, V> void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.put ( Cache< K, V >  cache, K  key, V  value  )

inlinepackage

                                                              {
        log.tracev("Adding cache operation: {0} on {1}", CacheOperation.ADD, key);

        Object taskKey = getTaskKey(cache, key);
        if (tasks.containsKey(taskKey)) {
            throw new IllegalStateException("Can't add session: task in progress for session");
        } else {
            tasks.put(taskKey, new CacheTaskWithValue<V>(value) {
                @Override
                public void execute() {
                    decorateCache(cache).put(key, value);
                }

                @Override
                public String toString() {
                    return String.format("CacheTaskWithValue: Operation 'put' for key %s", key);
                }
            });
        }
    }

put() [2/2]

public<K, V> void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.put ( Cache< K, V >  cache, K  key, V  value, long  lifespan, TimeUnit  lifespanUnit  )

inlinepackage

                                                                                                    {
        log.tracev("Adding cache operation: {0} on {1}", CacheOperation.ADD_WITH_LIFESPAN, key);

        Object taskKey = getTaskKey(cache, key);
        if (tasks.containsKey(taskKey)) {
            throw new IllegalStateException("Can't add session: task in progress for session");
        } else {
            tasks.put(taskKey, new CacheTaskWithValue<V>(value) {
                @Override
                public void execute() {
                    decorateCache(cache).put(key, value, lifespan, lifespanUnit);
                }

                @Override
                public String toString() {
                    return String.format("CacheTaskWithValue: Operation 'put' for key %s, lifespan %d TimeUnit %s", key, lifespan, lifespanUnit.toString());
                }
            });
        }
    }

putIfAbsent()

public<K, V> void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.putIfAbsent ( Cache< K, V >  cache, K  key, V  value  )

inlinepackage

                                                                      {
        log.tracev("Adding cache operation: {0} on {1}", CacheOperation.ADD_IF_ABSENT, key);

        Object taskKey = getTaskKey(cache, key);
        if (tasks.containsKey(taskKey)) {
            throw new IllegalStateException("Can't add session: task in progress for session");
        } else {
            tasks.put(taskKey, new CacheTaskWithValue<V>(value) {
                @Override
                public void execute() {
                    V existing = cache.putIfAbsent(key, value);
                    if (existing != null) {
                        throw new IllegalStateException("There is already existing value in cache for key " + key);
                    }
                }

                @Override
                public String toString() {
                    return String.format("CacheTaskWithValue: Operation 'putIfAbsent' for key %s", key);
                }
            });
        }
    }

remove()

public<K, V> void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.remove ( Cache< K, V >  cache, K  key  )

inlinepackage

                                                        {
        log.tracev("Adding cache operation: {0} on {1}", CacheOperation.REMOVE, key);

        Object taskKey = getTaskKey(cache, key);

        // TODO:performance Eventual performance optimization could be to skip "cache.remove" if item was added in this transaction (EG. authenticationSession valid for single request due to automatic SSO login)
        tasks.put(taskKey, new CacheTask() {

            @Override
            public void execute() {
                decorateCache(cache).remove(key);
            }

            @Override
            public String toString() {
                return String.format("CacheTask: Operation 'remove' for key %s", key);
            }

        });
    }

replace()

public<K, V> void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.replace ( Cache< K, V >  cache, K  key, V  value  )

inlinepackage

                                                                  {
        log.tracev("Adding cache operation: {0} on {1}", CacheOperation.REPLACE, key);

        Object taskKey = getTaskKey(cache, key);
        CacheTask current = tasks.get(taskKey);
        if (current != null) {
            if (current instanceof CacheTaskWithValue) {
                ((CacheTaskWithValue<V>) current).setValue(value);
            }
        } else {
            tasks.put(taskKey, new CacheTaskWithValue<V>(value) {
                @Override
                public void execute() {
                    decorateCache(cache).replace(key, value);
                }

                @Override
                public String toString() {
                    return String.format("CacheTaskWithValue: Operation 'replace' for key %s", key);
                }

            });
        }
    }

rollback()

void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.rollback ( )

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                           {
        tasks.clear();
    }

setRollbackOnly()

void org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.setRollbackOnly ( )

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                                  {
        rollback = true;
    }

メンバ詳解

active

boolean org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.active

private

log

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

staticprivate

rollback

boolean org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.rollback

private

tasks

final Map<Object, CacheTask> org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction.tasks = new LinkedHashMap<>()

private

---

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

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