org.xdi.oxauth.service.CleanerTimer クラス

org.xdi.oxauth.service.CleanerTimer 連携図

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

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

非公開メンバ関数
void	processCache (Date now)
void	processAuthorizationGrantList ()
void	processRegisteredClients ()
void	processU2fRequests ()
void	processU2fDeviceRegistrations ()
void	processMetricEntries ()

非公開変数類
Logger	log
PersistenceEntryManager	ldapEntryManager
AuthorizationGrantList	authorizationGrantList
ClientService	clientService
GrantService	grantService
UmaRptService	umaRptService
UmaPctService	umaPctService
UmaPermissionService	umaPermissionService
UmaResourceService	umaResourceService
SessionIdService	sessionIdService
CacheService	cacheService
RequestService	u2fRequestService
MetricService	metricService
DeviceRegistrationService	deviceRegistrationService
AppConfiguration	appConfiguration
Event< TimerEvent >	cleanerEvent
AtomicBoolean	isActive

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

詳解

著者

Yuriy Zabrovarnyy

Javier Rojas Blum

バージョン

August 9, 2017

関数詳解

initTimer()

void org.xdi.oxauth.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.xdi.oxauth.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);
            processAuthorizationGrantList();
            processRegisteredClients();

            this.umaRptService.cleanup(now);
            this.umaPermissionService.cleanup(now);
            this.umaPctService.cleanup(now);
            this.umaResourceService.cleanup(now);

            processU2fRequests();
            processU2fDeviceRegistrations();

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

processAuthorizationGrantList()

void org.xdi.oxauth.service.CleanerTimer.processAuthorizationGrantList ( )

inlineprivate

                                                 {
        log.debug("Start AuthorizationGrant clean up");
        grantService.cleanUp();
        log.debug("End AuthorizationGrant clean up");
    }

processCache()

void org.xdi.oxauth.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.xdi.oxauth.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");
    }

processRegisteredClients()

void org.xdi.oxauth.service.CleanerTimer.processRegisteredClients ( )

inlineprivate

                                            {
        log.debug("Start Client clean up");

        BatchOperation<Client> clientBatchService = new ProcessBatchOperation<Client>() {
            @Override
            public void performAction(List<Client> entries) {
                for (Client client : entries) {
                    try {
                        GregorianCalendar now = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
                        GregorianCalendar expirationDate = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
                        expirationDate.setTime(client.getClientSecretExpiresAt());
                        if (expirationDate.before(now)) {
                            List<AuthorizationGrant> toRemove = authorizationGrantList.getAuthorizationGrant(client.getClientId());
                            authorizationGrantList.removeAuthorizationGrants(toRemove);

                            log.debug("Removing Client: {}, Expiration date: {}",
                                    client.getClientId(),
                                    client.getClientSecretExpiresAt());
                            clientService.remove(client);
                        }
                    } catch (Exception e) {
                        log.error("Failed to remove entry", e);
                    }
                }
            }
        };

        clientService.getClientsWithExpirationDate(clientBatchService, new String[] {"inum", "oxAuthClientSecretExpiresAt"}, 0, BATCH_SIZE);

        log.debug("End Client clean up");
    }

processU2fDeviceRegistrations()

void org.xdi.oxauth.service.CleanerTimer.processU2fDeviceRegistrations ( )

inlineprivate

                                                 {
        log.debug("Start U2F request clean up");

        Calendar calendar = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
        calendar.add(Calendar.SECOND, -90);
        final Date expirationDate = calendar.getTime();

        BatchOperation<DeviceRegistration> deviceRegistrationBatchService = new ProcessBatchOperation<DeviceRegistration>() {
            @Override
            public void performAction(List<DeviceRegistration> entries) {
                for (DeviceRegistration deviceRegistration : entries) {
                    try {
                        log.debug("Removing DeviceRegistration: {}, Creation date: {}",
                                deviceRegistration.getId(),
                                deviceRegistration.getCreationDate());
                        deviceRegistrationService.removeUserDeviceRegistration(deviceRegistration);
                    } catch (Exception e) {
                        log.error("Failed to remove entry", e);
                    }
                }
            }
        };
        deviceRegistrationService.getExpiredDeviceRegistrations(deviceRegistrationBatchService, expirationDate, new String[] {"oxId", "creationDate"}, 0, BATCH_SIZE);

        log.debug("End U2F request clean up");
    }

processU2fRequests()

void org.xdi.oxauth.service.CleanerTimer.processU2fRequests ( )

inlineprivate

                                      {
        log.debug("Start U2F request clean up");

        Calendar calendar = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
        calendar.add(Calendar.SECOND, -90);
        final Date expirationDate = calendar.getTime();

        BatchOperation<RequestMessageLdap> requestMessageLdapBatchService = new ProcessBatchOperation<RequestMessageLdap>() {
            @Override
            public void performAction(List<RequestMessageLdap> entries) {
                for (RequestMessageLdap requestMessageLdap : entries) {
                    try {
                        log.debug("Removing RequestMessageLdap: {}, Creation date: {}",
                                requestMessageLdap.getRequestId(),
                                requestMessageLdap.getCreationDate());
                        u2fRequestService.removeRequestMessage(requestMessageLdap);
                    } catch (Exception e) {
                        log.error("Failed to remove entry", e);
                    }
                }
            }
        };

        u2fRequestService.getExpiredRequestMessages(requestMessageLdapBatchService, expirationDate, new String[] {"oxRequestId", "creationDate"}, 0, BATCH_SIZE);
        log.debug("End U2F request clean up");
    }

メンバ詳解

appConfiguration

AppConfiguration org.xdi.oxauth.service.CleanerTimer.appConfiguration

private

authorizationGrantList

AuthorizationGrantList org.xdi.oxauth.service.CleanerTimer.authorizationGrantList

private

BATCH_SIZE

final int org.xdi.oxauth.service.CleanerTimer.BATCH_SIZE = 100

static

cacheService

CacheService org.xdi.oxauth.service.CleanerTimer.cacheService

private

cleanerEvent

Event<TimerEvent> org.xdi.oxauth.service.CleanerTimer.cleanerEvent

private

clientService

ClientService org.xdi.oxauth.service.CleanerTimer.clientService

private

DEFAULT_INTERVAL

final int org.xdi.oxauth.service.CleanerTimer.DEFAULT_INTERVAL = 600

staticprivate

deviceRegistrationService

DeviceRegistrationService org.xdi.oxauth.service.CleanerTimer.deviceRegistrationService

private

grantService

GrantService org.xdi.oxauth.service.CleanerTimer.grantService

private

isActive

AtomicBoolean org.xdi.oxauth.service.CleanerTimer.isActive

private

ldapEntryManager

PersistenceEntryManager org.xdi.oxauth.service.CleanerTimer.ldapEntryManager

private

log

Logger org.xdi.oxauth.service.CleanerTimer.log

private

metricService

MetricService org.xdi.oxauth.service.CleanerTimer.metricService

private

sessionIdService

SessionIdService org.xdi.oxauth.service.CleanerTimer.sessionIdService

private

u2fRequestService

RequestService org.xdi.oxauth.service.CleanerTimer.u2fRequestService

private

umaPctService

UmaPctService org.xdi.oxauth.service.CleanerTimer.umaPctService

private

umaPermissionService

UmaPermissionService org.xdi.oxauth.service.CleanerTimer.umaPermissionService

private

umaResourceService

UmaResourceService org.xdi.oxauth.service.CleanerTimer.umaResourceService

private

umaRptService

UmaRptService org.xdi.oxauth.service.CleanerTimer.umaRptService

private

---

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

• D:/AppData/OpenId/gluu/src/oxAuth/Server/src/main/java/org/xdi/oxauth/service/CleanerTimer.java