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 @@ -3886,6 +3886,7 @@ fn test_threaded_payment_retries() {
38863886 while Instant :: now( ) < end_time {
38873887 node_a. node. get_and_clear_pending_events( ) ;
38883888 node_a. node. process_pending_htlc_forwards( ) ;
3889+ node_a. node. process_pending_htlc_forwards( ) ;
38893890 }
38903891 }
38913892 } } }
@@ -3950,7 +3951,12 @@ fn test_threaded_payment_retries() {
39503951 // Make sure we have some events to handle when we go around...
39513952 nodes[ 0 ] . node . get_and_clear_pending_events ( ) ;
39523953 nodes[ 0 ] . node . process_pending_htlc_forwards ( ) ;
3954+ nodes[ 0 ] . node . process_pending_htlc_forwards ( ) ;
39533955 send_msg_events = nodes[ 0 ] . node . get_and_clear_pending_msg_events ( ) ;
3956+
3957+ // We give the node some time for persistence to happen, before we check the added
3958+ // monitors.
3959+ std:: thread:: sleep ( Duration :: from_millis ( 100 ) ) ;
39543960 check_added_monitors ! ( nodes[ 0 ] , 2 ) ;
39553961
39563962 if cur_time > end_time {
You can’t perform that action at this time.
0 commit comments