org.keycloak.models.sessions.infinispan.initializer.InitializerState クラス

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

org.keycloak.models.sessions.infinispan.initializer.InitializerState 連携図

クラス
class	ExternalizerImpl

公開メンバ関数
	InitializerState (int segmentsCount)
boolean	isFinished ()
List< Integer >	getUnfinishedSegments (int maxSegmentCount)
void	markSegmentFinished (int index)
String	toString ()
int	hashCode ()
boolean	equals (Object obj)
String	getRealmId ()
void	setRealmId (String realmId)
SessionEntityWrapper	mergeRemoteEntityWithLocalEntity (SessionEntityWrapper localEntityWrapper)

非公開メンバ関数
	InitializerState (String realmId, int segmentsCount, BitSet segments)
void	updateLowestUnfinishedSegment ()
int	getNextUnfinishedSegmentFromIndex (int index)

非公開変数類
final int	segmentsCount
final BitSet	segments
int	lowestUnfinishedSegment = 0

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

詳解

Note that this state is NOT thread safe. Currently it is only used from single thread so it's fine but further optimizations might need to revisit this (see InfinispanCacheInitializer).

著者

Marek Posolda

構築子と解体子

InitializerState() [1/2]

org.keycloak.models.sessions.infinispan.initializer.InitializerState.InitializerState ( int  segmentsCount )

inline

                                               {
        this.segmentsCount = segmentsCount;
        this.segments = new BitSet(segmentsCount);

        log.debugf("segmentsCount: %d", segmentsCount);

        updateLowestUnfinishedSegment();
    }

InitializerState() [2/2]

org.keycloak.models.sessions.infinispan.initializer.InitializerState.InitializerState ( String  realmId, int  segmentsCount, BitSet  segments  )

inlineprivate

                                                                                 {
        super(realmId);
        this.segmentsCount = segmentsCount;
        this.segments = segments;

        log.debugf("segmentsCount: %d", segmentsCount);

        updateLowestUnfinishedSegment();
    }

関数詳解

equals()

boolean org.keycloak.models.sessions.infinispan.initializer.InitializerState.equals ( Object  obj )

inline

                                      {
        if (this == obj) {
            return true;
        }
        if (obj == null) {
            return false;
        }
        if (getClass() != obj.getClass()) {
            return false;
        }
        final InitializerState other = (InitializerState) obj;
        if (this.segmentsCount != other.segmentsCount) {
            return false;
        }
        if (this.lowestUnfinishedSegment != other.lowestUnfinishedSegment) {
            return false;
        }
        if ( ! Objects.equals(this.segments, other.segments)) {
            return false;
        }
        return true;
    }

getNextUnfinishedSegmentFromIndex()

int org.keycloak.models.sessions.infinispan.initializer.InitializerState.getNextUnfinishedSegmentFromIndex ( int  index )

inlineprivate

                                                             {
        final int nextFreeSegment = this.segments.nextClearBit(index);
        return (nextFreeSegment < this.segmentsCount)
          ? nextFreeSegment
          : -1;
    }

getRealmId()

String org.keycloak.models.sessions.infinispan.entities.SessionEntity.getRealmId ( )

inlineinherited

Returns realmId ID.

戻り値

                               {
        return realmId;
    }

getUnfinishedSegments()

List<Integer> org.keycloak.models.sessions.infinispan.initializer.InitializerState.getUnfinishedSegments ( int  maxSegmentCount )

inline

Return next un-finished segments. It returns at most

maxSegmentCount 

segments.

                                                                    {
        List<Integer> result = new LinkedList<>();
        int next = lowestUnfinishedSegment;
        boolean remaining = lowestUnfinishedSegment != -1;

        while (remaining && result.size() < maxSegmentCount) {
            next = getNextUnfinishedSegmentFromIndex(next);
            if (next == -1) {
                remaining = false;
            } else {
                result.add(next);
                next++;
            }
        }

        return result;
    }

hashCode()

int org.keycloak.models.sessions.infinispan.initializer.InitializerState.hashCode ( )

inline

                          {
        int hash = 3;
        hash = 97 * hash + this.segmentsCount;
        hash = 97 * hash + Objects.hashCode(this.segments);
        hash = 97 * hash + this.lowestUnfinishedSegment;
        return hash;
    }

isFinished()

boolean org.keycloak.models.sessions.infinispan.initializer.InitializerState.isFinished ( )

inline

Return true just if computation is entirely finished (all segments are true)

                                {
        return segments.cardinality() == segmentsCount;
    }

markSegmentFinished()

void org.keycloak.models.sessions.infinispan.initializer.InitializerState.markSegmentFinished ( int  index )

inline

                                               {
        segments.set(index);
        updateLowestUnfinishedSegment();
    }

mergeRemoteEntityWithLocalEntity()

SessionEntityWrapper org.keycloak.models.sessions.infinispan.entities.SessionEntity.mergeRemoteEntityWithLocalEntity ( SessionEntityWrapper  localEntityWrapper )

inlineinherited

                                                                                                          {
        if (localEntityWrapper == null) {
            return new SessionEntityWrapper<>(this);
        } else {
            return new SessionEntityWrapper<>(localEntityWrapper.getLocalMetadata(), this);
        }
    };

setRealmId()

void org.keycloak.models.sessions.infinispan.entities.SessionEntity.setRealmId ( String  realmId )

inlineinherited

                                           {
        this.realmId = realmId;
    }

toString()

String org.keycloak.models.sessions.infinispan.initializer.InitializerState.toString ( )

inline

                             {
        int finished = segments.cardinality();
        int nonFinished = segmentsCount - finished;

        return "finished segments count: " + finished
          + (", non-finished segments count: " + nonFinished);
    }

updateLowestUnfinishedSegment()

void org.keycloak.models.sessions.infinispan.initializer.InitializerState.updateLowestUnfinishedSegment ( )

inlineprivate

                                                 {
        this.lowestUnfinishedSegment = getNextUnfinishedSegmentFromIndex(lowestUnfinishedSegment);
    }

メンバ詳解

log

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

staticprivate

lowestUnfinishedSegment

int org.keycloak.models.sessions.infinispan.initializer.InitializerState.lowestUnfinishedSegment = 0

private

segments

final BitSet org.keycloak.models.sessions.infinispan.initializer.InitializerState.segments

private

segmentsCount

final int org.keycloak.models.sessions.infinispan.initializer.InitializerState.segmentsCount

private

---

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

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