File tree 2 files changed +5
-2
lines changed
2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,7 @@ mod communication_channel {
17
17
use iceoryx2_bb_posix:: unique_system_id:: UniqueSystemId ;
18
18
use iceoryx2_bb_system_types:: file_name:: FileName ;
19
19
use iceoryx2_bb_testing:: assert_that;
20
+ use iceoryx2_bb_testing:: watchdog:: Watchdog ;
20
21
use iceoryx2_cal:: communication_channel;
21
22
use iceoryx2_cal:: communication_channel:: * ;
22
23
use iceoryx2_cal:: named_concept:: * ;
@@ -366,6 +367,8 @@ mod communication_channel {
366
367
367
368
#[ test]
368
369
fn custom_suffix_keeps_channels_separated < Sut : CommunicationChannel < usize > > ( ) {
370
+ let _watch_dog = Watchdog :: new ( ) ;
371
+
369
372
let config_1 = <Sut as NamedConceptMgmt >:: Configuration :: default ( )
370
373
. suffix ( unsafe { FileName :: new_unchecked ( b".s1" ) } ) ;
371
374
let config_2 = <Sut as NamedConceptMgmt >:: Configuration :: default ( )
Original file line number Diff line number Diff line change @@ -433,7 +433,7 @@ mod service_event {
433
433
434
434
#[ test]
435
435
fn concurrent_reconnecting_notifier_can_trigger_waiting_listener < Sut : Service > ( ) {
436
- let _watch_dog = Watchdog :: new ( ) ;
436
+ let _watch_dog = Watchdog :: new_with_timeout ( Duration :: from_secs ( 120 ) ) ;
437
437
438
438
let number_of_listener_threads = ( SystemInfo :: NumberOfCpuCores . value ( ) * 2 ) . clamp ( 2 , 16 ) ;
439
439
let number_of_notifier_threads = ( SystemInfo :: NumberOfCpuCores . value ( ) * 2 ) . clamp ( 2 , 16 ) ;
@@ -490,7 +490,7 @@ mod service_event {
490
490
491
491
#[ test]
492
492
fn concurrent_reconnecting_listener_can_wait_for_triggering_notifiers < Sut : Service > ( ) {
493
- let _watch_dog = Watchdog :: new ( ) ;
493
+ let _watch_dog = Watchdog :: new_with_timeout ( Duration :: from_secs ( 120 ) ) ;
494
494
495
495
let number_of_listener_threads = ( SystemInfo :: NumberOfCpuCores . value ( ) * 2 ) . clamp ( 2 , 16 ) ;
496
496
let number_of_notifier_threads = ( SystemInfo :: NumberOfCpuCores . value ( ) * 2 ) . clamp ( 2 , 16 ) ;
You can’t perform that action at this time.
0 commit comments