mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-03-10 17:26:28 +01:00
Code Issues Projects Releases Packages Wiki Activity

AddressEventListener: new event produced by Peer if an addr or addrv2 message is received

Browse source
This commit is contained in:
Andreas Schildbach 2022-11-21 15:39:24 +01:00
parent 15cc61d066
commit 74d54de1f6
2 changed files with 56 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
core/src/main/java/org/bitcoinj/core/Peer.java
View file

@ -23,6 +23,7 @@ import com.google.common.base.Throwables;
import net.jcip.annotations.GuardedBy;
import org.bitcoinj.base.Coin;
import org.bitcoinj.base.Sha256Hash;
import org.bitcoinj.core.listeners.AddressEventListener;
import org.bitcoinj.core.listeners.BlocksDownloadedEventListener;
import org.bitcoinj.core.listeners.ChainDownloadStartedEventListener;
import org.bitcoinj.core.listeners.GetDataEventListener;
@ -101,6 +102,8 @@ public class Peer extends PeerSocketHandler {
= new CopyOnWriteArrayList<>();
private final CopyOnWriteArrayList<ListenerRegistration<OnTransactionBroadcastListener>> onTransactionEventListeners
= new CopyOnWriteArrayList<>();
private final CopyOnWriteArrayList<ListenerRegistration<AddressEventListener>> addressEventListeners
= new CopyOnWriteArrayList<>();
// Whether to try and download blocks and transactions from this peer. Set to false by PeerGroup if not the
// primary peer. This is to avoid redundant work and concurrency problems with downloading the same chain
// in parallel.
@ -331,6 +334,16 @@ public class Peer extends PeerSocketHandler {
preMessageReceivedEventListeners.add(new ListenerRegistration<>(listener, executor));
}
/** Registers a listener that is called when addr or addrv2 messages are received. */
public void addAddressEventListener(AddressEventListener listener) {
addAddressEventListener(Threading.USER_THREAD, listener);
}
/** Registers a listener that is called when addr or addrv2 messages are received. */
public void addAddressEventListener(Executor executor, AddressEventListener listener) {
addressEventListeners.add(new ListenerRegistration<>(listener, executor));
}
public boolean removeBlocksDownloadedEventListener(BlocksDownloadedEventListener listener) {
return ListenerRegistration.removeFromList(listener, blocksDownloadedEventListeners);
}
@ -359,6 +372,10 @@ public class Peer extends PeerSocketHandler {
return ListenerRegistration.removeFromList(listener, preMessageReceivedEventListeners);
}
public boolean removeAddressEventListener(AddressEventListener listener) {
return ListenerRegistration.removeFromList(listener, addressEventListeners);
}
@Override
public String toString() {
final MoreObjects.ToStringHelper helper = MoreObjects.toStringHelper(this).omitNullValues();
@ -485,14 +502,17 @@ public class Peer extends PeerSocketHandler {
}
}
private void processAddressMessage(AddressMessage m) {
private void processAddressMessage(AddressMessage message) {
for (final ListenerRegistration<AddressEventListener> registration : addressEventListeners) {
registration.executor.execute(() -> registration.listener.onAddr(Peer.this, message));
}
CompletableFuture<AddressMessage> future;
synchronized (getAddrFutures) {
future = getAddrFutures.poll();
if (future == null) // Not an addr message we are waiting for.
return;
}
future.complete(m);
future.complete(message);
}
private void processVersionMessage(VersionMessage peerVersionMessage) throws ProtocolException {

34
core/src/main/java/org/bitcoinj/core/listeners/AddressEventListener.java Normal file
View file

@ -0,0 +1,34 @@
/*
* Copyright by the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.bitcoinj.core.listeners;
import org.bitcoinj.core.AddressMessage;
import org.bitcoinj.core.Peer;
/**
* <p>Implementors can listen to addresses being received from remote peers.</p>
*/
public interface AddressEventListener {
/**
* <p>Called when a peer receives an addr or addrv2 message, usually in response to a getaddr message.</p>
*
* @param peer the peer that received the addr or addrv2 message
* @param message the addr or addrv2 message that was received
*/
void onAddr(Peer peer, AddressMessage message);
}