Skip to content

Commit

Permalink
TestFeeLevel: Print the number of peers already connected.
Browse files Browse the repository at this point in the history
  • Loading branch information
schildbach committed Oct 13, 2015
1 parent 91a49e6 commit bb9c93c
Showing 1 changed file with 19 additions and 0 deletions.
19 changes: 19 additions & 0 deletions tools/src/main/java/org/bitcoinj/tools/TestFeeLevel.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,11 +15,13 @@
package org.bitcoinj.tools;

import org.bitcoinj.core.*;
import org.bitcoinj.core.listeners.PeerConnectionEventListener;
import org.bitcoinj.kits.WalletAppKit;
import org.bitcoinj.params.MainNetParams;
import org.bitcoinj.utils.BriefLogFormatter;

import java.io.File;
import java.util.Set;

/**
* A program that sends a transaction with the specified fee and measures how long it takes to confirm.
Expand Down Expand Up @@ -77,6 +79,23 @@ private static void go(Coin feeToTest, int numOutputs) throws InterruptedExcepti
kit.wallet().completeTx(request);
System.out.println("Size in bytes is " + request.tx.bitcoinSerialize().length);
System.out.println("TX is " + request.tx);
System.out.println("Waiting for " + kit.peerGroup().getMaxConnections() + " connected peers");
kit.peerGroup().addConnectionEventListener(new PeerConnectionEventListener() {

@Override
public void onPeersDiscovered(Set<PeerAddress> peerAddresses) {
}

@Override
public void onPeerDisconnected(Peer peer, int peerCount) {
System.out.println(peerCount + " peers connected");
}

@Override
public void onPeerConnected(Peer peer, int peerCount) {
System.out.println(peerCount + " peers connected");
}
});
kit.peerGroup().broadcastTransaction(request.tx).future().get();
System.out.println("Send complete, waiting for confirmation");
request.tx.getConfidence().getDepthFuture(1).get();
Expand Down

0 comments on commit bb9c93c

Please sign in to comment.