mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-01-19 13:44:11 +01:00
Code Issues Packages Projects Releases Wiki Activity

Peer: measure ping-pong time using java.time API

Browse Source
This commit is contained in:
Andreas Schildbach 2023-03-01 23:39:43 +01:00
parent e597a68106
commit a40f206e45
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core/src/main/java/org/bitcoinj/core/Peer.java
View File

@ -47,6 +47,8 @@ import org.slf4j.LoggerFactory;
import javax.annotation.Nullable;
import java.net.SocketAddress;
import java.time.Duration;
import java.time.Instant;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
@ -1467,21 +1469,21 @@ public class Peer extends PeerSocketHandler {
// The random nonce that lets us tell apart overlapping pings/pongs.
public final long nonce;
// Measurement of the time elapsed.
public final long startTimeMsec;
public final Instant startTime;
public PendingPing(long nonce) {
this.future = new CompletableFuture<>();
this.nonce = nonce;
this.startTimeMsec = TimeUtils.currentTimeMillis();
this.startTime = TimeUtils.currentTime();
}
public void complete() {
if (!future.isDone()) {
long elapsed = TimeUtils.currentTimeMillis() - startTimeMsec;
Peer.this.addPingTimeData(elapsed);
Duration elapsed = TimeUtils.elapsedTime(startTime);
Peer.this.addPingTimeData(elapsed.toMillis());
if (log.isDebugEnabled())
log.debug("{}: ping time is {} ms", Peer.this.toString(), elapsed);
future.complete(elapsed);
log.debug("{}: ping time is {} ms", Peer.this.toString(), elapsed.toMillis());
future.complete(elapsed.toMillis());
}
}
}