tor-commits August 2018

tor-commits@lists.torproject.org

17 participants
2581 discussions

[onionoo/master] Use Map.putIfAbsent and Map.getOrDefault where possible.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit c51c4f20a56e56ff3d72b129666b824712f02d10 Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Tue Aug 21 14:46:16 2018 +0200 Use Map.putIfAbsent and Map.getOrDefault where possible. --- .../torproject/onionoo/docs/ClientsHistory.java | 9 +-- .../org/torproject/onionoo/docs/NodeStatus.java | 7 +-- .../onionoo/server/MostFrequentString.java | 17 ++---- .../org/torproject/onionoo/server/NodeIndexer.java | 68 ++++++---------------- .../onionoo/updater/ClientsStatusUpdater.java | 8 +-- .../onionoo/updater/DescriptorSource.java | 5 +- .../onionoo/updater/NodeDetailsStatusUpdater.java | 20 ++----- .../onionoo/updater/UptimeStatusUpdater.java | 9 +-- .../onionoo/docs/DummyDocumentStore.java | 4 +- .../onionoo/server/ResourceServletTest.java | 5 +- .../onionoo/updater/DummyDescriptorSource.java | 9 +-- 11 files changed, 42 insertions(+), 119 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/docs/ClientsHistory.java b/src/main/java/org/torproject/onionoo/docs/ClientsHistory.java index 0efe181..1890060 100644 --- a/src/main/java/org/torproject/onionoo/docs/ClientsHistory.java +++ b/src/main/java/org/torproject/onionoo/docs/ClientsHistory.java @@ -181,12 +181,9 @@ public class ClientsHistory implements Comparable<ClientsHistory> { SortedMap<String, Double> thisResponses, SortedMap<String, Double> otherResponses) { for (Map.Entry<String, Double> e : otherResponses.entrySet()) { - if (thisResponses.containsKey(e.getKey())) { - thisResponses.put(e.getKey(), thisResponses.get(e.getKey()) - + e.getValue()); - } else { - thisResponses.put(e.getKey(), e.getValue()); - } + thisResponses.putIfAbsent(e.getKey(), 0.0); + thisResponses.put(e.getKey(), thisResponses.get(e.getKey()) + + e.getValue()); } } diff --git a/src/main/java/org/torproject/onionoo/docs/NodeStatus.java b/src/main/java/org/torproject/onionoo/docs/NodeStatus.java index 9080b84..32965dd 100644 --- a/src/main/java/org/torproject/onionoo/docs/NodeStatus.java +++ b/src/main/java/org/torproject/onionoo/docs/NodeStatus.java @@ -335,11 +335,8 @@ public class NodeStatus extends Document { addressesAndPorts.add(address + ":" + dirPort); } addressesAndPorts.addAll(orAddressesAndPorts); - if (this.lastAddresses.containsKey(lastSeenMillis)) { - this.lastAddresses.get(lastSeenMillis).addAll(addressesAndPorts); - } else { - this.lastAddresses.put(lastSeenMillis, addressesAndPorts); - } + this.lastAddresses.putIfAbsent(lastSeenMillis, new TreeSet<>()); + this.lastAddresses.get(lastSeenMillis).addAll(addressesAndPorts); } /** Returns the time in milliseconds since the epoch when addresses or diff --git a/src/main/java/org/torproject/onionoo/server/MostFrequentString.java b/src/main/java/org/torproject/onionoo/server/MostFrequentString.java index 3d4d4c2..a6b7cb5 100644 --- a/src/main/java/org/torproject/onionoo/server/MostFrequentString.java +++ b/src/main/java/org/torproject/onionoo/server/MostFrequentString.java @@ -3,7 +3,6 @@ package org.torproject.onionoo.server; -import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.Map; @@ -17,12 +16,8 @@ class MostFrequentString { Map<String, Integer> stringFrequencies = new HashMap<>(); void addString(String string) { - if (!this.stringFrequencies.containsKey(string)) { - this.stringFrequencies.put(string, 1); - } else { - this.stringFrequencies.put(string, - this.stringFrequencies.get(string) + 1); - } + this.stringFrequencies.put(string, + this.stringFrequencies.getOrDefault(string, 0) + 1); } @Override @@ -33,12 +28,8 @@ class MostFrequentString { return "null (0)"; } for (Map.Entry<String, Integer> e : stringFrequencies.entrySet()) { - if (!sortedFrequencies.containsKey(e.getValue())) { - sortedFrequencies.put(e.getValue(), new TreeSet<>( - Arrays.asList(e.getKey()))); - } else { - sortedFrequencies.get(e.getValue()).add(e.getKey()); - } + sortedFrequencies.putIfAbsent(e.getValue(), new TreeSet<>()); + sortedFrequencies.get(e.getValue()).add(e.getKey()); } StringBuilder sb = new StringBuilder(); int stringsToAdd = 3; diff --git a/src/main/java/org/torproject/onionoo/server/NodeIndexer.java b/src/main/java/org/torproject/onionoo/server/NodeIndexer.java index 8388f33..80418aa 100644 --- a/src/main/java/org/torproject/onionoo/server/NodeIndexer.java +++ b/src/main/java/org/torproject/onionoo/server/NodeIndexer.java @@ -209,10 +209,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { * installations in international waters. */ countryCode = "xz"; } - if (!newRelaysByCountryCode.containsKey(countryCode)) { - newRelaysByCountryCode.put(countryCode, - new HashSet<>()); - } + newRelaysByCountryCode.putIfAbsent(countryCode, new HashSet<>()); newRelaysByCountryCode.get(countryCode).add(fingerprint); newRelaysByCountryCode.get(countryCode).add(hashedFingerprint); String asNumber; @@ -225,22 +222,16 @@ public class NodeIndexer implements ServletContextListener, Runnable { * shouldn't appear in any lookup databases. */ asNumber = "AS0"; } - if (!newRelaysByAsNumber.containsKey(asNumber)) { - newRelaysByAsNumber.put(asNumber, new HashSet<>()); - } + newRelaysByAsNumber.putIfAbsent(asNumber, new HashSet<>()); newRelaysByAsNumber.get(asNumber).add(fingerprint); newRelaysByAsNumber.get(asNumber).add(hashedFingerprint); String asName = entry.getAsName(); - if (!newRelaysByAsName.containsKey(asName)) { - newRelaysByAsName.put(asName, new HashSet<>()); - } + newRelaysByAsName.putIfAbsent(asName, new HashSet<>()); newRelaysByAsName.get(asName).add(fingerprint); newRelaysByAsName.get(asName).add(hashedFingerprint); for (String flag : entry.getRelayFlags()) { String flagLowerCase = flag.toLowerCase(); - if (!newRelaysByFlag.containsKey(flagLowerCase)) { - newRelaysByFlag.put(flagLowerCase, new HashSet<>()); - } + newRelaysByFlag.putIfAbsent(flagLowerCase, new HashSet<>()); newRelaysByFlag.get(flagLowerCase).add(fingerprint); newRelaysByFlag.get(flagLowerCase).add(hashedFingerprint); } @@ -258,42 +249,31 @@ public class NodeIndexer implements ServletContextListener, Runnable { int daysSinceFirstSeen = (int) (( (specialTime < 0 ? System.currentTimeMillis() : specialTime) - entry.getFirstSeenMillis()) / ONE_DAY); - if (!newRelaysByFirstSeenDays.containsKey(daysSinceFirstSeen)) { - newRelaysByFirstSeenDays.put(daysSinceFirstSeen, - new HashSet<>()); - } + newRelaysByFirstSeenDays.putIfAbsent(daysSinceFirstSeen, new HashSet<>()); newRelaysByFirstSeenDays.get(daysSinceFirstSeen).add(fingerprint); newRelaysByFirstSeenDays.get(daysSinceFirstSeen).add( hashedFingerprint); int daysSinceLastSeen = (int) (( (specialTime < 0 ? System.currentTimeMillis() : specialTime) - entry.getLastSeenMillis()) / ONE_DAY); - if (!newRelaysByLastSeenDays.containsKey(daysSinceLastSeen)) { - newRelaysByLastSeenDays.put(daysSinceLastSeen, - new HashSet<>()); - } + newRelaysByLastSeenDays.putIfAbsent(daysSinceLastSeen, new HashSet<>()); newRelaysByLastSeenDays.get(daysSinceLastSeen).add(fingerprint); newRelaysByLastSeenDays.get(daysSinceLastSeen).add( hashedFingerprint); String contact = entry.getContact(); - if (!newRelaysByContact.containsKey(contact)) { - newRelaysByContact.put(contact, new HashSet<>()); - } + newRelaysByContact.putIfAbsent(contact, new HashSet<>()); newRelaysByContact.get(contact).add(fingerprint); newRelaysByContact.get(contact).add(hashedFingerprint); String version = entry.getVersion(); if (null != version) { - if (!newRelaysByVersion.containsKey(version)) { - newRelaysByVersion.put(version, new HashSet<>()); - } + newRelaysByVersion.putIfAbsent(version, new HashSet<>()); newRelaysByVersion.get(version).add(fingerprint); newRelaysByVersion.get(version).add(hashedFingerprint); } String operatingSystem = entry.getOperatingSystem(); if (null != operatingSystem) { - if (!newRelaysByOperatingSystem.containsKey(operatingSystem)) { - newRelaysByOperatingSystem.put(operatingSystem, new HashSet<>()); - } + newRelaysByOperatingSystem.putIfAbsent(operatingSystem, + new HashSet<>()); newRelaysByOperatingSystem.get(operatingSystem).add(fingerprint); newRelaysByOperatingSystem.get(operatingSystem).add(hashedFingerprint); } @@ -308,9 +288,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { } for (String hostName : allHostNames) { String hostNameLowerCase = hostName.toLowerCase(); - if (!newRelaysByHostName.containsKey(hostNameLowerCase)) { - newRelaysByHostName.put(hostNameLowerCase, new HashSet<>()); - } + newRelaysByHostName.putIfAbsent(hostNameLowerCase, new HashSet<>()); newRelaysByHostName.get(hostNameLowerCase).add(fingerprint); newRelaysByHostName.get(hostNameLowerCase).add(hashedFingerprint); } @@ -346,9 +324,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { entry); for (String flag : entry.getRelayFlags()) { String flagLowerCase = flag.toLowerCase(); - if (!newBridgesByFlag.containsKey(flagLowerCase)) { - newBridgesByFlag.put(flagLowerCase, new HashSet<>()); - } + newBridgesByFlag.putIfAbsent(flagLowerCase, new HashSet<>()); newBridgesByFlag.get(flagLowerCase).add(hashedFingerprint); newBridgesByFlag.get(flagLowerCase).add( hashedHashedFingerprint); @@ -356,10 +332,8 @@ public class NodeIndexer implements ServletContextListener, Runnable { int daysSinceFirstSeen = (int) (( (specialTime < 0 ? System.currentTimeMillis() : specialTime) - entry.getFirstSeenMillis()) / ONE_DAY); - if (!newBridgesByFirstSeenDays.containsKey(daysSinceFirstSeen)) { - newBridgesByFirstSeenDays.put(daysSinceFirstSeen, - new HashSet<>()); - } + newBridgesByFirstSeenDays.putIfAbsent(daysSinceFirstSeen, + new HashSet<>()); newBridgesByFirstSeenDays.get(daysSinceFirstSeen).add( hashedFingerprint); newBridgesByFirstSeenDays.get(daysSinceFirstSeen).add( @@ -367,27 +341,21 @@ public class NodeIndexer implements ServletContextListener, Runnable { int daysSinceLastSeen = (int) (( (specialTime < 0 ? System.currentTimeMillis() : specialTime) - entry.getLastSeenMillis()) / ONE_DAY); - if (!newBridgesByLastSeenDays.containsKey(daysSinceLastSeen)) { - newBridgesByLastSeenDays.put(daysSinceLastSeen, - new HashSet<>()); - } + newBridgesByLastSeenDays.putIfAbsent(daysSinceLastSeen, new HashSet<>()); newBridgesByLastSeenDays.get(daysSinceLastSeen).add( hashedFingerprint); newBridgesByLastSeenDays.get(daysSinceLastSeen).add( hashedHashedFingerprint); String version = entry.getVersion(); if (null != version) { - if (!newBridgesByVersion.containsKey(version)) { - newBridgesByVersion.put(version, new HashSet<>()); - } + newBridgesByVersion.putIfAbsent(version, new HashSet<>()); newBridgesByVersion.get(version).add(hashedFingerprint); newBridgesByVersion.get(version).add(hashedHashedFingerprint); } String operatingSystem = entry.getOperatingSystem(); if (null != operatingSystem) { - if (!newBridgesByOperatingSystem.containsKey(operatingSystem)) { - newBridgesByOperatingSystem.put(operatingSystem, new HashSet<>()); - } + newBridgesByOperatingSystem.putIfAbsent(operatingSystem, + new HashSet<>()); newBridgesByOperatingSystem.get(operatingSystem) .add(hashedFingerprint); newBridgesByOperatingSystem.get(operatingSystem) diff --git a/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java b/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java index 205e391..e7ccd0b 100644 --- a/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java +++ b/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java @@ -114,12 +114,8 @@ public class ClientsStatusUpdater implements DescriptorListener, ClientsHistory newResponseHistory = new ClientsHistory( startMillis, endMillis, totalResponses, responsesByCountry, responsesByTransport, responsesByVersion); - if (!this.newResponses.containsKey(hashedFingerprint)) { - this.newResponses.put(hashedFingerprint, - new TreeSet<>()); - } - this.newResponses.get(hashedFingerprint).add( - newResponseHistory); + this.newResponses.putIfAbsent(hashedFingerprint, new TreeSet<>()); + this.newResponses.get(hashedFingerprint).add(newResponseHistory); } } diff --git a/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java b/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java index 65d342a..afa27a5 100644 --- a/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java +++ b/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java @@ -81,10 +81,7 @@ public class DescriptorSource { /** Registers a descriptor listener for a given descriptor type. */ public void registerDescriptorListener(DescriptorListener listener, DescriptorType descriptorType) { - if (!this.descriptorListeners.containsKey(descriptorType)) { - this.descriptorListeners.put(descriptorType, - new HashSet<>()); - } + this.descriptorListeners.putIfAbsent(descriptorType, new HashSet<>()); this.descriptorListeners.get(descriptorType).add(listener); } diff --git a/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java b/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java index 1cd989d..9bb4ab7 100644 --- a/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java +++ b/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java @@ -223,16 +223,11 @@ public class NodeDetailsStatusUpdater implements DescriptorListener, if (scanMillis < this.now - DateTimeHelper.ONE_DAY) { continue; } - if (!this.exitListEntries.containsKey(fingerprint)) { - this.exitListEntries.put(fingerprint, new HashMap<>()); - } + this.exitListEntries.putIfAbsent(fingerprint, new HashMap<>()); String exitAddress = exitAddressScanMillis.getKey(); - if (!this.exitListEntries.get(fingerprint).containsKey( - exitAddress) - || this.exitListEntries.get(fingerprint).get(exitAddress) + if (this.exitListEntries.get(fingerprint).getOrDefault(exitAddress, 0L) < scanMillis) { - this.exitListEntries.get(fingerprint).put(exitAddress, - scanMillis); + this.exitListEntries.get(fingerprint).put(exitAddress, scanMillis); } } } @@ -288,14 +283,12 @@ public class NodeDetailsStatusUpdater implements DescriptorListener, nodeStatus.setVersion(version); } if (entry.getUnmeasured()) { - if (!this.lastSeenUnmeasured.containsKey(fingerprint) - || this.lastSeenUnmeasured.get(fingerprint) + if (this.lastSeenUnmeasured.getOrDefault(fingerprint, 0L) < validAfterMillis) { this.lastSeenUnmeasured.put(fingerprint, validAfterMillis); } } else if (consensus.getConsensusMethod() >= 17) { - if (!this.lastSeenMeasured.containsKey(fingerprint) - || this.lastSeenMeasured.get(fingerprint) + if (this.lastSeenMeasured.getOrDefault(fingerprint, 0L) < validAfterMillis) { this.lastSeenMeasured.put(fingerprint, validAfterMillis); } @@ -846,8 +839,7 @@ public class NodeDetailsStatusUpdater implements DescriptorListener, this.exitListEntries.get(fingerprint).entrySet()) { String exitAddress = e.getKey(); long scanMillis = e.getValue(); - if (!exitAddresses.containsKey(exitAddress) - || exitAddresses.get(exitAddress) < scanMillis) { + if (exitAddresses.getOrDefault(exitAddress, 0L) < scanMillis) { exitAddresses.put(exitAddress, scanMillis); } } diff --git a/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java b/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java index f1ff574..58cd2fb 100644 --- a/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java +++ b/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java @@ -103,10 +103,7 @@ public class UptimeStatusUpdater implements DescriptorListener, for (NetworkStatusEntry entry : consensus.getStatusEntries().values()) { String fingerprint = entry.getFingerprint(); - if (!this.newRunningRelays.containsKey(fingerprint)) { - this.newRunningRelays.put(fingerprint, - new TreeMap<>()); - } + this.newRunningRelays.putIfAbsent(fingerprint, new TreeMap<>()); this.newRunningRelays.get(fingerprint).put(dateHourMillis, new Flags(entry.getFlags())); } @@ -124,9 +121,7 @@ public class UptimeStatusUpdater implements DescriptorListener, long dateHourMillis = (status.getPublishedMillis() / DateTimeHelper.ONE_HOUR) * DateTimeHelper.ONE_HOUR; for (String fingerprint : fingerprints) { - if (!this.newRunningBridges.containsKey(fingerprint)) { - this.newRunningBridges.put(fingerprint, new TreeSet<>()); - } + this.newRunningBridges.putIfAbsent(fingerprint, new TreeSet<>()); this.newRunningBridges.get(fingerprint).add(dateHourMillis); } this.newBridgeStatuses.add(dateHourMillis); diff --git a/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java b/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java index 3c79235..a8f51ae 100644 --- a/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java +++ b/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java @@ -19,9 +19,7 @@ public class DummyDocumentStore extends DocumentStore { private <T extends Document> SortedMap<String, Document> getStoredDocumentsByClass(Class<T> documentType) { - if (!this.storedDocuments.containsKey(documentType)) { - this.storedDocuments.put(documentType, new TreeMap<>()); - } + this.storedDocuments.putIfAbsent(documentType, new TreeMap<>()); return this.storedDocuments.get(documentType); } diff --git a/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java b/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java index 022381b..a6042b1 100644 --- a/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java +++ b/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java @@ -335,10 +335,7 @@ public class ResourceServletTest { new HashMap<>(); for (String parameter : uriParts[1].split("&")) { String[] parameterParts = parameter.split("="); - if (!parameterLists.containsKey(parameterParts[0])) { - parameterLists.put(parameterParts[0], - new ArrayList<>()); - } + parameterLists.putIfAbsent(parameterParts[0], new ArrayList<>()); parameterLists.get(parameterParts[0]).add(parameterParts[1]); } parameters = new HashMap<>(); diff --git a/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java b/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java index 22ae477..e31585d 100644 --- a/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java +++ b/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java @@ -31,9 +31,7 @@ public class DummyDescriptorSource extends DescriptorSource { private Set<Descriptor> getDescriptorsByType( DescriptorType descriptorType) { - if (!this.descriptors.containsKey(descriptorType)) { - this.descriptors.put(descriptorType, new HashSet<>()); - } + this.descriptors.putIfAbsent(descriptorType, new HashSet<>()); return this.descriptors.get(descriptorType); } @@ -43,10 +41,7 @@ public class DummyDescriptorSource extends DescriptorSource { /** Register a listener to receive descriptors of the demanded type. */ public void registerDescriptorListener(DescriptorListener listener, DescriptorType descriptorType) { - if (!this.descriptorListeners.containsKey(descriptorType)) { - this.descriptorListeners.put(descriptorType, - new HashSet<>()); - } + this.descriptorListeners.putIfAbsent(descriptorType, new HashSet<>()); this.descriptorListeners.get(descriptorType).add(listener); }

1 0

[onionoo/master] Remove an unnecessary return statement.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit 91588c989c0c4cd489b3a13f11683266247399cb Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Tue Aug 21 11:47:29 2018 +0200 Remove an unnecessary return statement. --- src/main/java/org/torproject/onionoo/server/RequestHandler.java | 1 - 1 file changed, 1 deletion(-) diff --git a/src/main/java/org/torproject/onionoo/server/RequestHandler.java b/src/main/java/org/torproject/onionoo/server/RequestHandler.java index 81cd8dc..d1e9cce 100644 --- a/src/main/java/org/torproject/onionoo/server/RequestHandler.java +++ b/src/main/java/org/torproject/onionoo/server/RequestHandler.java @@ -209,7 +209,6 @@ public class RequestHandler { private void filterByType() { if (this.type == null) { /* Not filtering by type. */ - return; } else if (this.type.equals("relay")) { this.filteredBridges.clear(); } else {

1 0

[onionoo/master] Make a couple JavaDoc fixes.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit 680118d0b0168865fae20a2d00109358817af98b Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Tue Aug 21 09:52:44 2018 +0200 Make a couple JavaDoc fixes. --- src/main/java/org/torproject/onionoo/docs/NodeStatus.java | 2 +- src/main/java/org/torproject/onionoo/docs/SummaryDocument.java | 6 +++--- src/main/java/org/torproject/onionoo/server/NodeIndexer.java | 6 +++--- src/main/java/org/torproject/onionoo/server/ResourceServlet.java | 4 ++-- src/main/java/org/torproject/onionoo/updater/LookupService.java | 2 +- src/main/java/org/torproject/onionoo/util/FormattingUtils.java | 2 +- 6 files changed, 11 insertions(+), 11 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/docs/NodeStatus.java b/src/main/java/org/torproject/onionoo/docs/NodeStatus.java index fe55229..1940198 100644 --- a/src/main/java/org/torproject/onionoo/docs/NodeStatus.java +++ b/src/main/java/org/torproject/onionoo/docs/NodeStatus.java @@ -29,7 +29,7 @@ import java.util.stream.Collectors; * are relevant descriptors, consensuses or other documents available. * * <p>At the end of each run of the hourly updater, these documents are - * concatenated and written to a single file in <code>status/summary</code>. + * concatenated and written to a single file in {@code status/summary}. * Each line contains a single document. * * <p>A new NodeStatus can be created from a string using the diff --git a/src/main/java/org/torproject/onionoo/docs/SummaryDocument.java b/src/main/java/org/torproject/onionoo/docs/SummaryDocument.java index c4308ec..5286f6c 100644 --- a/src/main/java/org/torproject/onionoo/docs/SummaryDocument.java +++ b/src/main/java/org/torproject/onionoo/docs/SummaryDocument.java @@ -58,7 +58,7 @@ public class SummaryDocument extends Document { @JsonIgnore private transient String hashedFingerprint = null; - /** Returns the SHA1-hashed fingerprint, or <code>null</code> if no + /** Returns the SHA1-hashed fingerprint, or {@code null} if no * fingerprint is set. */ public String getHashedFingerprint() { if (this.hashedFingerprint == null && this.fingerprint != null) { @@ -75,7 +75,7 @@ public class SummaryDocument extends Document { @JsonIgnore private transient String base64Fingerprint = null; - /** Returns the base64-encoded fingerprint, or <code>null</code> if no + /** Returns the base64-encoded fingerprint, or {@code null} if no * fingerprint is set. */ public String getBase64Fingerprint() { if (this.base64Fingerprint == null && this.fingerprint != null) { @@ -93,7 +93,7 @@ public class SummaryDocument extends Document { private transient String[] fingerprintSortedHexBlocks = null; /** Returns a sorted array containing blocks of 4 upper-case hex - * characters from the fingerprint, or <code>null</code> if no + * characters from the fingerprint, or {@code null} if no * fingerprint is set. */ public String[] getFingerprintSortedHexBlocks() { if (this.fingerprintSortedHexBlocks == null && this.fingerprint != null) { diff --git a/src/main/java/org/torproject/onionoo/server/NodeIndexer.java b/src/main/java/org/torproject/onionoo/server/NodeIndexer.java index 350a3ef..73b6777 100644 --- a/src/main/java/org/torproject/onionoo/server/NodeIndexer.java +++ b/src/main/java/org/torproject/onionoo/server/NodeIndexer.java @@ -61,8 +61,8 @@ public class NodeIndexer implements ServletContextListener, Runnable { private Thread nodeIndexerThread = null; /** Returns the creation time of the last known node index in - * milliseconds since the epoch, or <code>-1</code> if no node index - * could be retrieved within <code>timeoutMillis</code> milliseconds. */ + * milliseconds since the epoch, or {@code -1} if no node index + * could be retrieved within {@code timeoutMillis} milliseconds. */ public synchronized long getLastIndexed(long timeoutMillis) { if (this.lastIndexed == -1L && this.nodeIndexerThread != null && timeoutMillis > 0L) { @@ -77,7 +77,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { } /** Returns the last known node index, or null if no node index could be - * retrieved within <code>timeoutMillis</code> milliseconds. */ + * retrieved within {@code timeoutMillis} milliseconds. */ public synchronized NodeIndex getLatestNodeIndex(long timeoutMillis) { if (this.latestNodeIndex == null && this.nodeIndexerThread != null && timeoutMillis > 0L) { diff --git a/src/main/java/org/torproject/onionoo/server/ResourceServlet.java b/src/main/java/org/torproject/onionoo/server/ResourceServlet.java index 7567233..7913d22 100644 --- a/src/main/java/org/torproject/onionoo/server/ResourceServlet.java +++ b/src/main/java/org/torproject/onionoo/server/ResourceServlet.java @@ -86,8 +86,8 @@ public class ResourceServlet extends HttpServlet { doGet(request, response, System.currentTimeMillis()); } - /** Handles the HTTP GET request in the wrapped <code>request</code> by - * writing an HTTP GET response to the likewise <code>response</code>, + /** Handles the HTTP GET request in the wrapped {@code request} by + * writing an HTTP GET response to the likewise {@code response}, * both of which are wrapped to facilitate testing. */ @SuppressWarnings("checkstyle:variabledeclarationusagedistance") public void doGet(HttpServletRequestWrapper request, diff --git a/src/main/java/org/torproject/onionoo/updater/LookupService.java b/src/main/java/org/torproject/onionoo/updater/LookupService.java index 976a9ca..dd35b59 100644 --- a/src/main/java/org/torproject/onionoo/updater/LookupService.java +++ b/src/main/java/org/torproject/onionoo/updater/LookupService.java @@ -98,7 +98,7 @@ public class LookupService { } /** Looks up address strings in the configured - * <code>GeoLite2-City-*.csv</code> and <code>GeoIPASNum2.csv</code> + * {@code GeoLite2-City-*.csv} and {@code GeoIPASNum2.csv} * files and returns all lookup results. */ public SortedMap<String, LookupResult> lookup( SortedSet<String> addressStrings) { diff --git a/src/main/java/org/torproject/onionoo/util/FormattingUtils.java b/src/main/java/org/torproject/onionoo/util/FormattingUtils.java index 558477d..5307384 100644 --- a/src/main/java/org/torproject/onionoo/util/FormattingUtils.java +++ b/src/main/java/org/torproject/onionoo/util/FormattingUtils.java @@ -25,7 +25,7 @@ public class FormattingUtils { private static final long ONE_MINUTE = 60L * ONE_SECOND; /** Formats the given number of milliseconds using the format - * <code>"${minutes}:${seconds}.{milliseconds} minutes"</code>. */ + * {@code "${minutes}:${seconds}.{milliseconds} minutes"}. */ public static String formatMillis(long millis) { return String.format("%02d:%02d.%03d minutes", millis / ONE_MINUTE, (millis % ONE_MINUTE) / ONE_SECOND, millis % ONE_SECOND);

1 0

[onionoo/master] Fix trivial bug in parsing bridge extra-info descriptors.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit ba53eddc3735191ec8b11a3178c3cb0190460c3e Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Tue Aug 21 12:03:45 2018 +0200 Fix trivial bug in parsing bridge extra-info descriptors. If the first thing we'd learn from a bridge was an extra-info descriptor, we would not have stored the contained transports. This case is very unlikely and has very little effect. Worth fixing anyway. Found via code analysis. --- .../onionoo/updater/NodeDetailsStatusUpdater.java | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java b/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java index 7223e5a..1cd989d 100644 --- a/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java +++ b/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java @@ -346,14 +346,16 @@ public class NodeDetailsStatusUpdater implements DescriptorListener, DetailsStatus.class, true, fingerprint); if (detailsStatus == null) { detailsStatus = new DetailsStatus(); - } else if (null == detailsStatus.getExtraInfoDescPublished() - || descriptor.getPublishedMillis() - > detailsStatus.getExtraInfoDescPublished()) { - detailsStatus.setExtraInfoDescPublished( - descriptor.getPublishedMillis()); - detailsStatus.setTransports(descriptor.getTransports()); - this.documentStore.store(detailsStatus, fingerprint); + } else if (null != detailsStatus.getExtraInfoDescPublished() + && detailsStatus.getExtraInfoDescPublished() + >= descriptor.getPublishedMillis()) { + /* Already parsed more recent extra-info descriptor from this bridge. */ + return; } + detailsStatus.setExtraInfoDescPublished( + descriptor.getPublishedMillis()); + detailsStatus.setTransports(descriptor.getTransports()); + this.documentStore.store(detailsStatus, fingerprint); } private void processBridgeNetworkStatus(BridgeNetworkStatus status) {

1 0

[onionoo/master] Replace Comparator with lambda.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit ec16e791150785cfda603961469bc86bd65218a7 Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Mon Aug 20 12:37:07 2018 +0200 Replace Comparator with lambda. --- .../org/torproject/onionoo/docs/WeightsStatus.java | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/docs/WeightsStatus.java b/src/main/java/org/torproject/onionoo/docs/WeightsStatus.java index c221fdd..adce2c8 100644 --- a/src/main/java/org/torproject/onionoo/docs/WeightsStatus.java +++ b/src/main/java/org/torproject/onionoo/docs/WeightsStatus.java @@ -27,16 +27,14 @@ public class WeightsStatus extends Document { this.isDirty = false; } - private Comparator<long[]> histComparator = new Comparator<long[]>() { - public int compare(long[] first, long[] second) { - int relation = Long.compare(first[0], second[0]); - if (0 != relation) { - return relation; - } else { - return Long.compare(first[1], second[1]); - } - } - }; + private Comparator<long[]> histComparator = (first, second) -> { + int relation = Long.compare(first[0], second[0]); + if (0 != relation) { + return relation; + } else { + return Long.compare(first[1], second[1]); + } + }; private SortedMap<long[], double[]> history = new TreeMap<>(histComparator);

1 0

[onionoo/master] Remove unthrown exceptions.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit 54dfc8985ee7da543644762f8011f1323e53e24e Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Mon Aug 20 14:50:52 2018 +0200 Remove unthrown exceptions. --- src/main/java/org/torproject/onionoo/server/ResourceServlet.java | 2 +- src/main/java/org/torproject/onionoo/updater/LookupService.java | 6 ++---- .../java/org/torproject/onionoo/server/ResourceServletTest.java | 4 ++-- .../torproject/onionoo/updater/NodeDetailsStatusUpdaterTest.java | 2 +- 4 files changed, 6 insertions(+), 8 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/server/ResourceServlet.java b/src/main/java/org/torproject/onionoo/server/ResourceServlet.java index afcb867..1c72b9e 100644 --- a/src/main/java/org/torproject/onionoo/server/ResourceServlet.java +++ b/src/main/java/org/torproject/onionoo/server/ResourceServlet.java @@ -51,7 +51,7 @@ public class ResourceServlet extends HttpServlet { @Override public void doGet(HttpServletRequest request, - HttpServletResponse response) throws IOException, ServletException { + HttpServletResponse response) throws IOException { HttpServletRequestWrapper requestWrapper = new HttpServletRequestWrapper(request); HttpServletResponseWrapper responseWrapper = diff --git a/src/main/java/org/torproject/onionoo/updater/LookupService.java b/src/main/java/org/torproject/onionoo/updater/LookupService.java index 4bcc754..4af4443 100644 --- a/src/main/java/org/torproject/onionoo/updater/LookupService.java +++ b/src/main/java/org/torproject/onionoo/updater/LookupService.java @@ -14,7 +14,6 @@ import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStreamReader; -import java.nio.charset.CharacterCodingException; import java.nio.charset.CharsetDecoder; import java.nio.charset.CodingErrorAction; import java.nio.charset.StandardCharsets; @@ -340,14 +339,13 @@ public class LookupService { } private BufferedReader createBufferedReaderFromUtf8File(File utf8File) - throws FileNotFoundException, CharacterCodingException { + throws FileNotFoundException { return this.createBufferedReaderFromFile(utf8File, StandardCharsets.UTF_8.newDecoder()); } private BufferedReader createBufferedReaderFromIso88591File( - File iso88591File) throws FileNotFoundException, - CharacterCodingException { + File iso88591File) throws FileNotFoundException { return this.createBufferedReaderFromFile(iso88591File, StandardCharsets.ISO_8859_1.newDecoder()); } diff --git a/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java b/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java index bc01003..0be1635 100644 --- a/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java +++ b/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java @@ -87,7 +87,7 @@ public class ResourceServletTest { private int errorStatusCode; - protected void sendError(int errorStatusCode) throws IOException { + protected void sendError(int errorStatusCode) { this.errorStatusCode = errorStatusCode; } @@ -385,7 +385,7 @@ public class ResourceServletTest { } @Test(timeout = 100) - public void testValidSummaryRelay() throws IOException { + public void testValidSummaryRelay() { this.runTest("/summary"); assertEquals("2013-04-24 12:00:00", this.summaryDocument.relays_published); diff --git a/src/test/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdaterTest.java b/src/test/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdaterTest.java index 1bcc7eb..068c724 100644 --- a/src/test/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdaterTest.java +++ b/src/test/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdaterTest.java @@ -33,7 +33,7 @@ public class NodeDetailsStatusUpdaterTest { } @Test - public void testExitReset() throws Exception { + public void testExitReset() { NodeDetailsStatusUpdater ndsu = new NodeDetailsStatusUpdater(null, null); DescriptorParser dp = DescriptorSourceFactory.createDescriptorParser(); String descString = RELAY1 + PUB1 + RELAY2 + POLICY1 + RELAY3;

1 0

[onionoo/master] Use diamond operator.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit 38bd70aecb7b6c0a1440a31ec0a5585b2a2c8ef4 Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Mon Aug 20 15:05:33 2018 +0200 Use diamond operator. --- .../org/torproject/onionoo/docs/DetailsDocument.java | 2 +- .../org/torproject/onionoo/docs/DetailsStatus.java | 2 +- .../java/org/torproject/onionoo/docs/NodeStatus.java | 2 +- .../org/torproject/onionoo/server/NodeIndexer.java | 20 ++++++++++---------- .../onionoo/updater/ClientsStatusUpdater.java | 2 +- .../torproject/onionoo/updater/DescriptorSource.java | 2 +- .../onionoo/updater/NodeDetailsStatusUpdater.java | 2 +- .../onionoo/updater/RdnsLookupRequest.java | 2 +- .../onionoo/updater/UptimeStatusUpdater.java | 4 ++-- .../torproject/onionoo/docs/DummyDocumentStore.java | 2 +- .../onionoo/server/ResourceServletTest.java | 10 +++++----- .../onionoo/updater/DummyDescriptorSource.java | 4 ++-- .../onionoo/updater/LookupServiceTest.java | 6 +++--- 13 files changed, 30 insertions(+), 30 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/docs/DetailsDocument.java b/src/main/java/org/torproject/onionoo/docs/DetailsDocument.java index 5e53d4c..504f0b5 100644 --- a/src/main/java/org/torproject/onionoo/docs/DetailsDocument.java +++ b/src/main/java/org/torproject/onionoo/docs/DetailsDocument.java @@ -76,7 +76,7 @@ public class DetailsDocument extends Document { } public List<String> getExitAddresses() { - return this.exitAddresses == null ? new ArrayList<String>() + return this.exitAddresses == null ? new ArrayList<>() : this.exitAddresses; } diff --git a/src/main/java/org/torproject/onionoo/docs/DetailsStatus.java b/src/main/java/org/torproject/onionoo/docs/DetailsStatus.java index 7cd87ee..31762d3 100644 --- a/src/main/java/org/torproject/onionoo/docs/DetailsStatus.java +++ b/src/main/java/org/torproject/onionoo/docs/DetailsStatus.java @@ -248,7 +248,7 @@ public class DetailsStatus extends Document { } public SortedSet<String> getOrAddressesAndPorts() { - return this.orAddressesAndPorts == null ? new TreeSet<String>() : + return this.orAddressesAndPorts == null ? new TreeSet<>() : this.orAddressesAndPorts; } diff --git a/src/main/java/org/torproject/onionoo/docs/NodeStatus.java b/src/main/java/org/torproject/onionoo/docs/NodeStatus.java index c0c6adf..bef403b 100644 --- a/src/main/java/org/torproject/onionoo/docs/NodeStatus.java +++ b/src/main/java/org/torproject/onionoo/docs/NodeStatus.java @@ -182,7 +182,7 @@ public class NodeStatus extends Document { } public SortedSet<String> getOrAddressesAndPorts() { - return this.orAddressesAndPorts == null ? new TreeSet<String>() + return this.orAddressesAndPorts == null ? new TreeSet<>() : this.orAddressesAndPorts; } diff --git a/src/main/java/org/torproject/onionoo/server/NodeIndexer.java b/src/main/java/org/torproject/onionoo/server/NodeIndexer.java index 3812fea..350a3ef 100644 --- a/src/main/java/org/torproject/onionoo/server/NodeIndexer.java +++ b/src/main/java/org/torproject/onionoo/server/NodeIndexer.java @@ -211,7 +211,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { } if (!newRelaysByCountryCode.containsKey(countryCode)) { newRelaysByCountryCode.put(countryCode, - new HashSet<String>()); + new HashSet<>()); } newRelaysByCountryCode.get(countryCode).add(fingerprint); newRelaysByCountryCode.get(countryCode).add(hashedFingerprint); @@ -226,7 +226,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { asNumber = "AS0"; } if (!newRelaysByAsNumber.containsKey(asNumber)) { - newRelaysByAsNumber.put(asNumber, new HashSet<String>()); + newRelaysByAsNumber.put(asNumber, new HashSet<>()); } newRelaysByAsNumber.get(asNumber).add(fingerprint); newRelaysByAsNumber.get(asNumber).add(hashedFingerprint); @@ -239,7 +239,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { for (String flag : entry.getRelayFlags()) { String flagLowerCase = flag.toLowerCase(); if (!newRelaysByFlag.containsKey(flagLowerCase)) { - newRelaysByFlag.put(flagLowerCase, new HashSet<String>()); + newRelaysByFlag.put(flagLowerCase, new HashSet<>()); } newRelaysByFlag.get(flagLowerCase).add(fingerprint); newRelaysByFlag.get(flagLowerCase).add(hashedFingerprint); @@ -260,7 +260,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { - entry.getFirstSeenMillis()) / ONE_DAY); if (!newRelaysByFirstSeenDays.containsKey(daysSinceFirstSeen)) { newRelaysByFirstSeenDays.put(daysSinceFirstSeen, - new HashSet<String>()); + new HashSet<>()); } newRelaysByFirstSeenDays.get(daysSinceFirstSeen).add(fingerprint); newRelaysByFirstSeenDays.get(daysSinceFirstSeen).add( @@ -270,21 +270,21 @@ public class NodeIndexer implements ServletContextListener, Runnable { - entry.getLastSeenMillis()) / ONE_DAY); if (!newRelaysByLastSeenDays.containsKey(daysSinceLastSeen)) { newRelaysByLastSeenDays.put(daysSinceLastSeen, - new HashSet<String>()); + new HashSet<>()); } newRelaysByLastSeenDays.get(daysSinceLastSeen).add(fingerprint); newRelaysByLastSeenDays.get(daysSinceLastSeen).add( hashedFingerprint); String contact = entry.getContact(); if (!newRelaysByContact.containsKey(contact)) { - newRelaysByContact.put(contact, new HashSet<String>()); + newRelaysByContact.put(contact, new HashSet<>()); } newRelaysByContact.get(contact).add(fingerprint); newRelaysByContact.get(contact).add(hashedFingerprint); String version = entry.getVersion(); if (null != version) { if (!newRelaysByVersion.containsKey(version)) { - newRelaysByVersion.put(version, new HashSet<String>()); + newRelaysByVersion.put(version, new HashSet<>()); } newRelaysByVersion.get(version).add(fingerprint); newRelaysByVersion.get(version).add(hashedFingerprint); @@ -347,7 +347,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { for (String flag : entry.getRelayFlags()) { String flagLowerCase = flag.toLowerCase(); if (!newBridgesByFlag.containsKey(flagLowerCase)) { - newBridgesByFlag.put(flagLowerCase, new HashSet<String>()); + newBridgesByFlag.put(flagLowerCase, new HashSet<>()); } newBridgesByFlag.get(flagLowerCase).add(hashedFingerprint); newBridgesByFlag.get(flagLowerCase).add( @@ -358,7 +358,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { - entry.getFirstSeenMillis()) / ONE_DAY); if (!newBridgesByFirstSeenDays.containsKey(daysSinceFirstSeen)) { newBridgesByFirstSeenDays.put(daysSinceFirstSeen, - new HashSet<String>()); + new HashSet<>()); } newBridgesByFirstSeenDays.get(daysSinceFirstSeen).add( hashedFingerprint); @@ -369,7 +369,7 @@ public class NodeIndexer implements ServletContextListener, Runnable { - entry.getLastSeenMillis()) / ONE_DAY); if (!newBridgesByLastSeenDays.containsKey(daysSinceLastSeen)) { newBridgesByLastSeenDays.put(daysSinceLastSeen, - new HashSet<String>()); + new HashSet<>()); } newBridgesByLastSeenDays.get(daysSinceLastSeen).add( hashedFingerprint); diff --git a/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java b/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java index 0529dcf..8265f43 100644 --- a/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java +++ b/src/main/java/org/torproject/onionoo/updater/ClientsStatusUpdater.java @@ -116,7 +116,7 @@ public class ClientsStatusUpdater implements DescriptorListener, responsesByTransport, responsesByVersion); if (!this.newResponses.containsKey(hashedFingerprint)) { this.newResponses.put(hashedFingerprint, - new TreeSet<ClientsHistory>()); + new TreeSet<>()); } this.newResponses.get(hashedFingerprint).add( newResponseHistory); diff --git a/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java b/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java index 20e249d..64bb0e4 100644 --- a/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java +++ b/src/main/java/org/torproject/onionoo/updater/DescriptorSource.java @@ -83,7 +83,7 @@ public class DescriptorSource { DescriptorType descriptorType) { if (!this.descriptorListeners.containsKey(descriptorType)) { this.descriptorListeners.put(descriptorType, - new HashSet<DescriptorListener>()); + new HashSet<>()); } this.descriptorListeners.get(descriptorType).add(listener); } diff --git a/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java b/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java index 507d633..82cea1b 100644 --- a/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java +++ b/src/main/java/org/torproject/onionoo/updater/NodeDetailsStatusUpdater.java @@ -224,7 +224,7 @@ public class NodeDetailsStatusUpdater implements DescriptorListener, continue; } if (!this.exitListEntries.containsKey(fingerprint)) { - this.exitListEntries.put(fingerprint, new HashMap<String, Long>()); + this.exitListEntries.put(fingerprint, new HashMap<>()); } String exitAddress = exitAddressScanMillis.getKey(); if (!this.exitListEntries.get(fingerprint).containsKey( diff --git a/src/main/java/org/torproject/onionoo/updater/RdnsLookupRequest.java b/src/main/java/org/torproject/onionoo/updater/RdnsLookupRequest.java index 380b62c..9f3c6cf 100644 --- a/src/main/java/org/torproject/onionoo/updater/RdnsLookupRequest.java +++ b/src/main/java/org/torproject/onionoo/updater/RdnsLookupRequest.java @@ -91,7 +91,7 @@ class RdnsLookupRequest extends Thread { envProps.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.dns.DnsContextFactory"); final DirContext dnsContext = new InitialDirContext(envProps); - Set<String> results = new TreeSet<String>(); + Set<String> results = new TreeSet<>(); Attributes dnsEntries = dnsContext.getAttributes(hostName, new String[] { type }); if (dnsEntries != null) { diff --git a/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java b/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java index 8405bf8..338bf58 100644 --- a/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java +++ b/src/main/java/org/torproject/onionoo/updater/UptimeStatusUpdater.java @@ -105,7 +105,7 @@ public class UptimeStatusUpdater implements DescriptorListener, String fingerprint = entry.getFingerprint(); if (!this.newRunningRelays.containsKey(fingerprint)) { this.newRunningRelays.put(fingerprint, - new TreeMap<Long, Flags>()); + new TreeMap<>()); } this.newRunningRelays.get(fingerprint).put(dateHourMillis, new Flags(entry.getFlags())); @@ -125,7 +125,7 @@ public class UptimeStatusUpdater implements DescriptorListener, / DateTimeHelper.ONE_HOUR) * DateTimeHelper.ONE_HOUR; for (String fingerprint : fingerprints) { if (!this.newRunningBridges.containsKey(fingerprint)) { - this.newRunningBridges.put(fingerprint, new TreeSet<Long>()); + this.newRunningBridges.put(fingerprint, new TreeSet<>()); } this.newRunningBridges.get(fingerprint).add(dateHourMillis); } diff --git a/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java b/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java index 8827725..3c79235 100644 --- a/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java +++ b/src/test/java/org/torproject/onionoo/docs/DummyDocumentStore.java @@ -20,7 +20,7 @@ public class DummyDocumentStore extends DocumentStore { private <T extends Document> SortedMap<String, Document> getStoredDocumentsByClass(Class<T> documentType) { if (!this.storedDocuments.containsKey(documentType)) { - this.storedDocuments.put(documentType, new TreeMap<String, Document>()); + this.storedDocuments.put(documentType, new TreeMap<>()); } return this.storedDocuments.get(documentType); } diff --git a/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java b/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java index 0be1635..063f550 100644 --- a/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java +++ b/src/test/java/org/torproject/onionoo/server/ResourceServletTest.java @@ -56,7 +56,7 @@ public class ResourceServletTest { this.requestUri = requestUri; this.queryString = queryString; this.parameterMap = parameterMap == null - ? new HashMap<String, String[]>() : parameterMap; + ? new HashMap<>() : parameterMap; } @Override @@ -162,8 +162,8 @@ public class ResourceServletTest { "Running", "V2Dir", "Valid" })), 1140L, "us", DateTimeHelper.parse("2013-04-16 18:00:00"), "AS7922", "comcast cable communications, llc", null, - new TreeSet<String>(Arrays.asList(new String[] { - "000C5F55BD4814B917CC474BD537F1A3B33CCE2A" })), + new TreeSet<>(Arrays.asList(new String[]{ + "000C5F55BD4814B917CC474BD537F1A3B33CCE2A"})), new TreeSet<>(Arrays.asList(new String[] { "000C5F55BD4814B917CC474BD537F1A3B33CCE2A" })), null, null, new TreeSet<>(Arrays.asList( @@ -182,7 +182,7 @@ public class ResourceServletTest { "liberty global operations b.v.", "1024d/51e2a1c7 \"steven j. murdoch\" " + "<tor+steven.murdoch(a)cl.cam.ac.uk> <fb-token:5sr_k_zs2wm=>", - new TreeSet<String>(), new TreeSet<String>(), "0.2.3.24-rc-dev", + new TreeSet<>(), new TreeSet<>(), "0.2.3.24-rc-dev", "windows xp", null, null, false); this.relays.put("0025C136C1F3A9EEFE2AE3F918F03BFA21B5070B", relayTimMayTribute); @@ -337,7 +337,7 @@ public class ResourceServletTest { String[] parameterParts = parameter.split("="); if (!parameterLists.containsKey(parameterParts[0])) { parameterLists.put(parameterParts[0], - new ArrayList<String>()); + new ArrayList<>()); } parameterLists.get(parameterParts[0]).add(parameterParts[1]); } diff --git a/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java b/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java index c311b2b..c985090 100644 --- a/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java +++ b/src/test/java/org/torproject/onionoo/updater/DummyDescriptorSource.java @@ -32,7 +32,7 @@ public class DummyDescriptorSource extends DescriptorSource { private Set<Descriptor> getDescriptorsByType( DescriptorType descriptorType) { if (!this.descriptors.containsKey(descriptorType)) { - this.descriptors.put(descriptorType, new HashSet<Descriptor>()); + this.descriptors.put(descriptorType, new HashSet<>()); } return this.descriptors.get(descriptorType); } @@ -45,7 +45,7 @@ public class DummyDescriptorSource extends DescriptorSource { DescriptorType descriptorType) { if (!this.descriptorListeners.containsKey(descriptorType)) { this.descriptorListeners.put(descriptorType, - new HashSet<DescriptorListener>()); + new HashSet<>()); } this.descriptorListeners.get(descriptorType).add(listener); } diff --git a/src/test/java/org/torproject/onionoo/updater/LookupServiceTest.java b/src/test/java/org/torproject/onionoo/updater/LookupServiceTest.java index 6311316..743fe1d 100644 --- a/src/test/java/org/torproject/onionoo/updater/LookupServiceTest.java +++ b/src/test/java/org/torproject/onionoo/updater/LookupServiceTest.java @@ -234,19 +234,19 @@ public class LookupServiceTest { @Test() public void testLookupNoBlocksLines() { - this.assertLookupResult(new ArrayList<String>(), null, null, + this.assertLookupResult(new ArrayList<>(), null, null, "8.8.8.8", null, null, null, null, null, null, null, null); } @Test() public void testLookupNoLocationLines() { - this.assertLookupResult(null, new ArrayList<String>(), null, + this.assertLookupResult(null, new ArrayList<>(), null, "8.8.8.8", null, null, null, null, null, null, null, null); } @Test() public void testLookupNoGeoipAsNum2Lines() { - this.assertLookupResult(null, null, new ArrayList<String>(), + this.assertLookupResult(null, null, new ArrayList<>(), "8.8.8.8", null, null, null, null, null, null, null, null); }

1 0

[onionoo/master] Use Java 5 foreach loop.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit c9aadac0907bee8cc1a0657842506735b801622f Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Mon Aug 20 14:57:35 2018 +0200 Use Java 5 foreach loop. --- src/main/java/org/torproject/onionoo/server/IntegerDistribution.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/server/IntegerDistribution.java b/src/main/java/org/torproject/onionoo/server/IntegerDistribution.java index f462765..19862a0 100644 --- a/src/main/java/org/torproject/onionoo/server/IntegerDistribution.java +++ b/src/main/java/org/torproject/onionoo/server/IntegerDistribution.java @@ -17,8 +17,8 @@ class IntegerDistribution { public String toString() { StringBuilder sb = new StringBuilder(); int totalValues = 0; - for (int i = 0; i < logValues.length; i++) { - totalValues += logValues[i]; + for (int logValue : logValues) { + totalValues += logValue; } int[] permilles = new int[] { 500, 900, 990, 999 }; if (totalValues > 0) {

1 0

[onionoo/master] Use more appropriate assert methods in tests.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit d09bfefe943974b966eb487de0e062cac540ba56 Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Mon Aug 20 14:41:26 2018 +0200 Use more appropriate assert methods in tests. --- .../torproject/onionoo/docs/UptimeStatusTest.java | 21 +++++++-------------- .../onionoo/updater/UptimeStatusUpdaterTest.java | 10 ++++++---- 2 files changed, 13 insertions(+), 18 deletions(-) diff --git a/src/test/java/org/torproject/onionoo/docs/UptimeStatusTest.java b/src/test/java/org/torproject/onionoo/docs/UptimeStatusTest.java index aff5ce5..1b567ac 100644 --- a/src/test/java/org/torproject/onionoo/docs/UptimeStatusTest.java +++ b/src/test/java/org/torproject/onionoo/docs/UptimeStatusTest.java @@ -34,8 +34,7 @@ public class UptimeStatusTest { uptimeStatus.getRelayHistory().size()); UptimeHistory newUptimeHistory = uptimeStatus.getRelayHistory().first(); - assertEquals("History not for relay.", true, - newUptimeHistory.isRelay()); + assertTrue("History not for relay.", newUptimeHistory.isRelay()); assertEquals("History start millis not same as provided.", DateTimeHelper.parse("2013-12-20 00:00:00"), newUptimeHistory.getStartMillis()); @@ -55,8 +54,7 @@ public class UptimeStatusTest { uptimeStatus.getRelayHistory().size()); UptimeHistory newUptimeHistory = uptimeStatus.getRelayHistory().first(); - assertEquals("History not for relay.", true, - newUptimeHistory.isRelay()); + assertTrue("History not for relay.", newUptimeHistory.isRelay()); assertEquals("History start millis not same as provided.", DateTimeHelper.parse("2013-12-20 00:00:00"), newUptimeHistory.getStartMillis()); @@ -84,8 +82,7 @@ public class UptimeStatusTest { uptimeStatus.getRelayHistory().size()); UptimeHistory newUptimeHistory = uptimeStatus.getRelayHistory().first(); - assertEquals("History not for relay.", true, - newUptimeHistory.isRelay()); + assertTrue("History not for relay.", newUptimeHistory.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2013-07-22 17:00:00"), newUptimeHistory.getStartMillis()); @@ -128,8 +125,7 @@ public class UptimeStatusTest { 3, uptimeStatus.getRelayHistory().size()); UptimeHistory newUptimeHistory = uptimeStatus.getRelayHistory().first(); - assertEquals("History not for relay.", true, - newUptimeHistory.isRelay()); + assertTrue("History not for relay.", newUptimeHistory.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2013-07-22 16:00:00"), newUptimeHistory.getStartMillis()); @@ -150,8 +146,7 @@ public class UptimeStatusTest { 2, uptimeStatus.getRelayHistory().size()); UptimeHistory newUptimeHistory = uptimeStatus.getRelayHistory().first(); - assertEquals("History not for relay.", true, - newUptimeHistory.isRelay()); + assertTrue("History not for relay.", newUptimeHistory.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2013-07-22 17:00:00"), newUptimeHistory.getStartMillis()); @@ -176,8 +171,7 @@ public class UptimeStatusTest { 1, uptimeStatus.getRelayHistory().size()); UptimeHistory newUptimeHistory = uptimeStatus.getRelayHistory().first(); - assertEquals("History not for relay.", true, - newUptimeHistory.isRelay()); + assertTrue("History not for relay.", newUptimeHistory.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2013-07-22 16:00:00"), newUptimeHistory.getStartMillis()); @@ -198,8 +192,7 @@ public class UptimeStatusTest { + "entry.", 1, uptimeStatus.getBridgeHistory().size()); UptimeHistory newUptimeHistory = uptimeStatus.getBridgeHistory().last(); - assertEquals("History not for bridge.", false, - newUptimeHistory.isRelay()); + assertFalse("History not for bridge.", newUptimeHistory.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2013-07-22 16:00:00"), newUptimeHistory.getStartMillis()); diff --git a/src/test/java/org/torproject/onionoo/updater/UptimeStatusUpdaterTest.java b/src/test/java/org/torproject/onionoo/updater/UptimeStatusUpdaterTest.java index 4797356..df6dd66 100644 --- a/src/test/java/org/torproject/onionoo/updater/UptimeStatusUpdaterTest.java +++ b/src/test/java/org/torproject/onionoo/updater/UptimeStatusUpdaterTest.java @@ -4,6 +4,8 @@ package org.torproject.onionoo.updater; import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertTrue; import org.torproject.onionoo.docs.DateTimeHelper; import org.torproject.onionoo.docs.DocumentStoreFactory; @@ -75,7 +77,7 @@ public class UptimeStatusUpdaterTest { UptimeHistory history = status.getRelayHistory().first(); assertEquals("History must contain one entry.", 1, status.getRelayHistory().size()); - assertEquals("History not for relay.", true, history.isRelay()); + assertTrue("History not for relay.", history.isRelay()); assertEquals("History start millis not as expected.", VALID_AFTER_SAMPLE, history.getStartMillis()); assertEquals("History uptime hours must be 1.", 1, @@ -111,7 +113,7 @@ public class UptimeStatusUpdaterTest { assertEquals("Relay history must contain one entry.", 1, status.getRelayHistory().size()); UptimeHistory history = status.getRelayHistory().first(); - assertEquals("History not for relay.", true, history.isRelay()); + assertTrue("History not for relay.", history.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2013-07-22 17:00:00"), history.getStartMillis()); @@ -151,7 +153,7 @@ public class UptimeStatusUpdaterTest { UptimeHistory history = status.getBridgeHistory().first(); assertEquals("Bridge history must contain one entry.", 1, status.getBridgeHistory().size()); - assertEquals("History not for bridge.", false, history.isRelay()); + assertFalse("History not for bridge.", history.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2014-03-21 20:00:00"), history.getStartMillis()); @@ -174,7 +176,7 @@ public class UptimeStatusUpdaterTest { assertEquals("Bridge history must contain one entry.", 1, status.getBridgeHistory().size()); UptimeHistory history = status.getBridgeHistory().last(); - assertEquals("History not for bridge.", false, history.isRelay()); + assertFalse("History not for bridge.", history.isRelay()); assertEquals("History start millis not as expected.", DateTimeHelper.parse("2013-07-22 17:00:00"), history.getStartMillis());

1 0

[onionoo/master] Collapse identical catch blocks.
by karsten＠torproject.org 27 Aug '18

27 Aug '18

commit ad1ec28102596c5ac8fb19d4ea70963d00904fc5 Author: Karsten Loesing <karsten.loesing(a)gmx.net> Date: Mon Aug 20 15:35:47 2018 +0200 Collapse identical catch blocks. --- src/main/java/org/torproject/onionoo/docs/DocumentStore.java | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/src/main/java/org/torproject/onionoo/docs/DocumentStore.java b/src/main/java/org/torproject/onionoo/docs/DocumentStore.java index c9dc13b..6efbb52 100644 --- a/src/main/java/org/torproject/onionoo/docs/DocumentStore.java +++ b/src/main/java/org/torproject/onionoo/docs/DocumentStore.java @@ -529,10 +529,7 @@ public class DocumentStore { try { result = documentType.newInstance(); result.setFromDocumentString(documentString); - } catch (InstantiationException e) { - /* Handle below. */ - log.error(e.getMessage(), e); - } catch (IllegalAccessException e) { + } catch (InstantiationException | IllegalAccessException e) { /* Handle below. */ log.error(e.getMessage(), e); } @@ -566,10 +563,7 @@ public class DocumentStore { try { result = documentType.newInstance(); result.setDocumentString(documentString); - } catch (InstantiationException e) { - /* Handle below. */ - log.error(e.getMessage(), e); - } catch (IllegalAccessException e) { + } catch (InstantiationException | IllegalAccessException e) { /* Handle below. */ log.error(e.getMessage(), e); }

1 0

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

tor-commits August 2018