@@ -1095,7 +1095,6 @@ pub(crate) mod tests {
10951095 cancel. cancelled ( ) . await ;
10961096 router. shutdown ( ) . await . ok ( ) ;
10971097 drop ( router) ;
1098- tracing:: info!( "ROUTER DROPPED" ) ;
10991098 } ) ;
11001099 let router_fut = async move {
11011100 router_task. await . expect ( "router task panicked" ) ;
@@ -1389,7 +1388,7 @@ pub(crate) mod tests {
13891388
13901389 // cleanup and ensure everything went as expected
13911390 ct. cancel ( ) ;
1392- let wait = Duration :: from_secs ( 2 ) ;
1391+ let wait = Duration :: from_secs ( 5 ) ;
13931392 timeout ( wait, ep1_handle) . await . e ( ) ?;
13941393 timeout ( wait, ep2_handle) . await . e ( ) ?;
13951394 timeout ( wait, go1_handle) . await . e ( ) ?. e ( ) ??;
@@ -1465,7 +1464,7 @@ pub(crate) mod tests {
14651464
14661465 info ! ( "wait for neighbor down" ) ;
14671466 // we should receive a Neighbor down event
1468- let conn_timeout = Duration :: from_millis ( 500 ) ;
1467+ let conn_timeout = Duration :: from_millis ( 1000 ) ;
14691468 let ev = timeout ( conn_timeout, sub. try_next ( ) ) . await . e ( ) ??;
14701469 assert_eq ! ( ev, Some ( Event :: NeighborDown ( node_id2) ) ) ;
14711470 tracing:: info!( "node 2 left" ) ;
@@ -1474,7 +1473,7 @@ pub(crate) mod tests {
14741473 tx. send ( ( ) ) . await . e ( ) ?;
14751474
14761475 info ! ( "wait for neighbor up" ) ;
1477- let conn_timeout = Duration :: from_millis ( 500 ) ;
1476+ let conn_timeout = Duration :: from_millis ( 1000 ) ;
14781477 let ev = timeout ( conn_timeout, sub. try_next ( ) ) . await . e ( ) ??;
14791478 assert_eq ! ( ev, Some ( Event :: NeighborUp ( node_id2) ) ) ;
14801479 tracing:: info!( "node 2 rejoined!" ) ;
0 commit comments