mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-02-22 06:21:47 +01:00
Code Issues Projects Releases Packages Wiki Activity

Peer: WIP/Question: replace ReentrantLock

Browse source 
Replace `pingIntervalsLock.lock()` with `synchronizedLock(pingIntervals)`.

I'm not sure this is equivalent or if we are losing any functionality by doing this.
Note that before the Duration[] was nullable, so there had to be something to lock on.
Now that the Deque is final, we can use it.
This commit is contained in:
Sean Gilligan 2023-03-19 17:08:55 -07:00
parent 466444ebf7
commit db28774996
1 changed files with 4 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
core/src/main/java/org/bitcoinj/core/Peer.java
View file

@ -169,10 +169,9 @@ public class Peer extends PeerSocketHandler {
@GuardedBy("getAddrFutures") private final LinkedList<CompletableFuture<AddressMessage>> getAddrFutures;
// Outstanding pings against this peer and how long the last one took to complete.
private final ReentrantLock pingIntervalsLock = new ReentrantLock();
@GuardedBy("pingIntervalsLock") private final Deque<Duration> pingIntervals = new ArrayDeque<>(PING_MOVING_AVERAGE_WINDOW);
private volatile Duration lastPing = null; // should only be written while holding pingIntervalsLock
private volatile Duration averagePing = null; // should only be written while holding pingIntervalsLock
private final Deque<Duration> pingIntervals = new ArrayDeque<>(PING_MOVING_AVERAGE_WINDOW);
private volatile Duration lastPing = null; // should only be written while holding lock on pingIntervals
private volatile Duration averagePing = null; // should only be written while holding lock on pingIntervals
private final CopyOnWriteArrayList<PendingPing> pendingPings;
// Disconnect from a peer that is not responding to Pings
@ -1513,8 +1512,7 @@ public class Peer extends PeerSocketHandler {
/** Adds a ping time sample to the averaging window. */
private void addPingInterval(Duration sample) {
pingIntervalsLock.lock();
try {
synchronized (pingIntervals) {
if (pingIntervals.size() >= PING_MOVING_AVERAGE_WINDOW) {
// Remove oldest sample from front of queue
pingIntervals.remove();
@ -1527,8 +1525,6 @@ public class Peer extends PeerSocketHandler {
.reduce(Duration::plus)
.map(d -> d.dividedBy(pingIntervals.size()))
.orElse(null);
} finally {
pingIntervalsLock.unlock();
}
}