org.bitcoinj.net.discovery

Class MultiplexingDiscovery

java.lang.Object

org.bitcoinj.net.discovery.MultiplexingDiscovery

All Implemented Interfaces:

PeerDiscovery

Direct Known Subclasses:

DnsDiscovery

public class MultiplexingDiscovery
extends java.lang.Object
implements PeerDiscovery

MultiplexingDiscovery queries multiple PeerDiscovery objects, shuffles their responses and then returns the results, thus selecting randomly between them and reducing the influence of any particular seed. Any that don't respond within the timeout are ignored. Backends are queried in parallel. Backends may block.

Field Summary

Fields

Modifier and Type	Field and Description
protected NetworkParameters	netParams
protected java.util.List<PeerDiscovery>	seeds

Constructor Summary

Constructors

Constructor and Description
MultiplexingDiscovery(NetworkParameters params, java.util.List<PeerDiscovery> seeds) Will query the given seeds in parallel before producing a merged response.

Method Summary

Modifier and Type	Method and Description
protected java.util.concurrent.ExecutorService	createExecutor()
static MultiplexingDiscovery	forServices(NetworkParameters params, long services) Builds a suitable set of peer discoveries.
java.net.InetSocketAddress[]	getPeers(long services, long timeoutValue, java.util.concurrent.TimeUnit timeoutUnit) Returns an array of addresses.
void	shutdown() Stops any discovery in progress when we want to shut down quickly.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

seeds

protected final java.util.List<PeerDiscovery> seeds

netParams

protected final NetworkParameters netParams

Constructor Detail

MultiplexingDiscovery

public MultiplexingDiscovery(NetworkParameters params,
                             java.util.List<PeerDiscovery> seeds)

Will query the given seeds in parallel before producing a merged response.

Method Detail

forServices

public static MultiplexingDiscovery forServices(NetworkParameters params,
                                                long services)

Builds a suitable set of peer discoveries. Will query them in parallel before producing a merged response. If specific services are required, DNS is not used as the protocol can't handle it.

Parameters:

params - Network to use.

services - Required services as a bitmask, e.g. VersionMessage.NODE_NETWORK.

getPeers

public java.net.InetSocketAddress[] getPeers(long services,
                                             long timeoutValue,
                                             java.util.concurrent.TimeUnit timeoutUnit)
                                      throws PeerDiscoveryException

Description copied from interface: PeerDiscovery

Returns an array of addresses. This method may block.

Specified by:

getPeers in interface PeerDiscovery

Parameters:

services - Required services as a bitmask, e.g. VersionMessage.NODE_NETWORK.

Throws:

PeerDiscoveryException

createExecutor

protected java.util.concurrent.ExecutorService createExecutor()

shutdown

public void shutdown()

Description copied from interface: PeerDiscovery

Stops any discovery in progress when we want to shut down quickly.

Specified by:

shutdown in interface PeerDiscovery