Qortal/altcoinj
3
0
Fork 0
mirror of https://github.com/Qortal/altcoinj.git synced 2025-02-12 10:15:52 +00:00
Code Issues Projects Releases Wiki Activity

PeerGroup: Require Bloom-filtering capable peers by default. Resolves issue 421.

Browse Source
This commit is contained in:
Mike Hearn 2013-07-10 15:52:09 +02:00
parent 34d804ecca
commit 2c44a4fad7
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
core/src/main/java/com/google/bitcoin/core/PeerGroup.java
View File

@ -99,6 +99,8 @@ public class PeerGroup extends AbstractIdleService implements TransactionBroadca
// How many connections we want to have open at the current time. If we lose connections, we'll try opening more // How many connections we want to have open at the current time. If we lose connections, we'll try opening more
// until we reach this count. // until we reach this count.
@GuardedBy("lock") private int maxConnections; @GuardedBy("lock") private int maxConnections;
// Minimum protocol version we will allow ourselves to connect to: require Bloom filtering.
private volatile int vMinRequiredProtocolVersion = FilteredBlock.MIN_PROTOCOL_VERSION;
// Runs a background thread that we use for scheduling pings to our peers, so we can measure their performance // Runs a background thread that we use for scheduling pings to our peers, so we can measure their performance
// and network latency. We ping peers every pingIntervalMsec milliseconds. // and network latency. We ping peers every pingIntervalMsec milliseconds.
@ -263,6 +265,7 @@ public class PeerGroup extends AbstractIdleService implements TransactionBroadca
Peer peer = new Peer(params, chain, ver, memoryPool); Peer peer = new Peer(params, chain, ver, memoryPool);
peer.addLifecycleListener(startupListener); peer.addLifecycleListener(startupListener);
peer.setMinProtocolVersion(vMinRequiredProtocolVersion);
pendingPeers.add(peer); pendingPeers.add(peer);
TCPNetworkConnection codec = new TCPNetworkConnection(params, peer.getVersionMessage()); TCPNetworkConnection codec = new TCPNetworkConnection(params, peer.getVersionMessage());
p.addLast("codec", codec.getHandler()); p.addLast("codec", codec.getHandler());
@ -1285,6 +1288,19 @@ public class PeerGroup extends AbstractIdleService implements TransactionBroadca
} }
} }
/**
* If a peer is connected to that claims to speak a protocol version lower than the given version, it will
* be disconnected and another one will be tried instead.
*/
public void setMinRequiredProtocolVersion(int minRequiredProtocolVersion) {
this.vMinRequiredProtocolVersion = minRequiredProtocolVersion;
}
/** The minimum protocol version required: defaults to the version required for Bloom filtering. */
public int getMinRequiredProtocolVersion() {
return vMinRequiredProtocolVersion;
}
/** /**
* Returns our peers most commonly reported chain height. If multiple heights are tied, the highest is returned. * Returns our peers most commonly reported chain height. If multiple heights are tied, the highest is returned.
* If no peers are connected, returns zero. * If no peers are connected, returns zero.