org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService クラス

org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService 連携図

公開メンバ関数
boolean	prepareSnapshotsFolder (CacheRefreshConfiguration cacheRefreshConfiguration)
boolean	createSnapshot (CacheRefreshConfiguration cacheRefreshConfiguration, Map< String, Integer > inumWithEntryHashCodeMap)
Map< String, Integer >	readSnapshot (CacheRefreshConfiguration cacheRefreshConfiguration, String snapshotFileName)
Map< String, Integer >	readLastSnapshot (CacheRefreshConfiguration cacheRefreshConfiguration)
boolean	retainSnapshots (CacheRefreshConfiguration cacheRefreshConfiguration, int count)
List< String >	readProblemList (CacheRefreshConfiguration cacheRefreshConfiguration)
boolean	writeProblemList (CacheRefreshConfiguration cacheRefreshConfiguration, Set< String > changedInums)

非公開メンバ関数
String []	getSnapshotsList (CacheRefreshConfiguration cacheRefreshConfiguration)

非公開変数類
Logger	log

静的非公開変数類
static final String	SNAPSHOT_FILE_NAME_PATTERN = "inum-snapshot-%s.txt"
static final String	PROBLEM_LIST_FILE_NAME = "problem-inum-list.txt"
static final String	SNAPSHOT_FILE_NAME_DATE_PATTERN = "yyyy-MM-dd-HH-mm"

詳解

Helper service to work with snapshots

著者

Yuriy Movchan Date: 06.09.2011

関数詳解

createSnapshot()

boolean org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.createSnapshot ( CacheRefreshConfiguration  cacheRefreshConfiguration, Map< String, Integer >  inumWithEntryHashCodeMap  )

inline

                                                                                                                                          {
                if (!prepareSnapshotsFolder(cacheRefreshConfiguration)) {
                        return false;
                }

                DateFormat fileNameDateFormat = new SimpleDateFormat(SNAPSHOT_FILE_NAME_DATE_PATTERN);
                String snapshotFileName = String.format(SNAPSHOT_FILE_NAME_PATTERN, fileNameDateFormat.format(new Date()));

                File file = new File(cacheRefreshConfiguration.getSnapshotFolder() + File.separator + snapshotFileName);
                BufferedWriter bos;
                try {
                        bos = new BufferedWriter(new FileWriter(file));
                } catch (IOException ex) {
                        log.error("Failed to create snapshot file '{}'", file.getAbsolutePath(), ex);
                        return false;
                }

                try {
                        for (Entry<String, Integer> entry : inumWithEntryHashCodeMap.entrySet()) {
                                bos.write(String.format("%s:%d\n", entry.getKey(), entry.getValue()));
                        }
                        bos.flush();
                } catch (IOException ex) {
                        log.error("Failed to create snapshot file '{}'", file.getAbsolutePath(), ex);
                        return false;
                } finally {
                        IOUtils.closeQuietly(bos);
                }

                return true;
        }

getSnapshotsList()

String [] org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.getSnapshotsList ( CacheRefreshConfiguration  cacheRefreshConfiguration )

inlineprivate

                                                                                               {
                File file = new File(cacheRefreshConfiguration.getSnapshotFolder());
                String[] files = file.list(new WildcardFileFilter(String.format(SNAPSHOT_FILE_NAME_PATTERN, "*")));
                Arrays.sort(files);

                return files;
        }

prepareSnapshotsFolder()

boolean org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.prepareSnapshotsFolder ( CacheRefreshConfiguration  cacheRefreshConfiguration )

inline

                                                                                                   {
                String snapshotFolder = cacheRefreshConfiguration.getSnapshotFolder();

                try {
                        File dir = new File(snapshotFolder);
                        if (!dir.exists()) {
                                FileUtils.forceMkdir(dir);
                        }
                } catch (IOException ex) {
                        log.error("Failed to create snapshot folder '{}'", snapshotFolder, ex);
                        return false;
                }

                return true;
        }

readLastSnapshot()

Map<String, Integer> org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.readLastSnapshot ( CacheRefreshConfiguration  cacheRefreshConfiguration )

inline

                                                                                                          {
                if (!prepareSnapshotsFolder(cacheRefreshConfiguration)) {
                        return null;
                }

                String[] snapshots = getSnapshotsList(cacheRefreshConfiguration);
                if (ArrayHelper.isEmpty(snapshots)) {
                        return null;
                }

                return readSnapshot(cacheRefreshConfiguration, snapshots[snapshots.length - 1]);
        }

readProblemList()

List<String> org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.readProblemList ( CacheRefreshConfiguration  cacheRefreshConfiguration )

inline

                                                                                                 {
                if (!prepareSnapshotsFolder(cacheRefreshConfiguration)) {
                        return null;
                }

                File file = new File(cacheRefreshConfiguration.getSnapshotFolder() + File.separator + PROBLEM_LIST_FILE_NAME);
                if (!file.exists()) {
                        return null;
                }

                BufferedReader bis;
                try {
                        bis = new BufferedReader(new FileReader(file));
                } catch (FileNotFoundException ex) {
                        log.error("Failed to load problem list from file '{}'", file.getAbsolutePath(), ex);
                        return null;
                }

                List<String> result = new ArrayList<String>();
                try {
                        String line;
                        while ((line = bis.readLine()) != null) {
                                result.add(line);
                        }
                } catch (IOException ex) {
                        log.error("Failed to load problem list from file '{}'", file.getAbsolutePath(), ex);
                        return null;
                } finally {
                        IOUtils.closeQuietly(bis);
                }

                return result;
        }

readSnapshot()

Map<String, Integer> org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.readSnapshot ( CacheRefreshConfiguration  cacheRefreshConfiguration, String  snapshotFileName  )

inline

                                                                                                                               {
                if (!prepareSnapshotsFolder(cacheRefreshConfiguration)) {
                        return null;
                }

                File file = new File(cacheRefreshConfiguration.getSnapshotFolder() + File.separator + snapshotFileName);
                if (!file.exists()) {
                        return null;
                }

                BufferedReader bis;
                try {
                        bis = new BufferedReader(new FileReader(file));
                } catch (FileNotFoundException ex) {
                        log.error("Failed to load snapshot file '{}'", file.getAbsolutePath(), ex);
                        return null;
                }

                Map<String, Integer> result = new HashMap<String, Integer>();
                try {
                        String line;
                        while ((line = bis.readLine()) != null) {
                                String[] lineValues = line.split(":");
                                if (lineValues.length != 2) {
                                        log.error("Failed to parse line: {}", line);
                                        return null;
                                }

                                try {
                                        result.put(lineValues[0], Integer.valueOf(lineValues[1]));
                                } catch (RuntimeException ex) {
                                        log.error("Failed to parse '{}' to integer", lineValues[1], ex);
                                        return null;
                                }
                        }
                } catch (IOException ex) {
                        log.error("Failed to load snapshot file '{}'", file.getAbsolutePath(), ex);
                        return null;
                } finally {
                        IOUtils.closeQuietly(bis);
                }

                return result;
        }

retainSnapshots()

boolean org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.retainSnapshots ( CacheRefreshConfiguration  cacheRefreshConfiguration, int  count  )

inline

                                                                                                       {
                if (!prepareSnapshotsFolder(cacheRefreshConfiguration)) {
                        return false;
                }

                String[] snapshots = getSnapshotsList(cacheRefreshConfiguration);
                if (ArrayHelper.isEmpty(snapshots)) {
                        return true;
                }

                for (int i = 0; i < snapshots.length - count; i++) {
                        File file = new File(cacheRefreshConfiguration.getSnapshotFolder() + File.separator + snapshots[i]);
                        if (!file.delete()) {
                                log.error("Failed to remove snaphost file '{}'", file.getAbsolutePath());
                        }
                }

                return true;
        }

writeProblemList()

boolean org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.writeProblemList ( CacheRefreshConfiguration  cacheRefreshConfiguration, Set< String >  changedInums  )

inline

                                                                                                                       {
                if (!prepareSnapshotsFolder(cacheRefreshConfiguration)) {
                        return false;
                }

                File file = new File(cacheRefreshConfiguration.getSnapshotFolder() + File.separator + PROBLEM_LIST_FILE_NAME);
                BufferedWriter bos;
                try {
                        bos = new BufferedWriter(new FileWriter(file));
                } catch (IOException ex) {
                        log.error("Failed to write problem list to file '{}'", file.getAbsolutePath(), ex);
                        return false;
                }

                try {
                        for (String changedInum : changedInums) {
                                bos.write(String.format("%s\n", changedInum));
                        }
                        bos.flush();
                } catch (IOException ex) {
                        log.error("Failed to write problem list to file '{}'", file.getAbsolutePath(), ex);
                        return false;
                } finally {
                        IOUtils.closeQuietly(bos);
                }

                return true;
        }

メンバ詳解

log

Logger org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.log

private

PROBLEM_LIST_FILE_NAME

final String org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.PROBLEM_LIST_FILE_NAME = "problem-inum-list.txt"

staticprivate

SNAPSHOT_FILE_NAME_DATE_PATTERN

final String org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.SNAPSHOT_FILE_NAME_DATE_PATTERN = "yyyy-MM-dd-HH-mm"

staticprivate

SNAPSHOT_FILE_NAME_PATTERN

final String org.gluu.oxtrust.ldap.cache.service.CacheRefreshSnapshotFileService.SNAPSHOT_FILE_NAME_PATTERN = "inum-snapshot-%s.txt"

staticprivate

---

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

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