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 @@ -3887,6 +3887,7 @@ fn test_threaded_payment_retries() {
38873887 while Instant :: now( ) < end_time {
38883888 node_a. node. get_and_clear_pending_events( ) ;
38893889 node_a. node. process_pending_htlc_forwards( ) ;
3890+ node_a. node. process_pending_htlc_forwards( ) ;
38903891 }
38913892 }
38923893 } } }
@@ -3951,7 +3952,12 @@ fn test_threaded_payment_retries() {
39513952 // Make sure we have some events to handle when we go around...
39523953 nodes[ 0 ] . node . get_and_clear_pending_events ( ) ;
39533954 nodes[ 0 ] . node . process_pending_htlc_forwards ( ) ;
3955+ nodes[ 0 ] . node . process_pending_htlc_forwards ( ) ;
39543956 send_msg_events = nodes[ 0 ] . node . get_and_clear_pending_msg_events ( ) ;
3957+
3958+ // We give the node some time for persistence to happen, before we check the added
3959+ // monitors.
3960+ std:: thread:: sleep ( Duration :: from_secs ( 1 ) ) ;
39553961 check_added_monitors ! ( nodes[ 0 ] , 2 ) ;
39563962
39573963 if cur_time > end_time {
You can’t perform that action at this time.
0 commit comments