org.gluu.oxtrust.ldap.service.LogFileSizeChecker クラス

org.gluu.oxtrust.ldap.service.LogFileSizeChecker 連携図

公開メンバ関数
void	initTimer ()
void	process (@Observes @Scheduled LogFileSizeChekerEvent logFileSizeChekerEvent)

変数
ApplianceService	applianceService

非公開メンバ関数
void	processInt ()
List< LogDir >	readConfig (String source)

非公開変数類
Logger	log
Event< TimerEvent >	timerEvent
XmlService	xmlService
AtomicBoolean	isActive

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

詳解

関数詳解

initTimer()

void org.gluu.oxtrust.ldap.service.LogFileSizeChecker.initTimer ( )

inline

                            {
        log.info("Initializing Log File Size Checker Timer");
        this.isActive = new AtomicBoolean(false);

                final int delay = 2 * 60;
                final int interval = DEFAULT_INTERVAL;

                timerEvent.fire(new TimerEvent(new TimerSchedule(delay, interval), new LogFileSizeChekerEvent(),
                                Scheduled.Literal.INSTANCE));
    }

process()

void org.gluu.oxtrust.ldap.service.LogFileSizeChecker.process ( @Observes @Scheduled LogFileSizeChekerEvent  logFileSizeChekerEvent )

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.ldap.service.LogFileSizeChecker.processInt ( )

inlineprivate

Gather periodically site and server status

                                  {
                GluuAppliance appliance;
                appliance = applianceService.getAppliance();
                String maxLogSize = appliance.getMaxLogSize();
                log.debug("Max Log Size: " + maxLogSize);
                long maxSize = 0;

                try {
                        maxSize = Long.parseLong(maxLogSize); // MB
                } catch (Exception ex) {
                        log.error("appliance maxLogSize value is invalid: " + maxLogSize);
                        log.error("assuming 0");
                }

                if (maxSize > 0) {

                        log.debug("Max Log Size: " + maxLogSize);

                        long maxSizeInByte = maxSize * 1024 * 1024;
                        long currentSize = 0;
                        Date today = new Date();
                        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
                        String todayStr = sdf.format(today);

                        log.debug("Getting the tomcat home directory");
                        String filePath = ConfigurationFactory.DIR
                                        + ConfigurationFactory.LOG_ROTATION_CONFIGURATION;
                        log.debug("FilePath: " + filePath);

                        List<LogDir> logDirs = readConfig(filePath);

                        List<FileData> fDataList = new ArrayList<FileData>();
                        for (LogDir logDir : logDirs) {
                                File file = new File(logDir.getLocation());
                                File[] files = file.listFiles();
                                long totalSize = 0;

                                if (files != null && files.length > 0) {
                                        for (File singleFile : files) {
                                                if (singleFile.getName().startsWith(logDir.getPrefix()) && singleFile.getName().endsWith(logDir.getExtension())) {
                                                        totalSize += singleFile.length();
                                                        FileData fData = new FileData(singleFile.getName(), logDir.getLocation(), singleFile.lastModified(),
                                                                        singleFile.length());
                                                        fDataList.add(fData);
                                                }
                                        }
                                }

                                currentSize += totalSize;
                                logDir.setLength(totalSize);
                        }

                        Collections.sort(fDataList);
                        if (currentSize > maxSizeInByte) {
                                maxSizeInByte -= (maxSizeInByte * 15) / 100; // empty 15% space
                                                                                                                                // less of the
                                                                                                                                // maximum
                                                                                                                                // allocated
                        }
                        for (FileData fileData : fDataList) {
                                if (currentSize < maxSizeInByte) {
                                        break;
                                }
                                Date date = new Date(fileData.getLastModified());
                                String dateStr = sdf.format(date);
                                if (todayStr.equals(dateStr)) {
                                        log.debug("--Skipped Active File: " + fileData.getName() + " Date: " + sdf.format(date) + " Size: "
                                                        + fileData.getSize());
                                        continue;
                                }

                                File singleFile = new File(fileData.getFilePath() + "/" + fileData.getName());
                                if (!singleFile.delete()) {
                                        log.error("Failed to delete the file.");
                                } else {
                                        currentSize -= fileData.getSize();
                                        log.debug("--Deleted File Name: " + fileData.getName() + " Date: " + sdf.format(date) + " Size: " + fileData.getSize());
                                }
                        }
                }
        }

readConfig()

List<LogDir> org.gluu.oxtrust.ldap.service.LogFileSizeChecker.readConfig ( String  source )

inlineprivate

                                                       {
                List<LogDir> logDirs = new ArrayList<LogDir>();
                try {
                        org.w3c.dom.Document document = xmlService.getXmlDocument(FileUtils.readFileToByteArray(new File(source)));
                        XPath xPath = XPathFactory.newInstance().newXPath();
                        XPathExpression entriesXPath = xPath.compile("/entries/entry");

                        NodeList list = (NodeList) entriesXPath.evaluate(document, XPathConstants.NODESET);
                        for (int i = 0; i < list.getLength(); i++) {
                                Node node = list.item(i);

                                String prefix = null;
                                String location = null;
                                String extension = null;
                                
                                NodeList subList = node.getChildNodes();
                                for (int j = 0; j < subList.getLength(); j++) {
                                        Node subNode = subList.item(j);
                                        String subNodeName = subNode.getNodeName();
                                        String subNodeValue = subNode.getTextContent();
                                
                                        if (StringHelper.equalsIgnoreCase(subNodeName, "prefix")) {
                                                prefix = subNodeValue;
                                        } else if (StringHelper.equalsIgnoreCase(subNodeName, "location")) {
                                                location = subNodeValue;
                                        } else if (StringHelper.equalsIgnoreCase(subNodeName, "extension")) {
                                                extension = subNodeValue;
                                        }
                                }

                                if (extension == null || extension.trim().equals("")) {
                                        extension = "log";
                                }

                                LogDir logDir = new LogDir(prefix, location, extension);
                                logDirs.add(logDir);
                                log.debug("Prefix: " + prefix + " Location: " + location);
                        }
                } catch (Exception ex) {
                        log.debug("Exception while reading configuration file: " + ex);
                }
                return logDirs;
        }

メンバ詳解

applianceService

ApplianceService org.gluu.oxtrust.ldap.service.LogFileSizeChecker.applianceService

package

DEFAULT_INTERVAL

final int org.gluu.oxtrust.ldap.service.LogFileSizeChecker.DEFAULT_INTERVAL = 60 * 60 * 24

staticprivate

isActive

AtomicBoolean org.gluu.oxtrust.ldap.service.LogFileSizeChecker.isActive

private

log

Logger org.gluu.oxtrust.ldap.service.LogFileSizeChecker.log

private

timerEvent

Event<TimerEvent> org.gluu.oxtrust.ldap.service.LogFileSizeChecker.timerEvent

private

xmlService

XmlService org.gluu.oxtrust.ldap.service.LogFileSizeChecker.xmlService

private

---

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

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