mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2024-11-20 10:12:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

Peer: make GetDataRequest a subclass of CompletableFuture to simplify

Browse Source
This commit is contained in:
Andreas Schildbach 2022-03-31 23:37:09 +02:00
parent e86a77c557
commit 58e725b969
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
core/src/main/java/org/bitcoinj/core/Peer.java
View File

@ -134,9 +134,8 @@ public class Peer extends PeerSocketHandler {
private volatile int vMinProtocolVersion;
// When an API user explicitly requests a block or transaction from a peer, the InventoryItem is put here
// whilst waiting for the response. Is not used for downloads Peer generates itself.
private static class GetDataRequest {
private static class GetDataRequest extends CompletableFuture {
final Sha256Hash hash;
final CompletableFuture future = new CompletableFuture();
public GetDataRequest(Sha256Hash hash) {
this.hash = hash;
}
@ -570,7 +569,7 @@ public class Peer extends PeerSocketHandler {
for (InventoryItem item : m.getItems()) {
if (item.hash.equals(req.hash)) {
log.info("{}: Bottomed out dep tree at {}", this, req.hash);
req.future.cancel(true);
req.cancel(true);
getDataFutures.remove(req);
break;
}
@ -817,7 +816,7 @@ public class Peer extends PeerSocketHandler {
log.info("{}: Requesting {} transactions for depth {} dep resolution", getAddress(), txIdsToRequest.size(), depth + 1);
for (Sha256Hash hash : txIdsToRequest) {
GetDataRequest req = new GetDataRequest(hash);
futures.add(req.future);
futures.add(req);
getDataFutures.add(req);
}
CompletableFuture<List<Transaction>> successful = FutureUtils.successfulAsList(futures);
@ -1072,7 +1071,7 @@ public class Peer extends PeerSocketHandler {
Sha256Hash hash = m.getHash();
for (GetDataRequest req : getDataFutures) {
if (hash.equals(req.hash)) {
req.future.complete(m);
req.complete(m);
getDataFutures.remove(req);
found = true;
// Keep going in case there are more.
@ -1262,7 +1261,7 @@ public class Peer extends PeerSocketHandler {
GetDataRequest req = new GetDataRequest(getdata.getItems().get(0).hash);
getDataFutures.add(req);
sendMessage(getdata);
return req.future;
return req;
}
/** Sends a getaddr request to the peer and returns a future that completes with the answer once the peer has replied. */