Changeset 6049 for SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/scan/ScanCrawlTask.java

Timestamp:

02/25/15 11:11:38 (9 years ago)

Author:

emanuel.dima@uni-tuebingen.de

Message:

22. alpha 22: backup for corpora cache file + fix popup trigger

File:

• SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/scan/ScanCrawlTask.java (modified) (5 diffs)

SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/scan/ScanCrawlTask.java

@@ -24 +24 @@
         private AtomicReference<Corpora> corporaAtom;
         private File cachedCorpora;
+        private File oldCachedCorpora;
         private AtomicReference<Statistics> scanStatisticsAtom;
         private AtomicReference<Statistics> searchStatisticsAtom;
@@ -32 +33 @@
                         int cacheMaxDepth, List<URL> additionalCQLEndpoints,
                         EndpointFilter filter,
-                        AtomicReference<Corpora> corporaAtom, File cachedCorpora,
+                        AtomicReference<Corpora> corporaAtom,
+                        File cachedCorpora, File oldCachedCorpora,
                         AtomicReference<Statistics> scanStatisticsAtom,
                         AtomicReference<Statistics> searchStatisticsAtom
-                        ) {
+        ) {
                 this.sruClient = sruClient;
                 this.centerRegistryUrl = centerRegistryUrl;
@@ -43 +45 @@
                 this.corporaAtom = corporaAtom;
                 this.cachedCorpora = cachedCorpora;
+                this.oldCachedCorpora = oldCachedCorpora;
                 this.scanStatisticsAtom = scanStatisticsAtom;
                 this.searchStatisticsAtom = searchStatisticsAtom;
@@ -83 +86 @@
                                 log.warn("ScanCrawlTask: Skipped writing to disk (no corpora). Finished.");
                         } else {
-                                ObjectMapper mapper = new ObjectMapper();
-                                mapper.writerWithDefaultPrettyPrinter().writeValue(cachedCorpora, corpora);
+                                dump(corpora, cachedCorpora, oldCachedCorpora);
                                 log.info("ScanCrawlTask: wrote to disk, finished");
                         }
@@ -94 +96 @@
                 }
         }
+
+        private static void dump(Corpora corpora,
+                        File cachedCorpora, File oldCachedCorpora) throws IOException {
+                if (cachedCorpora.exists()) {
+                        try {
+                                oldCachedCorpora.delete();
+                        } catch (Throwable txc) {
+                                //ignore
+                        }
+                        try {
+                                cachedCorpora.renameTo(oldCachedCorpora);
+                        } catch (Throwable txc) {
+                                // ignore
+                        }
+                }
+                ObjectMapper mapper = new ObjectMapper();
+                mapper.writerWithDefaultPrettyPrinter().writeValue(cachedCorpora, corpora);
+        }
 }