org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore クラス

org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore 連携図

公開メンバ関数
void	putLastSessionRefresh (KeycloakSession kcSession, String sessionId, String realmId, int lastSessionRefresh)

限定公開メンバ関数
	LastSessionRefreshStore (int maxIntervalBetweenMessagesSeconds, int maxCount, String eventKey)
void	sendMessage (KeycloakSession kcSession, Map< String, SessionData > refreshesToSend)

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

関数
void	checkSendingMessage (KeycloakSession kcSession, int currentTime)

非公開メンバ関数
synchronized Map< String, SessionData >	prepareSendingMessage (int currentTime)

非公開変数類
final int	maxIntervalBetweenMessagesSeconds
final int	maxCount
final String	eventKey
volatile Map< String, SessionData >	lastSessionRefreshes = new ConcurrentHashMap<>()
volatile int	lastRun = Time.currentTime()

詳解

Tracks the queue of lastSessionRefreshes, which were updated on this host. Those will be sent to the second DC in bulk, so second DC can update lastSessionRefreshes on it's side. Message is sent either periodically or if there are lots of stored lastSessionRefreshes.

著者

Marek Posolda

構築子と解体子

LastSessionRefreshStore()

org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.LastSessionRefreshStore ( int  maxIntervalBetweenMessagesSeconds, int  maxCount, String  eventKey  )

inlineprotected

                                                                                                            {
        this.maxIntervalBetweenMessagesSeconds = maxIntervalBetweenMessagesSeconds;
        this.maxCount = maxCount;
        this.eventKey = eventKey;
    }

関数詳解

checkSendingMessage()

void org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.checkSendingMessage ( KeycloakSession  kcSession, int  currentTime  )

inlinepackage

                                                                         {
        if (lastSessionRefreshes.size() >= maxCount || lastRun + maxIntervalBetweenMessagesSeconds <= currentTime) {
            Map<String, SessionData> refreshesToSend = prepareSendingMessage(currentTime);

            // Sending message doesn't need to be synchronized
            if (refreshesToSend != null) {
                sendMessage(kcSession, refreshesToSend);
            }
        }
    }

prepareSendingMessage()

synchronized Map<String, SessionData> org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.prepareSendingMessage ( int  currentTime )

inlineprivate

                                                                                         {
        if (lastSessionRefreshes.size() >= maxCount || lastRun + maxIntervalBetweenMessagesSeconds <= currentTime) {
            // Create new map instance, so that new writers will use that one
            Map<String, SessionData> copiedRefreshesToSend = lastSessionRefreshes;
            lastSessionRefreshes = new ConcurrentHashMap<>();
            lastRun = currentTime;

            return copiedRefreshesToSend;
        } else {
            return null;
        }
    }

putLastSessionRefresh()

void org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.putLastSessionRefresh ( KeycloakSession  kcSession, String  sessionId, String  realmId, int  lastSessionRefresh  )

inline

                                                                                                                           {
        lastSessionRefreshes.put(sessionId, new SessionData(realmId, lastSessionRefresh));

        // Assume that lastSessionRefresh is same or close to current time
        checkSendingMessage(kcSession, lastSessionRefresh);
    }

sendMessage()

void org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.sendMessage ( KeycloakSession  kcSession, Map< String, SessionData >  refreshesToSend  )

inlineprotected

                                                                                                    {
        LastSessionRefreshEvent event = new LastSessionRefreshEvent(refreshesToSend);

        if (logger.isDebugEnabled()) {
            logger.debugf("Sending lastSessionRefreshes for key '%s'. Refreshes: %s", eventKey, event.getLastSessionRefreshes().toString());
        }

        // Don't notify local DC about the lastSessionRefreshes. They were processed here already
        ClusterProvider cluster = kcSession.getProvider(ClusterProvider.class);
        cluster.notify(eventKey, event, true, ClusterProvider.DCNotify.ALL_BUT_LOCAL_DC);
    }

メンバ詳解

eventKey

final String org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.eventKey

private

lastRun

volatile int org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.lastRun = Time.currentTime()

private

lastSessionRefreshes

volatile Map<String, SessionData> org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.lastSessionRefreshes = new ConcurrentHashMap<>()

private

logger

final Logger org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.logger = Logger.getLogger(LastSessionRefreshStore.class)

staticprotected

maxCount

final int org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.maxCount

private

maxIntervalBetweenMessagesSeconds

final int org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshStore.maxIntervalBetweenMessagesSeconds

private

---

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

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