File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -3883,6 +3883,7 @@ fn test_threaded_payment_retries() {
38833883 while Instant :: now( ) < end_time {
38843884 node_a. node. get_and_clear_pending_events( ) ;
38853885 node_a. node. process_pending_htlc_forwards( ) ;
3886+ node_a. node. process_pending_htlc_forwards( ) ;
38863887 }
38873888 }
38883889 } } }
@@ -3947,7 +3948,12 @@ fn test_threaded_payment_retries() {
39473948 // Make sure we have some events to handle when we go around...
39483949 nodes[ 0 ] . node . get_and_clear_pending_events ( ) ;
39493950 nodes[ 0 ] . node . process_pending_htlc_forwards ( ) ;
3951+ nodes[ 0 ] . node . process_pending_htlc_forwards ( ) ;
39503952 send_msg_events = nodes[ 0 ] . node . get_and_clear_pending_msg_events ( ) ;
3953+
3954+ // We give the node some time for persistence to happen, before we check the added
3955+ // monitors.
3956+ std:: thread:: sleep ( Duration :: from_millis ( 10 ) ) ;
39513957 check_added_monitors ! ( nodes[ 0 ] , 2 ) ;
39523958
39533959 if cur_time > end_time {
You can’t perform that action at this time.
0 commit comments