org.gluu.oxtrust.service.status.ldap.LdapStatusTimer クラス

org.gluu.oxtrust.service.status.ldap.LdapStatusTimer 連携図

公開メンバ関数
void	initTimer ()
void	process (@Observes @Scheduled LdapStatusEvent ldapStatusEvent)
void	logConnectionProviderStatistic (PersistenceEntryManager ldapEntryManager, String connectionProviderName)

非公開メンバ関数
void	processInt ()

非公開変数類
Logger	log
CentralLdapService	centralLdapService
Event< TimerEvent >	timerEvent
PersistenceEntryManager	ldapEntryManager
PersistenceEntryManager	ldapCentralEntryManager
AtomicBoolean	isActive

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

詳解

著者

Yuriy Movchan

バージョン

0.1, 11/18/2012

関数詳解

initTimer()

void org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.initTimer ( )

inline

                            {
        log.info("Initializing Ldap Status Timer");
        this.isActive = new AtomicBoolean(false);

                timerEvent.fire(new TimerEvent(new TimerSchedule(DEFAULT_INTERVAL, DEFAULT_INTERVAL), new LdapStatusEvent(),
                                Scheduled.Literal.INSTANCE));
    }

logConnectionProviderStatistic()

void org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.logConnectionProviderStatistic ( PersistenceEntryManager  ldapEntryManager, String  connectionProviderName  )

inline

                                                                                                                            {
            PersistenceOperationService persistenceOperationService = ldapEntryManager.getOperationService();
            if (!(persistenceOperationService instanceof LdapEntryManager)) {
                return;
            }

            LdapConnectionProvider ldapConnectionProvider = (LdapConnectionProvider) persistenceOperationService;
        
        if (ldapConnectionProvider == null) {
                log.error("{} is empty", connectionProviderName);
        } else {
            if (ldapConnectionProvider.getConnectionPool() == null) {
                log.error("{} is empty", connectionProviderName);
            } else {
                log.debug("{} statistics: {}", connectionProviderName, ldapConnectionProvider.getConnectionPool().getConnectionPoolStatistics());
            }
        }
        }

process()

void org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.process ( @Observes @Scheduled LdapStatusEvent  ldapStatusEvent )

inline

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

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

        try {
            processInt();
        } finally {
            this.isActive.set(false);
        }
    }

processInt()

void org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.processInt ( )

inlineprivate

                              {
        logConnectionProviderStatistic(ldapEntryManager, "connectionProvider");
        
        if (centralLdapService.isUseCentralServer() && (ldapCentralEntryManager.getOperationService() != null)) {
                logConnectionProviderStatistic(ldapCentralEntryManager, "centralConnectionProvider");
        }
    }

メンバ詳解

centralLdapService

CentralLdapService org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.centralLdapService

private

DEFAULT_INTERVAL

final int org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.DEFAULT_INTERVAL = 60

staticprivate

isActive

AtomicBoolean org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.isActive

private

ldapCentralEntryManager

PersistenceEntryManager org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.ldapCentralEntryManager

private

ldapEntryManager

PersistenceEntryManager org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.ldapEntryManager

private

log

Logger org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.log

private

timerEvent

Event<TimerEvent> org.gluu.oxtrust.service.status.ldap.LdapStatusTimer.timerEvent

private

---

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

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