[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [metrics-web/master] Use a distinct import history file for each importer.
commit 2c9c339af667350504bb021af0f87429ba6aadfb
Author: Karsten Loesing <karsten.loesing@xxxxxxx>
Date: Thu Dec 13 15:26:21 2012 +0100
Use a distinct import history file for each importer.
---
.../ernie/cron/BridgeStatsFileHandler.java | 4 ++--
.../ernie/cron/ConsensusStatsFileHandler.java | 2 +-
.../ernie/cron/PerformanceStatsImporter.java | 2 +-
.../cron/RelayDescriptorDatabaseImporter.java | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/org/torproject/ernie/cron/BridgeStatsFileHandler.java b/src/org/torproject/ernie/cron/BridgeStatsFileHandler.java
index 085394c..89d65a3 100644
--- a/src/org/torproject/ernie/cron/BridgeStatsFileHandler.java
+++ b/src/org/torproject/ernie/cron/BridgeStatsFileHandler.java
@@ -374,7 +374,7 @@ public class BridgeStatsFileHandler {
reader.addDirectory(bridgesDir);
if (keepBridgeDescriptorImportHistory) {
reader.setExcludeFiles(new File(statsDirectory,
- "bridge-descriptor-history"));
+ "bridge-stats-bridge-descriptor-history"));
}
Iterator<DescriptorFile> descriptorFiles = reader.readDescriptors();
while (descriptorFiles.hasNext()) {
@@ -449,7 +449,7 @@ public class BridgeStatsFileHandler {
reader.addDirectory(archivesDirectory);
if (keepRelayDescriptorImportHistory) {
reader.setExcludeFiles(new File(statsDirectory,
- "relay-descriptor-history"));
+ "bridge-stats-relay-descriptor-history"));
}
Iterator<DescriptorFile> descriptorFiles = reader.readDescriptors();
while (descriptorFiles.hasNext()) {
diff --git a/src/org/torproject/ernie/cron/ConsensusStatsFileHandler.java b/src/org/torproject/ernie/cron/ConsensusStatsFileHandler.java
index 1fcbf19..934401b 100644
--- a/src/org/torproject/ernie/cron/ConsensusStatsFileHandler.java
+++ b/src/org/torproject/ernie/cron/ConsensusStatsFileHandler.java
@@ -183,7 +183,7 @@ public class ConsensusStatsFileHandler {
reader.addDirectory(bridgesDir);
if (keepImportHistory) {
reader.setExcludeFiles(new File(statsDirectory,
- "bridge-descriptor-history"));
+ "consensus-stats-bridge-descriptor-history"));
}
Iterator<DescriptorFile> descriptorFiles = reader.readDescriptors();
while (descriptorFiles.hasNext()) {
diff --git a/src/org/torproject/ernie/cron/PerformanceStatsImporter.java b/src/org/torproject/ernie/cron/PerformanceStatsImporter.java
index 32d5911..105426b 100644
--- a/src/org/torproject/ernie/cron/PerformanceStatsImporter.java
+++ b/src/org/torproject/ernie/cron/PerformanceStatsImporter.java
@@ -201,7 +201,7 @@ public class PerformanceStatsImporter {
reader.addDirectory(archivesDirectory);
if (keepImportHistory) {
reader.setExcludeFiles(new File(statsDirectory,
- "connbidirect-relay-descriptor-history"));
+ "performance-stats-relay-descriptor-history"));
}
Iterator<DescriptorFile> descriptorFiles = reader.readDescriptors();
while (descriptorFiles.hasNext()) {
diff --git a/src/org/torproject/ernie/cron/RelayDescriptorDatabaseImporter.java b/src/org/torproject/ernie/cron/RelayDescriptorDatabaseImporter.java
index 05c663f..1bbd8d9 100644
--- a/src/org/torproject/ernie/cron/RelayDescriptorDatabaseImporter.java
+++ b/src/org/torproject/ernie/cron/RelayDescriptorDatabaseImporter.java
@@ -929,7 +929,7 @@ public final class RelayDescriptorDatabaseImporter {
reader.addDirectory(archivesDirectory);
if (keepImportHistory) {
reader.setExcludeFiles(new File(statsDirectory,
- "relay-descriptor-history"));
+ "database-importer-relay-descriptor-history"));
}
Iterator<DescriptorFile> descriptorFiles = reader.readDescriptors();
while (descriptorFiles.hasNext()) {
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits