projects
/
ldk-java
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
b52dde8
)
Fetch ChannelMonitor events during test and ensure there are none
author
Matt Corallo
<git@bluematt.me>
Wed, 3 Feb 2021 20:14:42 +0000
(15:14 -0500)
committer
Matt Corallo
<git@bluematt.me>
Fri, 5 Mar 2021 19:40:22 +0000
(14:40 -0500)
src/test/java/org/ldk/HumanObjectPeerTest.java
patch
|
blob
|
history
diff --git
a/src/test/java/org/ldk/HumanObjectPeerTest.java
b/src/test/java/org/ldk/HumanObjectPeerTest.java
index 807b33074b138b8e47adbe099615c2d5c9b7f6c6..d8d7d2ecf23347b6f48212a2b0ee9f28cbd77d8f 100644
(file)
--- a/
src/test/java/org/ldk/HumanObjectPeerTest.java
+++ b/
src/test/java/org/ldk/HumanObjectPeerTest.java
@@
-333,6
+333,20
@@
class HumanObjectPeerTestInstance {
return null;
}
return null;
}
+ Event[] get_monitor_events() {
+ if (chain_monitor != null) {
+ return chain_monitor.as_EventsProvider().get_and_clear_pending_events();
+ } else {
+ synchronized (monitors) {
+ assert monitors.size() == 1;
+ for (ChannelMonitor mon : monitors.values()) {
+ return mon.get_and_clear_pending_events();
+ }
+ return null;
+ }
+ }
+ }
+
Route get_route(byte[] dest_node, ChannelDetails[] our_chans) {
try (LockedNetworkGraph netgraph = this.router.read_locked_graph()) {
NetworkGraph graph = netgraph.graph();
Route get_route(byte[] dest_node, ChannelDetails[] our_chans) {
try (LockedNetworkGraph netgraph = this.router.read_locked_graph()) {
NetworkGraph graph = netgraph.graph();
@@
-517,6
+531,9
@@
class HumanObjectPeerTestInstance {
assert payment_res instanceof Result_NonePaymentSendFailureZ.Result_NonePaymentSendFailureZ_OK;
wait_events_processed(peer1, peer2);
assert payment_res instanceof Result_NonePaymentSendFailureZ.Result_NonePaymentSendFailureZ_OK;
wait_events_processed(peer1, peer2);
+ assert peer1.get_monitor_events().length == 0;
+ assert peer2.get_monitor_events().length == 0;
+
if (reload_peers) {
if (use_nio_peer_handler) {
peer1.nio_peer_handler.interrupt();
if (reload_peers) {
if (use_nio_peer_handler) {
peer1.nio_peer_handler.interrupt();
@@
-617,6
+634,9
@@
class HumanObjectPeerTestInstance {
state.peer1.nio_peer_handler.interrupt();
state.peer2.nio_peer_handler.interrupt();
}
state.peer1.nio_peer_handler.interrupt();
state.peer2.nio_peer_handler.interrupt();
}
+
+ assert state.peer1.get_monitor_events().length == 0;
+ assert state.peer2.get_monitor_events().length == 0;
}
java.util.LinkedList<WeakReference<Object>> must_free_objs = new java.util.LinkedList();
}
java.util.LinkedList<WeakReference<Object>> must_free_objs = new java.util.LinkedList();