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

More Peer logging improvements.

Browse Source
This commit is contained in:
Mike Hearn 2013-01-29 16:16:42 +01:00
parent 4bdb0fd5ce
commit 112fe818d5
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
core/src/main/java/com/google/bitcoin/core/Peer.java
View File

@ -443,10 +443,11 @@ public class Peer {
Futures.addCallback(downloadDependencies(fTx), new FutureCallback<List<Transaction>>() {
public void onSuccess(List<Transaction> dependencies) {
try {
log.info("Dependency download complete!");
log.info("{}: Dependency download complete!", address);
wallet.receivePending(fTx, dependencies);
} catch (VerificationException e) {
log.error("Wallet failed to process pending transaction {}", fTx.getHashAsString());
log.error("{}: Wallet failed to process pending transaction {}",
address, fTx.getHashAsString());
log.error("Error was: ", e);
// Not much more we can do at this point.
}
@ -467,11 +468,10 @@ public class Peer {
}
// Tell all listeners about this tx so they can decide whether to keep it or not. If no listener keeps a
// reference around then the memory pool will forget about it after a while too because it uses weak references.
final Transaction ftx = tx;
EventListenerInvoker.invoke(eventListeners, new EventListenerInvoker<PeerEventListener>() {
@Override
public void invoke(PeerEventListener listener) {
listener.onTransaction(Peer.this, ftx);
listener.onTransaction(Peer.this, fTx);
}
});
}
@ -495,7 +495,7 @@ public class Peer {
public ListenableFuture<List<Transaction>> downloadDependencies(Transaction tx) {
TransactionConfidence.ConfidenceType txConfidence = tx.getConfidence().getConfidenceType();
Preconditions.checkArgument(txConfidence != TransactionConfidence.ConfidenceType.BUILDING);
log.info("Downloading dependencies of {}", tx.getHashAsString());
log.info("{}: Downloading dependencies of {}", address, tx.getHashAsString());
final LinkedList<Transaction> results = new LinkedList<Transaction>();
// future will be invoked when the entire dependency tree has been walked and the results compiled.
final ListenableFuture future = downloadDependenciesInternal(tx, new Object(), results);
@ -568,7 +568,7 @@ public class Peer {
List<ListenableFuture<Object>> childFutures = Lists.newLinkedList();
for (Transaction tx : transactions) {
if (tx == null) continue;
log.info("Downloaded dependency of {}: {}", rootTxHash, tx.getHashAsString());
log.info("{}: Downloaded dependency of {}: {}", new Object[]{address, rootTxHash, tx.getHashAsString()});
results.add(tx);
// Now recurse into the dependencies of this transaction too.
childFutures.add(downloadDependenciesInternal(tx, marker, results));