org.gluu.oxtrust.service.CleanerTimer クラス

org.gluu.oxtrust.service.CleanerTimer 連携図

公開メンバ関数
void	initTimer ()
void	process (@Observes @Scheduled CleanerEvent cleanerEvent)

静的公開変数類
static final int	BATCH_SIZE = 100

限定公開メンバ関数
void	processPasswordReset ()

非公開メンバ関数
void	processCache (Date now)
void	processMetricEntries ()

非公開変数類
Logger	log
PersistenceEntryManager	ldapEntryManager
PasswordResetService	passwordResetService
CacheService	cacheService
MetricService	metricService
AppConfiguration	appConfiguration
Event< TimerEvent >	cleanerEvent
AtomicBoolean	isActive

静的非公開変数類
static final int	DEFAULT_INTERVAL = 600

詳解

Cleaner service

著者

Yuriy Movchan Date: 09/01/2018

関数詳解

initTimer()

void org.gluu.oxtrust.service.CleanerTimer.initTimer ( )

inline

                            {
        log.debug("Initializing Cleaner Timer");
        this.isActive = new AtomicBoolean(false);

        int interval = appConfiguration.getCleanServiceInterval();
        if (interval <= 0) {
            interval = DEFAULT_INTERVAL;
        }

        cleanerEvent.fire(new TimerEvent(new TimerSchedule(interval, interval), new CleanerEvent(), Scheduled.Literal.INSTANCE));
    }

process()

void org.gluu.oxtrust.service.CleanerTimer.process ( @Observes @Scheduled CleanerEvent  cleanerEvent )

inline

                                                                        {
        if (this.isActive.get()) {
            return;
        }

        if (!this.isActive.compareAndSet(false, true)) {
            return;
        }

        try {
            Date now = new Date();

            processCache(now);
            processPasswordReset();
            processMetricEntries();
        } finally {
            this.isActive.set(false);
        }
    }

processCache()

void org.gluu.oxtrust.service.CleanerTimer.processCache ( Date  now )

inlineprivate

                                        {
        try {
            if (cacheService.getCacheProvider() instanceof NativePersistenceCacheProvider) {
                ((NativePersistenceCacheProvider) cacheService.getCacheProvider()).cleanup(now, BATCH_SIZE);
            }
        } catch (Exception e) {
            log.error("Failed to clean up cache.", e);
        }
    }

processMetricEntries()

void org.gluu.oxtrust.service.CleanerTimer.processMetricEntries ( )

inlineprivate

                                        {
        log.debug("Start metric entries clean up");

        int keepDataDays = appConfiguration.getMetricReporterKeepDataDays();

        Calendar calendar = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
        calendar.add(Calendar.DATE, -keepDataDays);
        Date expirationDate = calendar.getTime();

        metricService.removeExpiredMetricEntries(expirationDate, ApplicationType.OX_AUTH, metricService.applianceInum(), 0, BATCH_SIZE);

        log.debug("End metric entries clean up");
    }

processPasswordReset()

void org.gluu.oxtrust.service.CleanerTimer.processPasswordReset ( )

inlineprotected

                                          {
        Calendar calendar = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
        calendar.add(Calendar.SECOND, -appConfiguration.getPasswordResetRequestExpirationTime());
        final Date expirationDate = calendar.getTime();
        
        passwordResetService.cleanup(expirationDate);
    }

メンバ詳解

appConfiguration

AppConfiguration org.gluu.oxtrust.service.CleanerTimer.appConfiguration

private

BATCH_SIZE

final int org.gluu.oxtrust.service.CleanerTimer.BATCH_SIZE = 100

static

cacheService

CacheService org.gluu.oxtrust.service.CleanerTimer.cacheService

private

cleanerEvent

Event<TimerEvent> org.gluu.oxtrust.service.CleanerTimer.cleanerEvent

private

DEFAULT_INTERVAL

final int org.gluu.oxtrust.service.CleanerTimer.DEFAULT_INTERVAL = 600

staticprivate

isActive

AtomicBoolean org.gluu.oxtrust.service.CleanerTimer.isActive

private

ldapEntryManager

PersistenceEntryManager org.gluu.oxtrust.service.CleanerTimer.ldapEntryManager

private

log

Logger org.gluu.oxtrust.service.CleanerTimer.log

private

metricService

MetricService org.gluu.oxtrust.service.CleanerTimer.metricService

private

passwordResetService

PasswordResetService org.gluu.oxtrust.service.CleanerTimer.passwordResetService

private

---

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

• D:/AppData/OpenId/gluu/src/oxTrust/server/src/main/java/org/gluu/oxtrust/service/CleanerTimer.java