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

Change PeerGroup.addPeerFilterProvider to return a ListenableFuture<BloomFilter>

Browse Source 
Currently 'addPeerFilterProvider()` returns `void`.  After this patch it
returns the `ListenableFuture<BloomFilter>` that is returned by its
invocation of `recalculateFastCatchupAndFilter()`.
This commit is contained in:
Adam Mackler 2015-02-04 06:06:27 -05:00 committed by Mike Hearn
parent 212aa41143
commit e8138c21b0
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -961,8 +961,14 @@ public class PeerGroup implements TransactionBroadcaster {
*
* <p>Note that this should be done before chain download commences because if you add a listener with keys earlier
* than the current chain head, the relevant parts of the chain won't be redownloaded for you.</p>
*
* <p>This method invokes {@link PeerGroup#recalculateFastCatchupAndFilter(FilterRecalculateMode)}.
* The return value of this method is the <code>ListenableFuture</code> returned by that invocation.</p>
*
* @return a future that completes once each <code>Peer</code> in this group has had its
* <code>BloomFilter</code> (re)set.
*/
public void addPeerFilterProvider(PeerFilterProvider provider) {
public ListenableFuture<BloomFilter> addPeerFilterProvider(PeerFilterProvider provider) {
lock.lock();
try {
checkNotNull(provider);
@ -981,8 +987,9 @@ public class PeerGroup implements TransactionBroadcaster {
// if a key is added. Of course, by then we may have downloaded the chain already. Ideally adding keys would
// automatically rewind the block chain and redownload the blocks to find transactions relevant to those keys,
// all transparently and in the background. But we are a long way from that yet.
recalculateFastCatchupAndFilter(FilterRecalculateMode.SEND_IF_CHANGED);
ListenableFuture<BloomFilter> future = recalculateFastCatchupAndFilter(FilterRecalculateMode.SEND_IF_CHANGED);
updateVersionMessageRelayTxesBeforeFilter(getVersionMessage());
return future;
} finally {
lock.unlock();
}