mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-03-09 16:04:54 +01:00
Code Issues Projects Releases Packages Wiki Activity

WatchMempool: migrate class to java.time API

Browse source
This commit is contained in:
Andreas Schildbach 2023-03-18 20:28:40 +01:00
parent 06e031a51e
commit 2061555afa
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
tools/src/main/java/org/bitcoinj/tools/WatchMempool.java
View file

@ -17,11 +17,14 @@
package org.bitcoinj.tools; package org.bitcoinj.tools;
import java.time.Duration;
import java.time.Instant;
import java.util.Collections; import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import org.bitcoinj.base.internal.TimeUtils;
import org.bitcoinj.core.listeners.*; import org.bitcoinj.core.listeners.*;
import org.bitcoinj.core.NetworkParameters; import org.bitcoinj.core.NetworkParameters;
import org.bitcoinj.core.Peer; import org.bitcoinj.core.Peer;
@ -41,8 +44,8 @@ public class WatchMempool {
private static final List<Transaction> NO_DEPS = Collections.emptyList(); private static final List<Transaction> NO_DEPS = Collections.emptyList();
private static final Map<String, Integer> counters = new HashMap<>(); private static final Map<String, Integer> counters = new HashMap<>();
private static final String TOTAL_KEY = "TOTAL"; private static final String TOTAL_KEY = "TOTAL";
private static final long START_MS = System.currentTimeMillis(); private static final Instant START = TimeUtils.currentTime();
private static final long STATISTICS_FREQUENCY_MS = 1000 * 5; private static final Duration STATISTICS_FREQUENCY = Duration.ofSeconds(5);
public static void main(String[] args) throws InterruptedException { public static void main(String[] args) throws InterruptedException {
BriefLogFormatter.init(); BriefLogFormatter.init();
@ -60,7 +63,7 @@ public class WatchMempool {
peerGroup.start(); peerGroup.start();
while (true) { while (true) {
Thread.sleep(STATISTICS_FREQUENCY_MS); Thread.sleep(STATISTICS_FREQUENCY.toMillis());
printCounters(); printCounters();
} }
} }
@ -74,7 +77,8 @@ public class WatchMempool {
} }
private static synchronized void printCounters() { private static synchronized void printCounters() {
System.out.printf("Runtime: %d minutes\n", (System.currentTimeMillis() - START_MS) / 1000 / 60); Duration elapsed = TimeUtils.elapsedTime(START);
System.out.printf("Runtime: %d:%02d minutes\n", elapsed.toMinutes(), elapsed.toSecondsPart());
Integer total = counters.get(TOTAL_KEY); Integer total = counters.get(TOTAL_KEY);
if (total == null) if (total == null)
return; return;