org.xdi.oxauth.service.status.ldap.LdapStatusTimer クラス

org.xdi.oxauth.service.status.ldap.LdapStatusTimer 連携図

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

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

非公開変数類
Logger	log
Event< TimerEvent >	timerEvent
PersistenceEntryManager	ldapEntryManager
List< PersistenceEntryManager >	ldapAuthEntryManagers
AtomicBoolean	isActive

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

詳解

著者

Yuriy Movchan

バージョン

0.1, 11/18/2012

関数詳解

initTimer()

void org.xdi.oxauth.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.xdi.oxauth.service.status.ldap.LdapStatusTimer.logConnectionProviderStatistic ( PersistenceEntryManager  ldapEntryManager, String  connectionProviderName, String  bindConnectionProviderName  )

inline

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

            LdapConnectionProvider ldapConnectionProvider = ((LdapOperationService) persistenceOperationService).getConnectionProvider();
        LdapConnectionProvider bindLdapConnectionProvider = ((LdapOperationService) persistenceOperationService).getBindConnectionProvider();
        
        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());
            }
        }

        if (bindLdapConnectionProvider == null) {
                log.error("{} is empty", bindConnectionProviderName);
        } else {
            if (bindLdapConnectionProvider.getConnectionPool() == null) {
                log.error("{} is empty", bindConnectionProviderName);
            } else {
                log.debug("{} statistics: {}", bindConnectionProviderName, bindLdapConnectionProvider.getConnectionPool().getConnectionPoolStatistics());
            }
        }
        }

process()

void org.xdi.oxauth.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.xdi.oxauth.service.status.ldap.LdapStatusTimer.processInt ( )

inlineprivate

                              {
        logConnectionProviderStatistic(ldapEntryManager, "connectionProvider", "bindConnectionProvider");

        for (int i = 0; i < ldapAuthEntryManagers.size(); i++) {
                        PersistenceEntryManager ldapAuthEntryManager = ldapAuthEntryManagers.get(i);
                        logConnectionProviderStatistic(ldapAuthEntryManager, "authConnectionProvider#" + i, "bindAuthConnectionProvider#" + i);
        }
    }

メンバ詳解

DEFAULT_INTERVAL

final int org.xdi.oxauth.service.status.ldap.LdapStatusTimer.DEFAULT_INTERVAL = 60

staticprivate

isActive

AtomicBoolean org.xdi.oxauth.service.status.ldap.LdapStatusTimer.isActive

private

ldapAuthEntryManagers

List<PersistenceEntryManager> org.xdi.oxauth.service.status.ldap.LdapStatusTimer.ldapAuthEntryManagers

private

ldapEntryManager

PersistenceEntryManager org.xdi.oxauth.service.status.ldap.LdapStatusTimer.ldapEntryManager

private

log

Logger org.xdi.oxauth.service.status.ldap.LdapStatusTimer.log

private

timerEvent

Event<TimerEvent> org.xdi.oxauth.service.status.ldap.LdapStatusTimer.timerEvent

private

---

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

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