org.xdi.oxd.server.license.LicenseFileUpdateService クラス

org.xdi.oxd.server.license.LicenseFileUpdateService 連携図

公開メンバ関数
void	start (Optional< LicenseFile > licenseFile)
void	updateLicenseFromServer ()
boolean	isRetryLimitExceeded ()

静的公開変数類
static final String	LICENSE_SERVER_ENDPOINT = "https://license.gluu.org/oxLicense"
static final int	RETRY_LIMIT = 3

関数
	LicenseFileUpdateService (OxdServerConfiguration conf, HttpService httpService)

非公開メンバ関数
boolean	lastModifiedLessThan12HoursAgo (long lastModified)
void	scheduleUpdatePinger ()
ScheduledExecutorService	newExecutor ()

非公開変数類
final OxdServerConfiguration	conf
final HttpService	httpService
AtomicInteger	retry = new AtomicInteger()

静的非公開変数類
static final Logger	LOG = LoggerFactory.getLogger(LicenseFileUpdateService.class)
static final int	ONE_HOUR_AS_MILLIS = 3600000
static final int	_24_HOURS_AS_MILLIS = 24 * ONE_HOUR_AS_MILLIS

詳解

著者

Yuriy Zabrovarnyy

バージョン

0.9, 12/10/2014

構築子と解体子

LicenseFileUpdateService()

org.xdi.oxd.server.license.LicenseFileUpdateService.LicenseFileUpdateService ( OxdServerConfiguration  conf, HttpService  httpService  )

inlinepackage

                                                                                   {
        this.conf = conf;
        this.httpService = httpService;
    }

関数詳解

isRetryLimitExceeded()

boolean org.xdi.oxd.server.license.LicenseFileUpdateService.isRetryLimitExceeded ( )

inline

                                          {
        return retry.get() > RETRY_LIMIT;
    }

lastModifiedLessThan12HoursAgo()

boolean org.xdi.oxd.server.license.LicenseFileUpdateService.lastModifiedLessThan12HoursAgo ( long  lastModified )

inlineprivate

                                                                      {
        long diff = System.currentTimeMillis() - lastModified;
        return diff < _24_HOURS_AS_MILLIS;
    }

newExecutor()

ScheduledExecutorService org.xdi.oxd.server.license.LicenseFileUpdateService.newExecutor ( )

inlineprivate

                                                   {
        return Executors.newSingleThreadScheduledExecutor(CoreUtils.daemonThreadFactory());
    }

scheduleUpdatePinger()

void org.xdi.oxd.server.license.LicenseFileUpdateService.scheduleUpdatePinger ( )

inlineprivate

                                        {
        newExecutor().scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                updateLicenseFromServer();
            }
        }, 24, 24, TimeUnit.HOURS);
    }

start()

void org.xdi.oxd.server.license.LicenseFileUpdateService.start ( Optional< LicenseFile >  licenseFile )

inline

                                                         {
        if (!licenseFile.isPresent() || !lastModifiedLessThan12HoursAgo(licenseFile.get().getLastModified())) {
            updateLicenseFromServer();
        }
        scheduleUpdatePinger();
    }

updateLicenseFromServer()

void org.xdi.oxd.server.license.LicenseFileUpdateService.updateLicenseFromServer ( )

inline

                                          {
        try {
            final GenerateWS generateWS = LicenseClient.generateWs(LICENSE_SERVER_ENDPOINT, httpService.getClientExecutor());

            final String macAddress = MacAddressProvider.macAddress();
            LOG.trace("Updating license, license_id: " + conf.getLicenseId() + ", retry: " + retry + " ... Mac address: " + macAddress);

            final List<LicenseResponse> generatedLicenses = generateWS.generatePost(conf.getLicenseId(), macAddress);
            if (generatedLicenses != null && !generatedLicenses.isEmpty() && !Strings.isNullOrEmpty(generatedLicenses.get(0).getEncodedLicense())) {
                final File file = LicenseFile.getLicenseFile();
                if (file != null) {
                    final String json = new LicenseFile(generatedLicenses.get(0).getEncodedLicense(), macAddress, conf.getLicenseId()).asJson();
                    FileUtils.write(file, json);

                    retry.set(0);
                    LOG.info("License file updated successfully. Mac address: " + macAddress);
                    return;
                }
            } else {
                retry.set(0);
                LOG.info("No license update, licenseId: " + conf.getLicenseId());
                return;
            }
        } catch (ClientResponseFailure e) {
            LOG.error(e.getMessage() + ", " + e.getResponse().getEntity(String.class), e);
        } catch (Exception e) {
            LOG.error(e.getMessage(), e);
        }
        LOG.trace("Failed to update license file by licenseId: " + conf.getLicenseId());

        retry.incrementAndGet();

        if (isRetryLimitExceeded()) {
            LicenseFile.deleteSilently();
            LOG.error("Shutdown server after trying to update license. Retry count: " + retry.get());
            ServerLauncher.shutdownDueToInvalidLicense();
        }

        newExecutor().schedule(new Runnable() {
            @Override
            public void run() {
                updateLicenseFromServer();
            }
        }, 3, TimeUnit.HOURS);
    }

メンバ詳解

_24_HOURS_AS_MILLIS

final int org.xdi.oxd.server.license.LicenseFileUpdateService._24_HOURS_AS_MILLIS = 24 * ONE_HOUR_AS_MILLIS

staticprivate

conf

final OxdServerConfiguration org.xdi.oxd.server.license.LicenseFileUpdateService.conf

private

httpService

final HttpService org.xdi.oxd.server.license.LicenseFileUpdateService.httpService

private

LICENSE_SERVER_ENDPOINT

final String org.xdi.oxd.server.license.LicenseFileUpdateService.LICENSE_SERVER_ENDPOINT = "https://license.gluu.org/oxLicense"

static

LOG

final Logger org.xdi.oxd.server.license.LicenseFileUpdateService.LOG = LoggerFactory.getLogger(LicenseFileUpdateService.class)

staticprivate

ONE_HOUR_AS_MILLIS

final int org.xdi.oxd.server.license.LicenseFileUpdateService.ONE_HOUR_AS_MILLIS = 3600000

staticprivate

retry

AtomicInteger org.xdi.oxd.server.license.LicenseFileUpdateService.retry = new AtomicInteger()

private

RETRY_LIMIT

final int org.xdi.oxd.server.license.LicenseFileUpdateService.RETRY_LIMIT = 3

static

---

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

• D:/AppData/OpenId/gluu/src/oxd/oxd-server/src/main/java/org/xdi/oxd/server/license/LicenseFileUpdateService.java