Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merge 4685 with 4680 #4686

Closed
wants to merge 33 commits into from
Closed
Changes from 1 commit
Commits
Show all changes
33 commits
Select commit Hold shift + click to select a range
607f447
Extract method for filling seed nodes from property file
chimp1984 Oct 14, 2020
ca91ccf
Make config nullable and extract methods where config is used and app…
chimp1984 Oct 14, 2020
f86ca72
Add inventory module
chimp1984 Oct 14, 2020
283fb70
Move inventory package to core as we want to include other domain dat…
chimp1984 Oct 15, 2020
905a74d
Add signature to request to limit the feature to requests from truste…
chimp1984 Oct 15, 2020
0ec34d3
Add readableFileSize
chimp1984 Oct 15, 2020
6f1cdd7
Add readSeedNodePropertyFile method
chimp1984 Oct 15, 2020
0646e55
Add sparkjava dependency
chimp1984 Oct 15, 2020
81bf469
Remove signature from GetInventoryRequest (as monitor is public it do…
chimp1984 Oct 15, 2020
053f624
Add shadow plugin
chimp1984 Oct 16, 2020
6f6ea13
Make RequestInfo public
chimp1984 Oct 18, 2020
66647ab
Add InventoryItem enum
chimp1984 Oct 18, 2020
52028fd
Add nodes from mike
chimp1984 Oct 18, 2020
93d3b59
Shut down connection after response received
chimp1984 Oct 19, 2020
fb474a1
Add network node shutdown
chimp1984 Oct 19, 2020
1e31363
Add more warn/alert checks
chimp1984 Oct 21, 2020
19eb130
Add triggers for maxConnections and numConnections
chimp1984 Oct 21, 2020
a0fd819
Fix error handling
chimp1984 Oct 21, 2020
b8e60fa
Add peakNumConnections
chimp1984 Oct 21, 2020
5fcab37
Add numAllConnectionsLostEvents
chimp1984 Oct 21, 2020
1a6547e
Fix connection config for monitor
freimair Feb 20, 2020
d7dd359
Code cleanup
freimair Feb 20, 2020
e97c4c8
Added offer volume feed metric
freimair Feb 20, 2020
d568f06
Added offer-volume-distribution
freimair Feb 21, 2020
9621895
Added offers-per-trader metric
freimair Feb 21, 2020
9574f18
Added volume-per-trader metric
freimair Feb 21, 2020
af86093
Cleanup and refactoring
freimair Feb 21, 2020
af41fdd
Reorg imports, reformat code according to your style guide
chimp1984 Oct 22, 2020
ba800bc
Remove change in Connection (issue with config when not using guice is
chimp1984 Oct 22, 2020
aad7d41
Adopt to new Persistencemanager
chimp1984 Oct 22, 2020
f8aa1af
Make constructor public
chimp1984 Oct 22, 2020
5841491
Add ifPresent check at optional
chimp1984 Oct 22, 2020
b508241
Use networkPostfix for file name
chimp1984 Oct 22, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
Expand Up @@ -34,6 +34,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
Expand Down Expand Up @@ -223,7 +224,9 @@ protected void report() {

// do version statistics
report.clear();
versionBucketsPerHost.values().stream().findAny().get().values().forEach((version, numberOfOccurrences) -> report.put(version, String.valueOf(numberOfOccurrences.value())));
Optional<Statistics<Aggregator>> optionalStatistics = versionBucketsPerHost.values().stream().findAny();
optionalStatistics.ifPresent(aggregatorStatistics -> aggregatorStatistics.values()
.forEach((version, numberOfOccurrences) -> report.put(version, String.valueOf(numberOfOccurrences.value()))));
reporter.report(report, "versions");
}

Expand Down